infrastructure

Documentation

Index

• func QueryCriteriaDynamo(value string, query *docstore.Query) *docstore.Query
• type WatcherDynamoRepository
  • func NewWatcherDynamoRepository(ctx context.Context, logger log.Logger, config *config.KernelConfig) (*WatcherDynamoRepository, func(), error)
  • func (r *WatcherDynamoRepository) Fetch(params *util.PaginationParams, filterParams util.FilterParams) ([]*domain.WatcherEntity, error)
  • func (r *WatcherDynamoRepository) FetchByID(id string) (*domain.WatcherEntity, error)
  • func (r *WatcherDynamoRepository) Remove(id string) error
  • func (r *WatcherDynamoRepository) Save(watcher *domain.WatcherEntity) error
  • func (r *WatcherDynamoRepository) Update(watcherUpdated *domain.WatcherEntity) error

Functions

func QueryCriteriaDynamo

func QueryCriteriaDynamo(value string, query *docstore.Query) *docstore.Query

Types

type WatcherDynamoRepository

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

WatcherDynamoRepository Watcher Repository interface implementation in AWS DynamoDB

func NewWatcherDynamoRepository

func NewWatcherDynamoRepository(ctx context.Context, logger log.Logger, config *config.KernelConfig) (*WatcherDynamoRepository, func(), error)

func (*WatcherDynamoRepository) Fetch

func (r *WatcherDynamoRepository) Fetch(params *util.PaginationParams, filterParams util.FilterParams) ([]*domain.WatcherEntity, error)

func (*WatcherDynamoRepository) FetchByID

func (r *WatcherDynamoRepository) FetchByID(id string) (*domain.WatcherEntity, error)

func (*WatcherDynamoRepository) Remove

func (r *WatcherDynamoRepository) Remove(id string) error

func (*WatcherDynamoRepository) Save

func (r *WatcherDynamoRepository) Save(watcher *domain.WatcherEntity) error

func (*WatcherDynamoRepository) Update

func (r *WatcherDynamoRepository) Update(watcherUpdated *domain.WatcherEntity) error