starter

package

v0.0.1-alpha Latest Latest Go to latest Published: Feb 28, 2022 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/twitter/scoot

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 GetProxyDialer ¶

func GetProxyDialer(proxyAddr string) (proxy.Dialer, error)

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.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL