repository

Documentation

Index

• type MessagePostgres
  • func NewMessagePostgres(client mrstorage.DBConnManager, table mrsql.DBTableInfo) *MessagePostgres
  • func (re *MessagePostgres) DeleteByIDs(ctx context.Context, rowsIDs []uint64) error
  • func (re *MessagePostgres) FetchByIDs(ctx context.Context, rowsIDs []uint64) ([]entity.Message, error)
  • func (re *MessagePostgres) Insert(ctx context.Context, rows []entity.Message) error

Types

type MessagePostgres

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

MessagePostgres - репозиторий для хранения сообщений подготовленных для отправки различным получателям.

func NewMessagePostgres

func NewMessagePostgres(client mrstorage.DBConnManager, table mrsql.DBTableInfo) *MessagePostgres

NewMessagePostgres - создаёт объект MessagePostgres.

func (*MessagePostgres) DeleteByIDs

func (re *MessagePostgres) DeleteByIDs(ctx context.Context, rowsIDs []uint64) error

DeleteByIDs - удаляет сообщения по их указанным ID.

func (*MessagePostgres) FetchByIDs

func (re *MessagePostgres) FetchByIDs(ctx context.Context, rowsIDs []uint64) ([]entity.Message, error)

FetchByIDs - возвращает список сообщений по их указанным ID.

func (*MessagePostgres) Insert

func (re *MessagePostgres) Insert(ctx context.Context, rows []entity.Message) error

Insert - вставляет новое сообщение.