backend

Documentation

Index

• type PostgresBackend
  • func NewPostgresBackend(ctx context.Context, config cli.BackendConfig) (*PostgresBackend, error)
  • func (r *PostgresBackend) Ack(ctx context.Context, msg cli.Message) error
  • func (r *PostgresBackend) AllMessages(ctx context.Context) ([]cli.Message, error)
  • func (r *PostgresBackend) Requeue(ctx context.Context, msg cli.Message) error
• type PostgresMessage

Types

type PostgresBackend

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

func NewPostgresBackend

func NewPostgresBackend(ctx context.Context, config cli.BackendConfig) (*PostgresBackend, error)

func (*PostgresBackend) Ack

func (r *PostgresBackend) Ack(ctx context.Context, msg cli.Message) error

func (*PostgresBackend) AllMessages

func (r *PostgresBackend) AllMessages(ctx context.Context) ([]cli.Message, error)

func (*PostgresBackend) Requeue

func (r *PostgresBackend) Requeue(ctx context.Context, msg cli.Message) error

type PostgresMessage

type PostgresMessage struct {
	Offset   int    `db:"offset"`
	UUID     string `db:"uuid"`
	Payload  string `db:"payload"`
	Metadata string `db:"metadata"`
}