commandstore

Documentation

Index

• type Store
  • func NewStore(ds datastore.DataStore, c cache.Cache, logger *zap.Logger) Store

Types

type Store

type Store interface {
	ListUnhandledCommands(ctx context.Context, pipedID string) ([]*model.Command, error)
	AddCommand(ctx context.Context, command *model.Command) error
	GetCommand(ctx context.Context, id string) (*model.Command, error)
	UpdateCommandHandled(ctx context.Context, id string, status model.CommandStatus, metadata map[string]string, unhandledAt int64) error
}

func NewStore

func NewStore(ds datastore.DataStore, c cache.Cache, logger *zap.Logger) Store