scheduler

Documentation

Index

• type LoadBalancer
  • func NewLoadBalancer() *LoadBalancer
  • func (lb *LoadBalancer) AssignTask(task *Task) *worker.Worker
• type Scheduler
  • func NewScheduler() *Scheduler
  • func (s *Scheduler) Start(ctx context.Context, target *pow.Target, data []byte)
  • func (s *Scheduler) Stop()
• type TaskQueue
  • func NewTaskQueue() *TaskQueue
  • func (q *TaskQueue) Pop() *Task
  • func (q *TaskQueue) Push(task *Task)

Types

type LoadBalancer

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

func NewLoadBalancer

func NewLoadBalancer() *LoadBalancer

func (*LoadBalancer) AssignTask

func (lb *LoadBalancer) AssignTask(task *Task) *worker.Worker

type Scheduler

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

func NewScheduler

func NewScheduler() *Scheduler

func (*Scheduler) Start

func (s *Scheduler) Start(ctx context.Context, target *pow.Target, data []byte)

func (*Scheduler) Stop

func (s *Scheduler) Stop()

type TaskQueue

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

func NewTaskQueue

func NewTaskQueue() *TaskQueue

func (*TaskQueue) Pop

func (q *TaskQueue) Pop() *Task

func (*TaskQueue) Push

func (q *TaskQueue) Push(task *Task)