Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EmptyPoolOptions ¶
type EmptyPoolOptions struct{}
EmptyPoolUrlOption does not alter the Pooluration. It can be embedded in another structure to build custom options.
This API is EXPERIMENTAL.
type Pool ¶
type Pool struct {
TaskFunc TaskHandler
// contains filtered or unexported fields
}
func New ¶
func New(taskFunc TaskHandler, opts ...PoolOptions) *Pool
func (*Pool) ApplyOptions ¶
func (o *Pool) ApplyOptions(options ...PoolOptions) *Pool
type PoolConfig ¶
type PoolConfig struct {
// contains filtered or unexported fields
}
type PoolOptions ¶
type PoolOptions interface {
// contains filtered or unexported methods
}
A PoolOptions sets options.
func WithBurst ¶
func WithBurst(burst int) PoolOptions
func WithErrStop ¶
func WithErrStop(errStop bool) PoolOptions
type PoolOptionsFunc ¶
type PoolOptionsFunc func(*Pool)
PoolOptionsFunc wraps a function that modifies Pool into an implementation of the PoolOptions interface.
type TaskHandler ¶
type TaskHandler func(task interface{}) error
type Worker ¶
type Worker struct {
Burst int32
// contains filtered or unexported fields
}
func (*Worker) TrySetError ¶
Source Files
Click to show internal directories.
Click to hide internal directories.