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") + 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 Service interface + Publish func(ctx context.Context, token 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(publisher messaging.Publisher, things mainflux.ThingsServiceClient) Service