ccjh

Documentation

Index

• type Handler
  • func New(buffer int) *Handler
  • func (h *Handler) Active() int
  • func (h *Handler) Add(job Job) error
  • func (h *Handler) Pending() int
  • func (h *Handler) Reset() error
  • func (h *Handler) Run(maxJobs int, interval time.Duration) error
  • func (h *Handler) RunAsync(maxJobs int, interval time.Duration) error
  • func (h *Handler) Running() bool
  • func (h *Handler) Stop()
• type Job

Types

type Handler

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

func New

func New(buffer int) *Handler

func (*Handler) Active

func (h *Handler) Active() int

func (*Handler) Add

func (h *Handler) Add(job Job) error

func (*Handler) Pending

func (h *Handler) Pending() int

func (*Handler) Reset

func (h *Handler) Reset() error

func (*Handler) Run

func (h *Handler) Run(maxJobs int, interval time.Duration) error

func (*Handler) RunAsync

func (h *Handler) RunAsync(maxJobs int, interval time.Duration) error

func (*Handler) Running

func (h *Handler) Running() bool

func (*Handler) Stop

func (h *Handler) Stop()

type Job

type Job interface {
	CallTarget(func())
	IsCanceled() bool
}