postgres

Documentation

Index

• type Postgres
  • func (this *Postgres) Disconnect() error
  • func (this Postgres) Healthy(ctx context.Context) error
  • func (this *Postgres) Init(queues []string) error
  • func (this Postgres) MaxConcurrentDrainWorkers() int
  • func (this *Postgres) PassConnection(connection *sql.DB)
  • func (this *Postgres) Pop(ctx context.Context, queueName string, handler types.Handler) error
  • func (this Postgres) Publish(ctx context.Context, queueName string, payload *types.Task) error
  • func (this Postgres) Purge(ctx context.Context, queueName string) error
  • func (this Postgres) PurgeMatching(ctx context.Context, queueName, substr string) error
  • func (this Postgres) Subscribe(ctx context.Context, queueName string, handler types.Handler) error
  • func (this Postgres) Suck(ctx context.Context, queueName string, handler types.Handler) error
• type Querier

Types

type Postgres

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

func (*Postgres) Disconnect

func (this *Postgres) Disconnect() error

func (Postgres) Healthy

func (this Postgres) Healthy(ctx context.Context) error

func (*Postgres) Init

func (this *Postgres) Init(queues []string) error

func (Postgres) MaxConcurrentDrainWorkers

func (this Postgres) MaxConcurrentDrainWorkers() int

func (*Postgres) PassConnection

func (this *Postgres) PassConnection(connection *sql.DB)

func (*Postgres) Pop

func (this *Postgres) Pop(ctx context.Context, queueName string, handler types.Handler) error

func (Postgres) Publish

func (this Postgres) Publish(ctx context.Context, queueName string, payload *types.Task) error

func (Postgres) Purge

func (this Postgres) Purge(ctx context.Context, queueName string) error

func (Postgres) PurgeMatching

func (this Postgres) PurgeMatching(ctx context.Context, queueName, substr string) error

func (Postgres) Subscribe

func (this Postgres) Subscribe(ctx context.Context, queueName string, handler types.Handler) error

func (Postgres) Suck

func (this Postgres) Suck(ctx context.Context, queueName string, handler types.Handler) error

type Querier

type Querier interface {
	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
	QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
}