NewBrokerServiceClient returns a new BrokerServiceClient.

NewDiscoveryClient returns a DiscoveryClient.

NewExecutorClient creates a new executor client.

NewExecutorGroup creates a new ExecutorGroup.

NewExecutorServiceClient creates a new ExecutorServiceClient.

NewMockExecutorClient creates a new mock instance.

NewMockExecutorGroup returns a new MockExecutorGroup.

NewMockServerMasterClient creates a new mock instance.

NewResourceManagerClient returns a ResourceManagerClient.

NewServerMasterClientWithEndpointList creates a new ServerMasterClientWithFailOver with an endpoint list.

NewServerMasterClientWithFailOver creates a new ServerMasterClientWithFailOver.

NewTaskSchedulerClient returns a TaskSchedulerClient.

DefaultExecutorGroup is the default implementation for ExecutorGroup.

DispatchTaskArgs contains the required parameters for creating a worker.

MockExecutorClient is a mock of ExecutorClient interface.

MockExecutorClientMockRecorder is the mock recorder for MockExecutorClient.

MockExecutorGroup is a stub implementation for ExecutorGroup.

MockServerMasterClient is a mock of ServerMasterClient interface.

MockServerMasterClientMockRecorder is the mock recorder for MockServerMasterClient.

ServerMasterClientWithFailOver implements ServerMasterClient.

BrokerServiceClient wraps a pb.BrokerServiceClient.

DiscoveryClient is a client to the Discovery service on the server master.

ExecutorClient is the public interface for an executor client.

ExecutorGroup holds a group of ExecutorClients.

ExecutorServiceClient wraps a pb.ExecutorServiceClient and provides a DispatchTask method, which will call PreDispatchTask and ConfirmDispatchTask.

ResourceManagerClient is a client to the service ResourceManager, which currently is part of the server master.

ServerMasterClient is a client for connecting to the server master.

TaskSchedulerClient is an interface for a client to the task scheduler in the server master.