Documentation
¶
Index ¶
- Variables
- func RegisterAutomationServer(s grpc.ServiceRegistrar, srv AutomationServer)
- type AutomationClient
- type AutomationServer
- type UnimplementedAutomationServer
- func (UnimplementedAutomationServer) EnqueueClusterOperation(context.Context, *automation.EnqueueClusterOperationRequest) (*automation.EnqueueClusterOperationResponse, error)
- func (UnimplementedAutomationServer) GetClusterOperationDetails(context.Context, *automation.GetClusterOperationDetailsRequest) (*automation.GetClusterOperationDetailsResponse, error)
- type UnsafeAutomationServer
Constants ¶
This section is empty.
Variables ¶
var Automation_ServiceDesc = grpc.ServiceDesc{ ServiceName: "automationservice.Automation", HandlerType: (*AutomationServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "EnqueueClusterOperation", Handler: _Automation_EnqueueClusterOperation_Handler, }, { MethodName: "GetClusterOperationDetails", Handler: _Automation_GetClusterOperationDetails_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "automationservice.proto", }
Automation_ServiceDesc is the grpc.ServiceDesc for Automation service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_automationservice_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAutomationServer ¶
func RegisterAutomationServer(s grpc.ServiceRegistrar, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAutomationClient ¶
func NewAutomationClient(cc grpc.ClientConnInterface) 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)
// contains filtered or unexported methods
}
AutomationServer is the server API for Automation service. All implementations must embed UnimplementedAutomationServer for forward compatibility
type UnimplementedAutomationServer ¶
type UnimplementedAutomationServer struct {
}
UnimplementedAutomationServer must be embedded to have forward compatible implementations.
func (UnimplementedAutomationServer) EnqueueClusterOperation ¶
func (UnimplementedAutomationServer) EnqueueClusterOperation(context.Context, *automation.EnqueueClusterOperationRequest) (*automation.EnqueueClusterOperationResponse, error)
func (UnimplementedAutomationServer) GetClusterOperationDetails ¶
func (UnimplementedAutomationServer) GetClusterOperationDetails(context.Context, *automation.GetClusterOperationDetailsRequest) (*automation.GetClusterOperationDetailsResponse, error)
type UnsafeAutomationServer ¶ added in v0.11.0
type UnsafeAutomationServer interface {
// contains filtered or unexported methods
}
UnsafeAutomationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AutomationServer will result in compilation errors.
Source Files