import "gopkg.in/src-d/go-vitess.v1/vt/proto/automationservice"
func RegisterAutomationServer(s *grpc.Server, srv AutomationServer)
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(cc *grpc.ClientConn) AutomationClient
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.
Package automationservice imports 6 packages (graph). Updated 2019-06-13. Refresh now. Tools for package owners.