scheduler

Documentation

Index

• type Factory
• type LRUScheduler
  • func (lru *LRUScheduler) Schedule(ctx context.Context) (Factory, error)
• type Scheduler
  • func NewLRUScheduler(pool []Factory) (Scheduler, error)

Types

type Factory

type Factory interface {
	// Value will return the total numbers of goods
	Value() int

	// Produce will produce numbers of goods
	Produce(goods int)

	// Consume will consume numbers of goods
	Consume(goods int) error
}

Factory is an interface that can produce and consume "goods"

type LRUScheduler

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

LRUScheduler is a Least Recently Used scheduler.

func (*LRUScheduler) Schedule

func (lru *LRUScheduler) Schedule(ctx context.Context) (Factory, error)

Schedule is to choose the next candidate.

type Scheduler

type Scheduler interface {
	// Return a chosed client
	Schedule(ctx context.Context) (Factory, error)
}

Scheduler is an interface that implement a function choosing an item from a items pool.

func NewLRUScheduler

func NewLRUScheduler(pool []Factory) (Scheduler, error)

NewLRUScheduler new a LRU scheduler.