dispatcher

Documentation

Index

• type Dispatcher
  • func NewDispatcher(config DispatcherConfig, processServer *processServer.ProcessServer, ...) *Dispatcher
  • func (dispatcher *Dispatcher) Run()
• type DispatcherConfig

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(config DispatcherConfig, processServer *processServer.ProcessServer, dispatchChannel chan submitwrap.SubmitTaskWrap, executorChannel chan<- submitwrap.SubmitTaskWrap) *Dispatcher

func (*Dispatcher) Run

func (dispatcher *Dispatcher) Run()

type DispatcherConfig

type DispatcherConfig struct {
	QueueSize           int `json:"queueSize"`
	DispatchChannelSize int `json:"channelSize"`
	Ndocker             int `json:"ndocker"`
}