consumers

README

Consumers

Consumers provide an abstraction of various Mainflux consumers. Mainflux consumer is a generic service that can handle received messages - consume them. The message is not necessarily a Mainflux message - before consuming, Mainflux message can be transformed into any valid format that specific consumer can understand. For example, writers are consumers that can take a SenML or JSON message and store it.

Consumers are optional services and are treated as plugins. In order to run consumer services, core services must be up and running.

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

For more information about service capabilities and its usage, please check out the API documentation.

Documentation

Overview

Package consumers contain the domain concept definitions needed to support Mainflux consumer services functionality.

Index

• func Start(id string, sub messaging.Subscriber, consumer Consumer, subjects ...string) error
• type Consumer

Functions

func Start

func Start(id string, sub messaging.Subscriber, consumer Consumer, subjects ...string) error

Start method starts consuming messages received from Message broker.

Types

type Consumer

type Consumer interface {
	// Consume method is used to consumed received messages.
	// A non-nil error is returned to indicate operation failure.
	Consume(messages interface{}) error
}

Consumer specifies message consuming API.