Documentation ¶
Overview ¶
Package consumers contain the domain concept definitions needed to support Mainflux consumer services functionality.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Start ¶
func Start(sub messaging.Subscriber, consumer Consumer, transformer transformers.Transformer, subjectsCfgPath string, logger logger.Logger) error
Start method starts consuming messages received from NATS. This method transforms messages to SenML format before using MessageRepository to store them.
Types ¶
Directories ¶
Path | Synopsis |
---|---|
Package notifiers contain the domain concept definitions needed to support Mainflux notifications functionality.
|
Package notifiers contain the domain concept definitions needed to support Mainflux notifications functionality. |
api
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
|
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations. |
postgres
Package postgres contains repository implementations using PostgreSQL as the underlying database.
|
Package postgres contains repository implementations using PostgreSQL as the underlying database. |
smtp
Package smtp contains the domain concept definitions needed to support Mainflux SMTP notifications.
|
Package smtp contains the domain concept definitions needed to support Mainflux SMTP notifications. |
tracing
Package tracing contains middlewares that will add spans to existing traces.
|
Package tracing contains middlewares that will add spans to existing traces. |
Package writers contain the domain concept definitions needed to support Mainflux writer services functionality.
|
Package writers contain the domain concept definitions needed to support Mainflux writer services functionality. |
cassandra
Package cassandra contains the domain concept definitions needed to support Mainflux Cassandra writer service.
|
Package cassandra contains the domain concept definitions needed to support Mainflux Cassandra writer service. |
influxdb
Package influxdb contains the domain concept definitions needed to support Mainflux InfluxDB writer service functionality.
|
Package influxdb contains the domain concept definitions needed to support Mainflux InfluxDB writer service functionality. |
mongodb
Package mongodb contains the domain concept definitions needed to support Mainflux MondoDB writer service functionality.
|
Package mongodb contains the domain concept definitions needed to support Mainflux MondoDB writer service functionality. |
postgres
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.