bdkeeper

Documentation

Index

• type BDKeeper
  • func NewBDKeeper(dsn func() string, log Log, userUpdateInterval func() string) *BDKeeper
  • func (kp *BDKeeper) Close() bool
  • func (kp *BDKeeper) GetMessages(ctx context.Context, filter models.Filter, pagination models.Pagination) ([]models.Message, error)
  • func (kp *BDKeeper) InsertMessage(ctx context.Context, message models.Message) (int, error)
  • func (kp *BDKeeper) LoadMessages(ctx context.Context) (storage.StorageMessage, error)
  • func (kp *BDKeeper) Ping(ctx context.Context) bool
  • func (kp *BDKeeper) UpdateMessagesProcessed(ctx context.Context, ids []int) error
• type Log

Types

type BDKeeper

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

func NewBDKeeper

func NewBDKeeper(dsn func() string, log Log, userUpdateInterval func() string) *BDKeeper

func (*BDKeeper) Close

func (kp *BDKeeper) Close() bool

func (*BDKeeper) GetMessages

func (kp *BDKeeper) GetMessages(ctx context.Context, filter models.Filter, pagination models.Pagination) ([]models.Message, error)

GetMessages retrieves processed messages from the database based on the provided filter and pagination

func (*BDKeeper) InsertMessage

func (kp *BDKeeper) InsertMessage(ctx context.Context, message models.Message) (int, error)

InsertMessage inserts a new message into the database

func (*BDKeeper) LoadMessages

func (kp *BDKeeper) LoadMessages(ctx context.Context) (storage.StorageMessage, error)

LoadMessages loads messages from the database

func (*BDKeeper) Ping

func (kp *BDKeeper) Ping(ctx context.Context) bool

func (*BDKeeper) UpdateMessagesProcessed

func (kp *BDKeeper) UpdateMessagesProcessed(ctx context.Context, ids []int) error

UpdateMessagesProcessed updates the processed status of messages in the database

type Log

type Log interface {
	Info(string, ...zap.Field)
}