config

Documentation

Index

• func NewTask(manager *pgqueue.Manager, threads uint) (server.Task, error)
• type Config
  • func (c Config) Description() string
  • func (c Config) Name() string
  • func (c Config) New(ctx context.Context) (server.Task, error)

Functions

func NewTask

func NewTask(manager *pgqueue.Manager, threads uint) (server.Task, error)

Types

type Config

type Config struct {
	Pool      server.PG         `kong:"-"`           // Connection pool
	Router    server.HTTPRouter `kong:"-"`           // Which HTTP router to use
	Namespace *string           `help:"Namespace"`   // Namespace for queues and tickers
	Worker    *string           `help:"Worker name"` // The name of the worker
}

func (Config) Description

func (c Config) Description() string

func (Config) Name

func (c Config) Name() string

func (Config) New

func (c Config) New(ctx context.Context) (server.Task, error)