pool

Documentation

Index

• Variables
• type ConsumeErrorHandler
• type Pool
  • func NewPool(size int, expiry int, errHandle func(string, error)) (*Pool, error)
  • func (p *Pool) Release() error
  • func (p *Pool) Submit(task *Task) error
• type Task
• type Worker

Variables

var (
	ErrorPoolClosed           = errors.New("pool closed")
	ErrorPoolIllegalSize      = errors.New("wrong size")
	ErrorWorkerExpiryDuration = errors.New("invalid expiry duration")
)

Types

type ConsumeErrorHandler

type ConsumeErrorHandler func(string, error)

type Pool

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

func NewPool

func NewPool(size int, expiry int, errHandle func(string, error)) (*Pool, error)

func (*Pool) Release

func (p *Pool) Release() error

func (*Pool) Submit

func (p *Pool) Submit(task *Task) error

type Task

type Task struct {
	Msg        string
	HandleChan chan string
	Handle     func(string) error
}

type Worker

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