repository

Documentation

Index

• type Repository
  • func New(dbFilePath string) *Repository
  • func (r *Repository) Create(ctx context.Context, log *logger.Logger, params *model.SaveMessageParams) error
  • func (r *Repository) Delete(ctx context.Context, log *logger.Logger, params *model.DeleteMessageParams) error
  • func (r *Repository) GetBatch(ctx context.Context, log *logger.Logger) ([]*model.Message, error)
  • func (r *Repository) ReadUserMessages(ctx context.Context, log *logger.Logger, params *model.ReadUserMessagesParams) (*model.ReadUserMessagesResult, error)
  • func (r *Repository) Truncate(ctx context.Context, log *logger.Logger) error
  • func (r *Repository) Update(ctx context.Context, log *logger.Logger, params *model.UpdateMessageParams) error

Types

type Repository

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

func New

func New(dbFilePath string) *Repository

func (*Repository) Create

func (r *Repository) Create(ctx context.Context, log *logger.Logger, params *model.SaveMessageParams) error

*

• Receives message id from params;
• Does not put message with same id
• twice

func (*Repository) Delete

func (r *Repository) Delete(ctx context.Context, log *logger.Logger, params *model.DeleteMessageParams) error

func (*Repository) GetBatch

func (r *Repository) GetBatch(ctx context.Context, log *logger.Logger) ([]*model.Message, error)

func (*Repository) ReadUserMessages

func (r *Repository) ReadUserMessages(ctx context.Context, log *logger.Logger, params *model.ReadUserMessagesParams) (
	*model.ReadUserMessagesResult, error,
)

func (*Repository) Truncate

func (r *Repository) Truncate(ctx context.Context, log *logger.Logger) error

func (*Repository) Update

func (r *Repository) Update(ctx context.Context, log *logger.Logger, params *model.UpdateMessageParams) error