scootconfig

Documentation

Index

• Constants
• func InmemoryWorkerFactory() func(cluster.Node) runner.Service
• type ClientTimeout
• type WorkersLocalConfig
  • func (c *WorkersLocalConfig) Install(bag *ice.MagicBag)
• type WorkersThriftConfig
  • 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)

Constants

const DefaultClientTimeout = time.Minute

Functions

func InmemoryWorkerFactory

func InmemoryWorkerFactory() func(cluster.Node) runner.Service

Types

type ClientTimeout

type ClientTimeout time.Duration

type WorkersLocalConfig

type WorkersLocalConfig struct {
	Type string
}

Parameters for configuring locally started workers

func (*WorkersLocalConfig) Install

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 (*WorkersThriftConfig) Create

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

func (*WorkersThriftConfig) Install

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