writers

README

Writers

Writers provide an implementation of various message writers. Message writers are services that normalize (in SenML format) Mainflux messages and store them in specific data store.

Writers are optional services and are treated as plugins. In order to run writer services, core services must be up and running. For more info on the platform core services with its dependencies, please check out the Docker Compose file.

For an in-depth explanation of the usage of writers, as well as thorough understanding of Mainflux, please check out the official documentation.

Documentation

Overview

Package writers contain the domain concept definitions needed to support Mainflux writer services functionality.

Index

• func Start(sub messaging.Subscriber, repo MessageRepository, ...) error
• type MessageRepository

Functions

func Start

func Start(sub messaging.Subscriber, repo MessageRepository, transformer transformers.Transformer, queue string, 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

type MessageRepository

type MessageRepository interface {
	// Save method is used to save published message. A non-nil
	// error is returned to indicate  operation failure.
	Save(messages ...senml.Message) error
}

MessageRepository specifies message writing API.