Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterAutomationServer ¶
func RegisterAutomationServer(s *grpc.Server, srv AutomationServer)
Types ¶
type AutomationClient ¶
type AutomationClient interface {
// Start a cluster operation.
EnqueueClusterOperation(ctx context.Context, in *automation.EnqueueClusterOperationRequest, opts ...grpc.CallOption) (*automation.EnqueueClusterOperationResponse, error)
// TODO(mberlin): Polling this is bad. Implement a subscribe mechanism to wait for changes?
// Get all details of an active cluster operation.
GetClusterOperationDetails(ctx context.Context, in *automation.GetClusterOperationDetailsRequest, opts ...grpc.CallOption) (*automation.GetClusterOperationDetailsResponse, error)
}
AutomationClient is the client API for Automation service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAutomationClient ¶
func NewAutomationClient(cc *grpc.ClientConn) AutomationClient
type AutomationServer ¶
type AutomationServer interface {
// Start a cluster operation.
EnqueueClusterOperation(context.Context, *automation.EnqueueClusterOperationRequest) (*automation.EnqueueClusterOperationResponse, error)
// TODO(mberlin): Polling this is bad. Implement a subscribe mechanism to wait for changes?
// Get all details of an active cluster operation.
GetClusterOperationDetails(context.Context, *automation.GetClusterOperationDetailsRequest) (*automation.GetClusterOperationDetailsResponse, error)
}
AutomationServer is the server API for Automation service.
Source Files
Click to show internal directories.
Click to hide internal directories.