Versions in this module Expand all Collapse all v0 v0.0.1 Oct 16, 2020 Changes in this version + var ErrOption = errors.New("unable to set option") + var ErrUnauthorized = errors.New("unauthorized access") + var ErrUnsubscribe = errors.New("unable to unsubscribe") + type Client interface + Cancel func() error + Done func() <-chan struct{} + SendMessage func(m messaging.Message) error + Token func() string + func NewClient(mc mux.Client, token message.Token, l logger.Logger) Client + type Observer interface + Cancel func() error + func NewObserver(subject string, c Client, conn *broker.Conn) (Observer, error) + type Service interface + Publish func(ctx context.Context, key string, msg messaging.Message) error + Subscribe func(ctx context.Context, key, chanID, subtopic string, c Client) error + Unsubscribe func(ctx context.Context, key, chanID, subptopic, token string) error + func New(auth mainflux.ThingsServiceClient, nc *broker.Conn) Service