Documentation
¶
Overview ¶
Package api implements the Scoot thrift API, Bazel grpc remote execution and longrunning operation APIs, and the TwitterServer http API.
Index ¶
- func MakeServer(handler scoot.CloudScoot, transport thrift.TServerTransport, ...) thrift.TServer
- func NewHandler(scheduler server.Scheduler, sc saga.SagaCoordinator, stat stats.StatsReceiver) scoot.CloudScoot
- type Handler
- func (h *Handler) GetClassLoadPercents() (map[string]int32, error)
- func (h *Handler) GetRebalanceMinimumDuration() (int32, error)
- func (h *Handler) GetRebalanceThreshold() (int32, error)
- func (h *Handler) GetRequestorToClassMap() (map[string]string, error)
- func (h *Handler) GetSchedulerStatus() (*scoot.SchedulerStatus, error)
- func (h *Handler) GetStatus(jobId string) (*scoot.JobStatus, error)
- func (h *Handler) KillJob(jobId string) (*scoot.JobStatus, error)
- func (h *Handler) OfflineWorker(req *scoot.OfflineWorkerReq) error
- func (h *Handler) ReinstateWorker(req *scoot.ReinstateWorkerReq) error
- func (h *Handler) RunJob(def *scoot.JobDefinition) (*scoot.JobId, error)
- func (h *Handler) SetClassLoadPercents(classLoadPercents map[string]int32) error
- func (h *Handler) SetRebalanceMinimumDuration(durationMinimum int32) error
- func (h *Handler) SetRebalanceThreshold(threshold int32) error
- func (h *Handler) SetRequestorToClassMap(requestToClassMap map[string]string) error
- func (h *Handler) SetSchedulerStatus(maxNumTasks int32) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeServer ¶
func MakeServer(handler scoot.CloudScoot, transport thrift.TServerTransport, transportFactory thrift.TTransportFactory, protocolFactory thrift.TProtocolFactory) thrift.TServer
Creates a Thrift server given a Handler and Thrift connection information
func NewHandler ¶
func NewHandler(scheduler server.Scheduler, sc saga.SagaCoordinator, stat stats.StatsReceiver) scoot.CloudScoot
Creates and returns a new server Handler, which combines the scheduler, saga coordinator and stats receivers.
Types ¶
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Wrapping type that combines a scheduler, saga coordinator and stat receiver into a server
func (*Handler) GetClassLoadPercents ¶
GetClassLoadPercents Implements GetClassLoadPercents Cloud Scoot API
func (*Handler) GetRebalanceMinimumDuration ¶
GetRebalanceMinimumDuration get the duration(minutes) that the scheduler needs to be exceeding the rebalance threshold before rebalancing. <= 0 implies no rebalancing
func (*Handler) GetRebalanceThreshold ¶
GetRebalanceThreshold the % spread threshold that must be exceeded to trigger rebalance <= 0 implies no rebalancing
func (*Handler) GetRequestorToClassMap ¶
GetRequestorToClassMap Implements GetRequestorToClassMap Cloud Scoot API
func (*Handler) GetSchedulerStatus ¶
func (h *Handler) GetSchedulerStatus() (*scoot.SchedulerStatus, error)
Implements GetSchedulerStatus Cloud Scoot API
func (*Handler) OfflineWorker ¶
func (h *Handler) OfflineWorker(req *scoot.OfflineWorkerReq) error
Implements OfflineWorker Cloud Scoot API
func (*Handler) ReinstateWorker ¶
func (h *Handler) ReinstateWorker(req *scoot.ReinstateWorkerReq) error
Implements ReinstateWorker Cloud Scoot API
func (*Handler) SetClassLoadPercents ¶
SetClassLoadPercents Implements SetClassLoadPercents Cloud Scoot API
func (*Handler) SetRebalanceMinimumDuration ¶
SetRebalanceMinimumDuration set the duration(minutes) that the scheduler needs to be exceeding the rebalance threshold before rebalancing. <= 0 implies no rebalancing
func (*Handler) SetRebalanceThreshold ¶
SetRebalanceThreshold the % spread threshold that must be exceeded to trigger rebalance <= 0 implies no rebalancing
func (*Handler) SetRequestorToClassMap ¶
SetRequestorToClassMap Implements SetRequestorToClassMap Cloud Scoot API
func (*Handler) SetSchedulerStatus ¶
Implements SetSchedulerStatus Cloud Scoot API
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package thrift implements the Scoot API, see scoot.thrift for details
|
Package thrift implements the Scoot API, see scoot.thrift for details |