msg

Documentation

Index

• func CreateTables(ctx context.Context, chDB *ch.DB, pgDB *bun.DB) error
• type Repository
  • func NewRepository(ck *ch.DB, pg *bun.DB) *Repository
  • func (r *Repository) AddMessagePayloads(ctx context.Context, tx bun.Tx, payloads []*core.MessagePayload) error
  • func (r *Repository) AddMessages(ctx context.Context, tx bun.Tx, messages []*core.Message) error
  • func (r *Repository) AggregateMessages(ctx context.Context, req *aggregate.MessagesReq) (*aggregate.MessagesRes, error)
  • func (r *Repository) AggregateMessagesHistory(ctx context.Context, req *history.MessagesReq) (*history.MessagesRes, error)
  • func (r *Repository) FilterMessages(ctx context.Context, req *filter.MessagesReq) (*filter.MessagesRes, error)

Functions

func CreateTables

func CreateTables(ctx context.Context, chDB *ch.DB, pgDB *bun.DB) error

Types

type Repository

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

func NewRepository

func NewRepository(ck *ch.DB, pg *bun.DB) *Repository

func (*Repository) AddMessagePayloads

func (r *Repository) AddMessagePayloads(ctx context.Context, tx bun.Tx, payloads []*core.MessagePayload) error

func (*Repository) AddMessages

func (r *Repository) AddMessages(ctx context.Context, tx bun.Tx, messages []*core.Message) error

func (*Repository) AggregateMessages

func (r *Repository) AggregateMessages(ctx context.Context, req *aggregate.MessagesReq) (*aggregate.MessagesRes, error)

func (*Repository) AggregateMessagesHistory

func (r *Repository) AggregateMessagesHistory(ctx context.Context, req *history.MessagesReq) (*history.MessagesRes, error)

func (*Repository) FilterMessages

func (r *Repository) FilterMessages(ctx context.Context, req *filter.MessagesReq) (*filter.MessagesRes, error)