pg

Documentation

Index

• type Postgres
  • func (pg *Postgres) AddMessage(ctx context.Context, tx *sqlx.Tx, message types.Outbox) error
  • func (pg *Postgres) GetMessagesFromPos(ctx context.Context, processName string, position int64, limit int) ([]types.Outbox, error)
  • func (pg *Postgres) GetPositionWithLock(ctx context.Context, processName string) (int64, error)
  • func (pg *Postgres) Init(option *types.Option)
  • func (pg *Postgres) SetPosition(ctx context.Context, processName string, position int64) error
  • func (pg *Postgres) UpsertCursor(ctx context.Context, cursor types.Cursor) error

Types

type Postgres

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

func (*Postgres) AddMessage

func (pg *Postgres) AddMessage(
	ctx context.Context,
	tx *sqlx.Tx,
	message types.Outbox,
) error

AddMessage adds message to outbox

func (*Postgres) GetMessagesFromPos

func (pg *Postgres) GetMessagesFromPos(
	ctx context.Context,
	processName string,
	position int64,
	limit int,
) ([]types.Outbox, error)

func (*Postgres) GetPositionWithLock

func (pg *Postgres) GetPositionWithLock(ctx context.Context, processName string) (int64, error)

func (*Postgres) Init

func (pg *Postgres) Init(option *types.Option)

func (*Postgres) SetPosition

func (pg *Postgres) SetPosition(ctx context.Context, processName string, position int64) error

func (*Postgres) UpsertCursor

func (pg *Postgres) UpsertCursor(ctx context.Context, cursor types.Cursor) error