Versions in this module Expand all Collapse all v0 v0.20.0 Nov 6, 2022 Changes in this version + const MetadataLabelOtel + var ErrConflict = errors.New("entity already exists") + var ErrConflictSink = errors.New("entity already exists") + var ErrCreateSink = errors.New("failed to create Sink") + var ErrEntityConnected = errors.New("check connection in database error") + var ErrInvalidBackend = errors.New("No available backends") + var ErrMalformedEntity = errors.New("malformed entity specification") + var ErrNotFound = errors.New("non-existent entity") + var ErrRemoveEntity = errors.New("failed to remove entity") + var ErrScanMetadata = errors.New("failed to scan metadata in db") + var ErrSelectEntity = errors.New("select entity from db error") + var ErrUnauthorizedAccess = errors.New("missing or invalid credentials provided") + var ErrUnsupportedContentTypeSink = errors.New("unsupported content type") + var ErrUpdateEntity = errors.New("failed to update entity") + var ErrValidateSink = errors.New("failed to validate Sink") + func NewPasswordService(logger *zap.Logger, key string) *passwordService + type Filter struct + OpenTelemetry string + StateFilter string + type Page struct + Sinks []Sink + type PageMetadata struct + Dir string + Limit uint64 + Metadata types.Metadata + Name string + Offset uint64 + Order string + Tags types.Tags + Total uint64 + type PasswordService interface + DecodePassword func(cipheredText string) (string, error) + EncodePassword func(plainText string) (string, error) + SetKey func(newKey string) + type Sink struct + Backend string + Config types.Metadata + Created time.Time + Description string + Error string + ID string + MFOwnerID string + Name types.Identifier + State State + Tags types.Tags + type SinkRepository interface + Remove func(ctx context.Context, owner string, key string) error + RetrieveAllByOwnerID func(ctx context.Context, owner string, pm PageMetadata) (Page, error) + RetrieveById func(ctx context.Context, key string) (Sink, error) + RetrieveByOwnerAndId func(ctx context.Context, ownerID string, key string) (Sink, error) + Save func(ctx context.Context, sink Sink) (string, error) + SearchAllSinks func(ctx context.Context, filter Filter) ([]Sink, error) + Update func(ctx context.Context, sink Sink) error + UpdateSinkState func(ctx context.Context, sinkID string, msg string, ownerID string, state State) error + type SinkService interface + ChangeSinkStateInternal func(ctx context.Context, sinkID string, msg string, ownerID string, state State) error + CreateSink func(ctx context.Context, token string, s Sink) (Sink, error) + DeleteSink func(ctx context.Context, token string, key string) error + ListBackends func(ctx context.Context, token string) ([]string, error) + ListSinks func(ctx context.Context, token string, pm PageMetadata) (Page, error) + ListSinksInternal func(ctx context.Context, filter Filter) ([]Sink, error) + UpdateSink func(ctx context.Context, token string, s Sink) (Sink, error) + ValidateSink func(ctx context.Context, token string, sink Sink) (Sink, error) + ViewBackend func(ctx context.Context, token string, key string) (backend.Backend, error) + ViewSink func(ctx context.Context, token string, key string) (Sink, error) + ViewSinkInternal func(ctx context.Context, ownerID string, key string) (Sink, error) + func NewSinkService(logger *zap.Logger, auth mainflux.AuthServiceClient, sinkRepo SinkRepository, ...) SinkService + type State int + const Active + const Error + const Idle + const Unknown + func (s *State) Scan(value interface{}) error + func (s State) String() string + func (s State) Value() (driver.Value, error)
Go to main page