Versions in this module Expand all Collapse all v0 v0.0.1 Oct 16, 2020 Changes in this version + const SubtopicWildcard + var ErrConflict = errors.New("entity already exists") + var ErrMalformedEntity = errors.New("malformed entity specification") + var ErrNotFound = errors.New("non-existent entity") + var ErrUnauthorizedAccess = errors.New("missing or invalid credentials provided") + type Attribute struct + Channel string + Name string + PersistState bool + Subtopic string + type Definition struct + Attributes []Attribute + Created time.Time + Delta int64 + ID int + type Metadata map[string]interface + type Page struct + Twins []Twin + type PageMetadata struct + Limit uint64 + Offset uint64 + Total uint64 + type Service interface + AddTwin func(ctx context.Context, token string, twin Twin, def Definition) (tw Twin, err error) + ListStates func(ctx context.Context, token string, offset uint64, limit uint64, twinID string) (StatesPage, error) + ListTwins func(ctx context.Context, token string, offset uint64, limit uint64, name string, ...) (Page, error) + RemoveTwin func(ctx context.Context, token, twinID string) (err error) + SaveStates func(msg *messaging.Message) error + UpdateTwin func(ctx context.Context, token string, twin Twin, def Definition) (err error) + ViewTwin func(ctx context.Context, token, twinID string) (tw Twin, err error) + func New(publisher messaging.Publisher, auth mainflux.AuthNServiceClient, ...) Service + type State struct + Created time.Time + Definition int + ID int64 + Payload map[string]interface{} + TwinID string + type StateRepository interface + Count func(ctx context.Context, twin Twin) (int64, error) + RetrieveAll func(ctx context.Context, offset uint64, limit uint64, twinID string) (StatesPage, error) + RetrieveLast func(ctx context.Context, twinID string) (State, error) + Save func(ctx context.Context, state State) error + Update func(ctx context.Context, state State) error + type StatesPage struct + States []State + type Twin struct + Created time.Time + Definitions []Definition + ID string + Metadata Metadata + Name string + Owner string + Revision int + Updated time.Time + type TwinCache interface + IDs func(ctx context.Context, channel, subtopic string) ([]string, error) + Remove func(ctx context.Context, twinID string) error + Save func(ctx context.Context, twin Twin) error + SaveIDs func(ctx context.Context, channel, subtopic string, twinIDs []string) error + Update func(ctx context.Context, twin Twin) error + type TwinRepository interface + Remove func(ctx context.Context, twinID string) error + RetrieveAll func(ctx context.Context, owner string, offset, limit uint64, name string, ...) (Page, error) + RetrieveByAttribute func(ctx context.Context, channel, subtopic string) ([]string, error) + RetrieveByID func(ctx context.Context, twinID string) (Twin, error) + Save func(ctx context.Context, twin Twin) (string, error) + Update func(ctx context.Context, twin Twin) error