source

Documentation

Index

• type SourceAPI
  • func New(ctx context.Context, logger *zap.Logger, storage storageTY.Plugin, ...) *SourceAPI
  • func (s *SourceAPI) Delete(IDs []string) (int64, error)
  • func (s *SourceAPI) Get(filters []storageTY.Filter) (*sourceTY.Source, error)
  • func (s *SourceAPI) GetByIDs(gatewayID, nodeID, sourceID string) (*sourceTY.Source, error)
  • func (s *SourceAPI) GetEntityInterface() interface{}
  • func (s *SourceAPI) Import(data interface{}) error
  • func (s *SourceAPI) List(filters []storageTY.Filter, pagination *storageTY.Pagination) (*storageTY.Result, error)
  • func (s *SourceAPI) Save(source *sourceTY.Source) error

Types

type SourceAPI

type SourceAPI struct {
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, logger *zap.Logger, storage storageTY.Plugin, bus busTY.Plugin) *SourceAPI

func (*SourceAPI) Delete

func (s *SourceAPI) Delete(IDs []string) (int64, error)

Delete source

func (*SourceAPI) Get

func (s *SourceAPI) Get(filters []storageTY.Filter) (*sourceTY.Source, error)

Get returns a source

func (*SourceAPI) GetByIDs

func (s *SourceAPI) GetByIDs(gatewayID, nodeID, sourceID string) (*sourceTY.Source, error)

GetByIDs returns a source details by gatewayID, nodeId and sourceID of a message

func (*SourceAPI) GetEntityInterface

func (s *SourceAPI) GetEntityInterface() interface{}

func (*SourceAPI) Import

func (s *SourceAPI) Import(data interface{}) error

func (*SourceAPI) List

func (s *SourceAPI) List(filters []storageTY.Filter, pagination *storageTY.Pagination) (*storageTY.Result, error)

List by filter and pagination

func (*SourceAPI) Save

func (s *SourceAPI) Save(source *sourceTY.Source) error

Save a source details