subprocessor

Documentation

Index

• type Coordinator
  • func NewCoordinator() *Coordinator
  • func (coordinator *Coordinator) Destroy()
  • func (coordinator *Coordinator) Run()
• type Resource
• type Routine
  • func NewRoutine(cp chan chan Resource) *Routine
  • func (r *Routine) Start()
  • func (r *Routine) Stop()

Types

type Coordinator

type Coordinator struct {
	ResourceChannel chan Resource
	// contains filtered or unexported fields
}

func NewCoordinator

func NewCoordinator() *Coordinator

func (*Coordinator) Destroy

func (coordinator *Coordinator) Destroy()

func (*Coordinator) Run

func (coordinator *Coordinator) Run()

type Resource

type Resource struct {
	Process func()
}

type Routine

type Routine struct {
	ResourceChannel chan Resource
	// contains filtered or unexported fields
}

func NewRoutine

func NewRoutine(cp chan chan Resource) *Routine

func (*Routine) Start

func (r *Routine) Start()

func (*Routine) Stop

func (r *Routine) Stop()