dispatch

Documentation

Index

• Constants
• func New(ctx context.Context, opts ...OptionFunc) schedule.Scheduler
• type Dispatcher
  • func (d *Dispatcher) Schedule(j *schedule.Job)
• type Option
• type OptionFunc
  • func WithMaxWorker(maxWorker int) OptionFunc
• type Ring
  • func NewRing(size int) *Ring
  • func (q *Ring) Push(j *schedule.Job)
  • func (q *Ring) String() string
• type Worker
  • func NewWorker(id int, jobSize int) *Worker

Constants

const (
	DefaultWorkers = 2113
	DefaultJobSize = 64
)

Functions

func New

func New(ctx context.Context, opts ...OptionFunc) schedule.Scheduler

Types

type Dispatcher

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

func (*Dispatcher) Schedule

func (d *Dispatcher) Schedule(j *schedule.Job)

type Option

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

type OptionFunc

type OptionFunc func(o *Option)

func WithMaxWorker

func WithMaxWorker(maxWorker int) OptionFunc

type Ring

type Ring struct {
	Data []*schedule.Job
	// contains filtered or unexported fields
}

func NewRing

func NewRing(size int) *Ring

func (*Ring) Push

func (q *Ring) Push(j *schedule.Job)

func (*Ring) String

func (q *Ring) String() string

type Worker

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

func NewWorker

func NewWorker(id int, jobSize int) *Worker