Documentation ¶
Index ¶
- Constants
- func GetProxyAddr() string
- func GetProxyDialer(proxyAddr string) (proxy.Dialer, error)
- func GetSocksWorker() (server.RunnerFactory, error)
- func GetWorkerRunnerServiceFn(workers client.WorkersClientJSONConfig, ...) (func(cluster.Node) runner.Service, error)
- func MakeSagaLog(config config.SagaLogJSONConfig) (saga.SagaLog, error)
- func NewTTransportFactory() (thrift.TTransportFactory, error)
- func StartCluster(clusterJSON config.ClusterJSONConfig) (chan []cluster.NodeUpdate, error)
- func StartServer(schedulerConfig server.SchedulerConfiguration, ...) error
Constants ¶
View Source
const DEFAULT_SOCKS_ADDR = "localhost:" + DEFAULT_SOCKS_PORT
View Source
const DEFAULT_SOCKS_PORT = "50001"
Variables ¶
This section is empty.
Functions ¶
func GetProxyAddr ¶
func GetProxyAddr() string
func GetSocksWorker ¶
func GetSocksWorker() (server.RunnerFactory, error)
func GetWorkerRunnerServiceFn ¶
func GetWorkerRunnerServiceFn(workers client.WorkersClientJSONConfig, thriftTransportFactory thrift.TTransportFactory, binaryProtocolFactory thrift.TProtocolFactory) (func(cluster.Node) runner.Service, error)
func MakeSagaLog ¶
func MakeSagaLog(config config.SagaLogJSONConfig) (saga.SagaLog, error)
MakeSagaLog - TODO remove saga or refactor it so this function can be moved into saga or sagalog the current organization leads to cyclic dependency when moving to saga or sagalogs
func NewTTransportFactory ¶
func NewTTransportFactory() (thrift.TTransportFactory, error)
func StartCluster ¶
func StartCluster(clusterJSON config.ClusterJSONConfig) (chan []cluster.NodeUpdate, error)
func StartServer ¶
func StartServer(schedulerConfig server.SchedulerConfiguration, sagaLogConfig config.SagaLogJSONConfig, workers client.WorkersClientJSONConfig, thriftServerTransport thrift.TServerTransport, statsReceiver *stats.StatsReceiver, workerClientTimeout time.Duration, endpoints *endpoints.TwitterServer, bazelGRPCConfig *bazel.GRPCConfig, persistor server.Persistor, durationKeyExtractorFn func(string) string, nodesUpdatesCh chan []cluster.NodeUpdate) error
StartServer construct and start scheduler service (without using ice)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.