Documentation
¶
Index ¶
- Variables
- type HandlerFunc
- type Middleware
- type Pool
- func (p *Pool) IsRunning() bool
- func (p *Pool) MustRegisterHandler(jobType string, handler HandlerFunc)
- func (p *Pool) Queues() []string
- func (p *Pool) RegisterHandler(jobType string, handler HandlerFunc) error
- func (p *Pool) Start(ctx context.Context) error
- func (p *Pool) Stop(ctx context.Context) error
- func (p *Pool) Use(mw ...Middleware)
- func (p *Pool) WorkerCount() int
- type PoolOption
- type Registry
- func (r *Registry) Clear()
- func (r *Registry) Get(jobType string) (HandlerFunc, error)
- func (r *Registry) Has(jobType string) bool
- func (r *Registry) MustRegister(jobType string, handler HandlerFunc)
- func (r *Registry) Register(jobType string, handler HandlerFunc) error
- func (r *Registry) Types() []string
- func (r *Registry) Unregister(jobType string)
- func (r *Registry) Use(mw ...Middleware)
- type Worker
- type WorkerOption
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrHandlerNotFound = errors.New("handler not found for job type") ErrHandlerExists = errors.New("handler already registered for job type") )
Functions ¶
This section is empty.
Types ¶
type Middleware ¶
type Middleware func(next HandlerFunc) HandlerFunc
func Chain ¶
func Chain(middleware ...Middleware) Middleware
type Pool ¶
type Pool struct {
// contains filtered or unexported fields
}
func (*Pool) MustRegisterHandler ¶
func (p *Pool) MustRegisterHandler(jobType string, handler HandlerFunc)
func (*Pool) RegisterHandler ¶
func (p *Pool) RegisterHandler(jobType string, handler HandlerFunc) error
func (*Pool) Use ¶
func (p *Pool) Use(mw ...Middleware)
func (*Pool) WorkerCount ¶
type PoolOption ¶
type PoolOption func(*Pool)
func WithConcurrency ¶
func WithConcurrency(n int) PoolOption
func WithPoolLogger ¶
func WithPoolLogger(logger zerolog.Logger) PoolOption
func WithPoolPollInterval ¶
func WithPoolPollInterval(d time.Duration) PoolOption
func WithPoolQueues ¶
func WithPoolQueues(queues []string) PoolOption
func WithShutdownTimeout ¶
func WithShutdownTimeout(d time.Duration) PoolOption
type Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
func NewRegistry ¶
func NewRegistry() *Registry
func (*Registry) MustRegister ¶
func (r *Registry) MustRegister(jobType string, handler HandlerFunc)
func (*Registry) Unregister ¶
func (*Registry) Use ¶
func (r *Registry) Use(mw ...Middleware)
type WorkerOption ¶
type WorkerOption func(*Worker)
func WithLogger ¶
func WithLogger(logger zerolog.Logger) WorkerOption
func WithPollInterval ¶
func WithPollInterval(d time.Duration) WorkerOption
func WithQueues ¶
func WithQueues(queues []string) WorkerOption
Source Files
Click to show internal directories.
Click to hide internal directories.