scootconfig

type ClientTimeout ¶

type ClientTimeout time.Duration

type WorkersLocalConfig ¶

type WorkersLocalConfig struct {
	Type string
}

Parameters for configuring locally started workers

func (c *WorkersLocalConfig) Install(bag *ice.MagicBag)

type WorkersThriftConfig ¶

type WorkersThriftConfig struct {
	Type          string
	PollingPeriod string // will be parsed to a time.Duration
}

Parameters for configuring connections to remote (Thrift) workers.

func (c *WorkersThriftConfig) Create(
	tf thrift.TTransportFactory,
	pf thrift.TProtocolFactory,
	ct ClientTimeout) (func(cluster.Node) runner.Service, error)

func (c *WorkersThriftConfig) Install(bag *ice.MagicBag)