Documentation
¶
Overview ¶
The client package provides an interface and implementation for the Scoot Worker API, as well as a CLI client that wraps it.
Index ¶
- func APIAddrToBundlestoreURI(addr string) string
- func GetScootapiAddr() (sched string, api string, err error)
- func GetScootapiAddrPath() string
- func NewWorkerThriftClient(tf thrift.TTransportFactory, pf thrift.TProtocolFactory, ct time.Duration, ...) (func(cluster.Node) runner.Service, error)
- type Client
- type WorkersClientJSONConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func APIAddrToBundlestoreURI ¶
Create a Bundlestore URI from an addr
func GetScootapiAddr ¶
Get the scootapi address (as host:port)
func GetScootapiAddrPath ¶
func GetScootapiAddrPath() string
Get the path of the file containing the address for scootapi to use
func NewWorkerThriftClient ¶
func NewWorkerThriftClient( tf thrift.TTransportFactory, pf thrift.TProtocolFactory, ct time.Duration, wc WorkersClientJSONConfig) (func(cluster.Node) runner.Service, error)
Types ¶
type Client ¶
type Client interface {
// Connection funtions
Dial() error
Close() error
// Worker API Interactions
QueryWorker() (domain.WorkerStatus, error)
runner.Controller
runner.StatusQueryNower
runner.LegacyStatusReader
}
type WorkersClientJSONConfig ¶
type WorkersClientJSONConfig struct {
Type string // transport type: rpc
PollingPeriod string // polling period default to 250ms
}
Parameters for configuring connections to remote workers.
Source Files
Click to show internal directories.
Click to hide internal directories.