Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNotFound = errors.New("entity not found")
ErrNotFound indicates that requested entity doesn't exist.
Functions ¶
This section is empty.
Types ¶
type MessageRepository ¶
type MessageRepository interface { // ReadAll skips given number of messages for given channel and returns next // limited number of messages. ReadAll(chanID string, offset, limit uint64, query map[string]string) (MessagesPage, error) }
MessageRepository specifies message reader API.
Directories
¶
Path | Synopsis |
---|---|
Package cassandra contains Cassandra specific reader implementation.
|
Package cassandra contains Cassandra specific reader implementation. |
Package influxdb contains the domain concept definitions needed to support Mainflux InfluxDB reader service functionality.
|
Package influxdb contains the domain concept definitions needed to support Mainflux InfluxDB reader service functionality. |
Package mongodb contains the domain concept definitions needed to support Mainflux MondoDB reader service functionality.
|
Package mongodb contains the domain concept definitions needed to support Mainflux MondoDB reader service functionality. |
Package postgres contains repository implementations using Postgres as the underlying database.
|
Package postgres contains repository implementations using Postgres as the underlying database. |
Click to show internal directories.
Click to hide internal directories.