postgresql

Documentation

Index

• type PostgreSQL
  • func MustCreate(cfg config.PersistentStorage) *PostgreSQL
  • func (p *PostgreSQL) ProcessedCount(ctx context.Context) (dto.Processed, error)
  • func (p *PostgreSQL) SaveMessage(ctx context.Context, data dto.MessageID) error
  • func (p *PostgreSQL) UpdateStatus(ctx context.Context, id uuid.UUID) error

Types

type PostgreSQL

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

PostgreSQL структура, хранящая пул соединений, их максимальное количество и текущую схему базы данных.

func MustCreate

func MustCreate(cfg config.PersistentStorage) *PostgreSQL

MustCreate возвращает структуру для взаимодействия с базой данных в СУБД PostgreSQL. В случае ошибки завершает работу всего приложения.

func (*PostgreSQL) ProcessedCount

func (p *PostgreSQL) ProcessedCount(ctx context.Context) (dto.Processed, error)

ProcessedCount возвращает сумму обработанных сообщений за последний час, день, неделю, месяц.

func (*PostgreSQL) SaveMessage

func (p *PostgreSQL) SaveMessage(ctx context.Context, data dto.MessageID) error

SaveMessage сохраняет сообщение и его идентификатор в БД. Статус сообщения сохраняется по умолчанию (status.InProcessing).

func (*PostgreSQL) UpdateStatus

func (p *PostgreSQL) UpdateStatus(ctx context.Context, id uuid.UUID) error

UpdateStatus статус сообщения с идентификатором id обновляется на status.Processed.