Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterProvisionPluginServiceServer(s grpc.ServiceRegistrar, srv ProvisionPluginServiceServer)
- type DeployRequest
- func (*DeployRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeployRequest) GetDataSource() uint32
- func (x *DeployRequest) GetKubeCfgFile() string
- func (*DeployRequest) ProtoMessage()
- func (x *DeployRequest) ProtoReflect() protoreflect.Message
- func (x *DeployRequest) Reset()
- func (x *DeployRequest) String() string
- type DeployResponse
- type ProvisionPluginServiceClient
- type ProvisionPluginServiceServer
- type ProvisionPluginService_DeployClient
- type ProvisionPluginService_DeployServer
- type ProvisionPluginService_TearDownClient
- type ProvisionPluginService_TearDownServer
- type Status
- func (*Status) Descriptor() ([]byte, []int)deprecated
- func (x *Status) GetDone() bool
- func (x *Status) GetError() string
- func (x *Status) GetMessage() string
- func (x *Status) GetStage() string
- func (*Status) ProtoMessage()
- func (x *Status) ProtoReflect() protoreflect.Message
- func (x *Status) Reset()
- func (x *Status) String() string
- type TearDownRequest
- func (*TearDownRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TearDownRequest) GetDataSource() uint32
- func (x *TearDownRequest) GetKubeCfgFile() string
- func (*TearDownRequest) ProtoMessage()
- func (x *TearDownRequest) ProtoReflect() protoreflect.Message
- func (x *TearDownRequest) Reset()
- func (x *TearDownRequest) String() string
- type TearDownResponse
- type UnimplementedProvisionPluginServiceServer
- func (UnimplementedProvisionPluginServiceServer) Deploy(*DeployRequest, grpc.ServerStreamingServer[DeployResponse]) error
- func (UnimplementedProvisionPluginServiceServer) TearDown(*TearDownRequest, grpc.ServerStreamingServer[TearDownResponse]) error
- func (UnimplementedProvisionPluginServiceServer) Validate(context.Context, *ValidateRequest) (*ValidateResponse, error)
- type UnsafeProvisionPluginServiceServer
- type ValidateRequest
- type ValidateResponse
Constants ¶
const ( ProvisionPluginService_Validate_FullMethodName = "/proto.provision_plugin.v1alpha1.ProvisionPluginService/Validate" ProvisionPluginService_Deploy_FullMethodName = "/proto.provision_plugin.v1alpha1.ProvisionPluginService/Deploy" ProvisionPluginService_TearDown_FullMethodName = "/proto.provision_plugin.v1alpha1.ProvisionPluginService/TearDown" )
Variables ¶
var File_proto_provision_plugin_v1alpha1_plugin_proto protoreflect.FileDescriptor
var ProvisionPluginService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.provision_plugin.v1alpha1.ProvisionPluginService", HandlerType: (*ProvisionPluginServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Validate", Handler: _ProvisionPluginService_Validate_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Deploy", Handler: _ProvisionPluginService_Deploy_Handler, ServerStreams: true, }, { StreamName: "TearDown", Handler: _ProvisionPluginService_TearDown_Handler, ServerStreams: true, }, }, Metadata: "proto/provision_plugin/v1alpha1/plugin.proto", }
ProvisionPluginService_ServiceDesc is the grpc.ServiceDesc for ProvisionPluginService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterProvisionPluginServiceServer ¶
func RegisterProvisionPluginServiceServer(s grpc.ServiceRegistrar, srv ProvisionPluginServiceServer)
Types ¶
type DeployRequest ¶
type DeployRequest struct { DataSource *uint32 `protobuf:"varint,1,opt,name=data_source,json=dataSource,proto3,oneof" json:"data_source,omitempty"` KubeCfgFile *string `protobuf:"bytes,2,opt,name=kube_cfg_file,json=kubeCfgFile,proto3,oneof" json:"kube_cfg_file,omitempty"` // contains filtered or unexported fields }
func (*DeployRequest) Descriptor
deprecated
func (*DeployRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeployRequest.ProtoReflect.Descriptor instead.
func (*DeployRequest) GetDataSource ¶
func (x *DeployRequest) GetDataSource() uint32
func (*DeployRequest) GetKubeCfgFile ¶
func (x *DeployRequest) GetKubeCfgFile() string
func (*DeployRequest) ProtoMessage ¶
func (*DeployRequest) ProtoMessage()
func (*DeployRequest) ProtoReflect ¶
func (x *DeployRequest) ProtoReflect() protoreflect.Message
func (*DeployRequest) Reset ¶
func (x *DeployRequest) Reset()
func (*DeployRequest) String ¶
func (x *DeployRequest) String() string
type DeployResponse ¶
type DeployResponse struct { Status *Status `protobuf:"bytes,1,opt,name=status,proto3,oneof" json:"status,omitempty"` // contains filtered or unexported fields }
func (*DeployResponse) Descriptor
deprecated
func (*DeployResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeployResponse.ProtoReflect.Descriptor instead.
func (*DeployResponse) GetStatus ¶
func (x *DeployResponse) GetStatus() *Status
func (*DeployResponse) ProtoMessage ¶
func (*DeployResponse) ProtoMessage()
func (*DeployResponse) ProtoReflect ¶
func (x *DeployResponse) ProtoReflect() protoreflect.Message
func (*DeployResponse) Reset ¶
func (x *DeployResponse) Reset()
func (*DeployResponse) String ¶
func (x *DeployResponse) String() string
type ProvisionPluginServiceClient ¶
type ProvisionPluginServiceClient interface { Validate(ctx context.Context, in *ValidateRequest, opts ...grpc.CallOption) (*ValidateResponse, error) Deploy(ctx context.Context, in *DeployRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DeployResponse], error) TearDown(ctx context.Context, in *TearDownRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TearDownResponse], error) }
ProvisionPluginServiceClient is the client API for ProvisionPluginService 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 NewProvisionPluginServiceClient ¶
func NewProvisionPluginServiceClient(cc grpc.ClientConnInterface) ProvisionPluginServiceClient
type ProvisionPluginServiceServer ¶
type ProvisionPluginServiceServer interface { Validate(context.Context, *ValidateRequest) (*ValidateResponse, error) Deploy(*DeployRequest, grpc.ServerStreamingServer[DeployResponse]) error TearDown(*TearDownRequest, grpc.ServerStreamingServer[TearDownResponse]) error }
ProvisionPluginServiceServer is the server API for ProvisionPluginService service. All implementations should embed UnimplementedProvisionPluginServiceServer for forward compatibility.
type ProvisionPluginService_DeployClient ¶
type ProvisionPluginService_DeployClient = grpc.ServerStreamingClient[DeployResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ProvisionPluginService_DeployServer ¶
type ProvisionPluginService_DeployServer = grpc.ServerStreamingServer[DeployResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ProvisionPluginService_TearDownClient ¶
type ProvisionPluginService_TearDownClient = grpc.ServerStreamingClient[TearDownResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ProvisionPluginService_TearDownServer ¶
type ProvisionPluginService_TearDownServer = grpc.ServerStreamingServer[TearDownResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Status ¶
type Status struct { Stage *string `protobuf:"bytes,1,opt,name=stage,proto3,oneof" json:"stage,omitempty"` Message *string `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"` Done *bool `protobuf:"varint,3,opt,name=done,proto3,oneof" json:"done,omitempty"` Error *string `protobuf:"bytes,4,opt,name=error,proto3,oneof" json:"error,omitempty"` // contains filtered or unexported fields }
func (*Status) Descriptor
deprecated
func (*Status) GetMessage ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) ProtoReflect ¶
func (x *Status) ProtoReflect() protoreflect.Message
type TearDownRequest ¶
type TearDownRequest struct { DataSource *uint32 `protobuf:"varint,1,opt,name=data_source,json=dataSource,proto3,oneof" json:"data_source,omitempty"` KubeCfgFile *string `protobuf:"bytes,2,opt,name=kube_cfg_file,json=kubeCfgFile,proto3,oneof" json:"kube_cfg_file,omitempty"` // contains filtered or unexported fields }
func (*TearDownRequest) Descriptor
deprecated
func (*TearDownRequest) Descriptor() ([]byte, []int)
Deprecated: Use TearDownRequest.ProtoReflect.Descriptor instead.
func (*TearDownRequest) GetDataSource ¶
func (x *TearDownRequest) GetDataSource() uint32
func (*TearDownRequest) GetKubeCfgFile ¶ added in v0.5.0
func (x *TearDownRequest) GetKubeCfgFile() string
func (*TearDownRequest) ProtoMessage ¶
func (*TearDownRequest) ProtoMessage()
func (*TearDownRequest) ProtoReflect ¶
func (x *TearDownRequest) ProtoReflect() protoreflect.Message
func (*TearDownRequest) Reset ¶
func (x *TearDownRequest) Reset()
func (*TearDownRequest) String ¶
func (x *TearDownRequest) String() string
type TearDownResponse ¶
type TearDownResponse struct { Status *Status `protobuf:"bytes,1,opt,name=status,proto3,oneof" json:"status,omitempty"` // contains filtered or unexported fields }
func (*TearDownResponse) Descriptor
deprecated
func (*TearDownResponse) Descriptor() ([]byte, []int)
Deprecated: Use TearDownResponse.ProtoReflect.Descriptor instead.
func (*TearDownResponse) GetStatus ¶
func (x *TearDownResponse) GetStatus() *Status
func (*TearDownResponse) ProtoMessage ¶
func (*TearDownResponse) ProtoMessage()
func (*TearDownResponse) ProtoReflect ¶
func (x *TearDownResponse) ProtoReflect() protoreflect.Message
func (*TearDownResponse) Reset ¶
func (x *TearDownResponse) Reset()
func (*TearDownResponse) String ¶
func (x *TearDownResponse) String() string
type UnimplementedProvisionPluginServiceServer ¶
type UnimplementedProvisionPluginServiceServer struct{}
UnimplementedProvisionPluginServiceServer should be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedProvisionPluginServiceServer) Validate ¶
func (UnimplementedProvisionPluginServiceServer) Validate(context.Context, *ValidateRequest) (*ValidateResponse, error)
type UnsafeProvisionPluginServiceServer ¶
type UnsafeProvisionPluginServiceServer interface {
// contains filtered or unexported methods
}
UnsafeProvisionPluginServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProvisionPluginServiceServer will result in compilation errors.
type ValidateRequest ¶
type ValidateRequest struct {
// contains filtered or unexported fields
}
func (*ValidateRequest) Descriptor
deprecated
func (*ValidateRequest) Descriptor() ([]byte, []int)
Deprecated: Use ValidateRequest.ProtoReflect.Descriptor instead.
func (*ValidateRequest) ProtoMessage ¶
func (*ValidateRequest) ProtoMessage()
func (*ValidateRequest) ProtoReflect ¶
func (x *ValidateRequest) ProtoReflect() protoreflect.Message
func (*ValidateRequest) Reset ¶
func (x *ValidateRequest) Reset()
func (*ValidateRequest) String ¶
func (x *ValidateRequest) String() string
type ValidateResponse ¶
type ValidateResponse struct {
// contains filtered or unexported fields
}
func (*ValidateResponse) Descriptor
deprecated
func (*ValidateResponse) Descriptor() ([]byte, []int)
Deprecated: Use ValidateResponse.ProtoReflect.Descriptor instead.
func (*ValidateResponse) ProtoMessage ¶
func (*ValidateResponse) ProtoMessage()
func (*ValidateResponse) ProtoReflect ¶
func (x *ValidateResponse) ProtoReflect() protoreflect.Message
func (*ValidateResponse) Reset ¶
func (x *ValidateResponse) Reset()
func (*ValidateResponse) String ¶
func (x *ValidateResponse) String() string