automationservice

Documentation

Index

• func RegisterAutomationServer(s *grpc.Server, srv AutomationServer)
• type AutomationClient
  • func NewAutomationClient(cc *grpc.ClientConn) AutomationClient
• type AutomationServer
• type UnimplementedAutomationServer
  • func (*UnimplementedAutomationServer) EnqueueClusterOperation(ctx context.Context, req *automation.EnqueueClusterOperationRequest) (*automation.EnqueueClusterOperationResponse, error)
  • func (*UnimplementedAutomationServer) GetClusterOperationDetails(ctx context.Context, req *automation.GetClusterOperationDetailsRequest) (*automation.GetClusterOperationDetailsResponse, error)

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.

type UnimplementedAutomationServer

type UnimplementedAutomationServer struct {
}

UnimplementedAutomationServer can be embedded to have forward compatible implementations.

func (*UnimplementedAutomationServer) EnqueueClusterOperation

func (*UnimplementedAutomationServer) EnqueueClusterOperation(ctx context.Context, req *automation.EnqueueClusterOperationRequest) (*automation.EnqueueClusterOperationResponse, error)

func (*UnimplementedAutomationServer) GetClusterOperationDetails

func (*UnimplementedAutomationServer) GetClusterOperationDetails(ctx context.Context, req *automation.GetClusterOperationDetailsRequest) (*automation.GetClusterOperationDetailsResponse, error)