scheduler

Documentation

Index

• Constants
• type Config
• type LIFOFilter
• type Registry
  • func NewRegistry() *Registry
  • func (r *Registry) Close()
  • func (r *Registry) Config(key string) Config
  • func (r *Registry) Do(routes []*routing.Route) []*routing.Route
• type Stack
  • func (s *Stack) Config() Config
  • func (s *Stack) Wait() (done func(), err error)

Constants

const (
	LIFOKey = "lifo"
)

Types

type Config

type Config struct {
	Name           string
	MaxConcurrency int
	MaxStackSize   int
	Timeout        time.Duration
}

type LIFOFilter

type LIFOFilter interface {
	SetStack(*Stack)
	GetStack() *Stack
	Config(*Registry) Config
	Key() string
	SetKey(string)
}

type Registry

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

func NewRegistry

func NewRegistry() *Registry

func (*Registry) Close

func (r *Registry) Close()

func (*Registry) Config

func (r *Registry) Config(key string) Config

func (*Registry) Do

func (r *Registry) Do(routes []*routing.Route) []*routing.Route

Do implements routing.PostProcessor and sets the stack for the scheduler filters.

It preserves the existing stack when available.

type Stack

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

func (*Stack) Config

func (s *Stack) Config() Config

func (*Stack) Wait

func (s *Stack) Wait() (done func(), err error)