components

Documentation

Index

• type Processor
• type ProcessorController
  • func (c *ProcessorController) Get() Processor
  • func (c *ProcessorController) Init() error
  • func (c *ProcessorController) Set(p Processor) error
• type Worker
• type WorkerPool
  • func (s *WorkerPool) Init() error
  • func (wp *WorkerPool) Register(w Worker)
  • func (wp *WorkerPool) Status() []string

Types

type Processor

type Processor interface {
	Data() string
	Ready() <-chan struct{}
}

type ProcessorController

type ProcessorController struct {
	Processor Processor
}

func (*ProcessorController) Get

func (c *ProcessorController) Get() Processor

func (*ProcessorController) Init

func (c *ProcessorController) Init() error

func (*ProcessorController) Set

func (c *ProcessorController) Set(p Processor) error

type Worker

type Worker interface {
	DoWork()
	Status() string
}

type WorkerPool

type WorkerPool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*WorkerPool) Init

func (s *WorkerPool) Init() error

func (*WorkerPool) Register

func (wp *WorkerPool) Register(w Worker)

func (*WorkerPool) Status

func (wp *WorkerPool) Status() []string