repository

Documentation

Index

• type MessageRepository
  • func NewMessageRepository(db db) *MessageRepository
  • func (r *MessageRepository) Create(ctx context.Context, model *model.Message) error
  • func (r *MessageRepository) RetrieveAll(ctx context.Context, filters model.DbFilters[model.Message]) ([]model.Message, error)
  • func (r *MessageRepository) RetrieveMessagesForProcess(ctx context.Context, limit int) ([]model.Message, error)
  • func (r *MessageRepository) Update(ctx context.Context, model *model.Message, updates map[string]interface{}) error

Types

type MessageRepository

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

func NewMessageRepository

func NewMessageRepository(db db) *MessageRepository

func (*MessageRepository) Create

func (r *MessageRepository) Create(ctx context.Context, model *model.Message) error

func (*MessageRepository) RetrieveAll

func (r *MessageRepository) RetrieveAll(ctx context.Context, filters model.DbFilters[model.Message]) ([]model.Message, error)

func (*MessageRepository) RetrieveMessagesForProcess

func (r *MessageRepository) RetrieveMessagesForProcess(ctx context.Context, limit int) ([]model.Message, error)

func (*MessageRepository) Update

func (r *MessageRepository) Update(ctx context.Context, model *model.Message, updates map[string]interface{}) error