Documentation
¶
Overview ¶
Package server provides the implementation of the Scoot Worker Server, which implements the Worker API and starts the actual worker.
Index ¶
- func GetStatsReceiver() stats.StatsReceiver
- func MakeServer(handler worker.Worker, transport thrift.TServerTransport, ...) thrift.TServer
- func NewHandler(stat stats.StatsReceiver, run runner.Service) worker.Worker
- func StartServer(thriftAddr string, httpAddr string, bzFiler *bazel.BzFiler, db *gitdb.DB, ...)
- type StatsCollectInterval
- type WorkerStatusHTTPHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetStatsReceiver ¶
func GetStatsReceiver() stats.StatsReceiver
func MakeServer ¶
func MakeServer( handler worker.Worker, transport thrift.TServerTransport, transportFactory thrift.TTransportFactory, protocolFactory thrift.TProtocolFactory) thrift.TServer
Creates a Worker Server
func NewHandler ¶
Creates a new Handler which combines a runner.Service to do work and a StatsReceiver
func StartServer ¶
func StartServer( thriftAddr string, httpAddr string, bzFiler *bazel.BzFiler, db *gitdb.DB, oc runners.HttpOutputCreator, rID runner.RunnerID, dirMonitor *stats.DirsMonitor, memCap uint64, stat *stats.StatsReceiver, preprocessors []func() error, postprocessors []func() error, )
StartServer construct and start scheduler service (without using ice)
Types ¶
type StatsCollectInterval ¶
defining StatsCollectInterval type so it can be injected via ICE (avoid conflict with other injected integers)
type WorkerStatusHTTPHandler ¶
type WorkerStatusHTTPHandler struct {
// contains filtered or unexported fields
}
WorkerStatusHTTPHandler implements http.Handler to return status for aurora health check endpoints based on the underlying runner.ServiceStatus
func (*WorkerStatusHTTPHandler) ServeHTTP ¶
func (h *WorkerStatusHTTPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
Source Files
Click to show internal directories.
Click to hide internal directories.