Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterDrainServiceServer(s grpc.ServiceRegistrar, srv DrainServiceServer)
- type ConfigFormat
- type DrainServiceClient
- type DrainServiceServer
- type InitRequest
- func (x *InitRequest) ClearConfig()
- func (x *InitRequest) GetConfig() []byte
- func (x *InitRequest) HasConfig() bool
- func (*InitRequest) ProtoMessage()
- func (x *InitRequest) ProtoReflect() protoreflect.Message
- func (x *InitRequest) Reset()
- func (x *InitRequest) SetConfig(v []byte)
- func (x *InitRequest) String() string
- type InitRequest_builder
- type InitResponse
- type InitResponse_builder
- type IsDrainOkRequest
- func (x *IsDrainOkRequest) ClearNodeName()
- func (x *IsDrainOkRequest) GetNodeName() string
- func (x *IsDrainOkRequest) HasNodeName() bool
- func (*IsDrainOkRequest) ProtoMessage()
- func (x *IsDrainOkRequest) ProtoReflect() protoreflect.Message
- func (x *IsDrainOkRequest) Reset()
- func (x *IsDrainOkRequest) SetNodeName(v string)
- func (x *IsDrainOkRequest) String() string
- type IsDrainOkRequest_builder
- type IsDrainOkResponse
- func (x *IsDrainOkResponse) ClearOk()
- func (x *IsDrainOkResponse) GetOk() bool
- func (x *IsDrainOkResponse) HasOk() bool
- func (*IsDrainOkResponse) ProtoMessage()
- func (x *IsDrainOkResponse) ProtoReflect() protoreflect.Message
- func (x *IsDrainOkResponse) Reset()
- func (x *IsDrainOkResponse) SetOk(v bool)
- func (x *IsDrainOkResponse) String() string
- type IsDrainOkResponse_builder
- type IsHealthyRequest
- type IsHealthyRequest_builder
- type IsHealthyResponse
- func (x *IsHealthyResponse) ClearHealthy()
- func (x *IsHealthyResponse) GetHealthy() bool
- func (x *IsHealthyResponse) HasHealthy() bool
- func (*IsHealthyResponse) ProtoMessage()
- func (x *IsHealthyResponse) ProtoReflect() protoreflect.Message
- func (x *IsHealthyResponse) Reset()
- func (x *IsHealthyResponse) SetHealthy(v bool)
- func (x *IsHealthyResponse) String() string
- type IsHealthyResponse_builder
- type IsSupportedRequest
- type IsSupportedRequest_builder
- type IsSupportedResponse
- func (x *IsSupportedResponse) ClearSupported()
- func (x *IsSupportedResponse) GetSupported() bool
- func (x *IsSupportedResponse) HasSupported() bool
- func (*IsSupportedResponse) ProtoMessage()
- func (x *IsSupportedResponse) ProtoReflect() protoreflect.Message
- func (x *IsSupportedResponse) Reset()
- func (x *IsSupportedResponse) SetSupported(v bool)
- func (x *IsSupportedResponse) String() string
- type IsSupportedResponse_builder
- type PluginInfoRequest
- type PluginInfoRequest_builder
- type PluginInfoResponse
- func (x *PluginInfoResponse) ClearConfigFormat()
- func (x *PluginInfoResponse) ClearId()
- func (x *PluginInfoResponse) GetConfigFormat() ConfigFormat
- func (x *PluginInfoResponse) GetId() string
- func (x *PluginInfoResponse) HasConfigFormat() bool
- func (x *PluginInfoResponse) HasId() bool
- func (*PluginInfoResponse) ProtoMessage()
- func (x *PluginInfoResponse) ProtoReflect() protoreflect.Message
- func (x *PluginInfoResponse) Reset()
- func (x *PluginInfoResponse) SetConfigFormat(v ConfigFormat)
- func (x *PluginInfoResponse) SetId(v string)
- func (x *PluginInfoResponse) String() string
- type PluginInfoResponse_builder
- type PostDrainRequest
- func (x *PostDrainRequest) ClearNodeName()
- func (x *PostDrainRequest) GetNodeName() string
- func (x *PostDrainRequest) HasNodeName() bool
- func (*PostDrainRequest) ProtoMessage()
- func (x *PostDrainRequest) ProtoReflect() protoreflect.Message
- func (x *PostDrainRequest) Reset()
- func (x *PostDrainRequest) SetNodeName(v string)
- func (x *PostDrainRequest) String() string
- type PostDrainRequest_builder
- type PostDrainResponse
- type PostDrainResponse_builder
- type PreDrainRequest
- func (x *PreDrainRequest) ClearNodeName()
- func (x *PreDrainRequest) GetNodeName() string
- func (x *PreDrainRequest) HasNodeName() bool
- func (*PreDrainRequest) ProtoMessage()
- func (x *PreDrainRequest) ProtoReflect() protoreflect.Message
- func (x *PreDrainRequest) Reset()
- func (x *PreDrainRequest) SetNodeName(v string)
- func (x *PreDrainRequest) String() string
- type PreDrainRequest_builder
- type PreDrainResponse
- type PreDrainResponse_builder
- type UnimplementedDrainServiceServer
- func (UnimplementedDrainServiceServer) Init(context.Context, *InitRequest) (*InitResponse, error)
- func (UnimplementedDrainServiceServer) IsDrainOk(context.Context, *IsDrainOkRequest) (*IsDrainOkResponse, error)
- func (UnimplementedDrainServiceServer) IsHealthy(context.Context, *IsHealthyRequest) (*IsHealthyResponse, error)
- func (UnimplementedDrainServiceServer) IsSupported(context.Context, *IsSupportedRequest) (*IsSupportedResponse, error)
- func (UnimplementedDrainServiceServer) PluginInfo(context.Context, *PluginInfoRequest) (*PluginInfoResponse, error)
- func (UnimplementedDrainServiceServer) PostDrain(context.Context, *PostDrainRequest) (*PostDrainResponse, error)
- func (UnimplementedDrainServiceServer) PreDrain(context.Context, *PreDrainRequest) (*PreDrainResponse, error)
- type UnsafeDrainServiceServer
Constants ¶
const ( DrainService_PluginInfo_FullMethodName = "/api.plugins.proto.v1.DrainService/PluginInfo" DrainService_Init_FullMethodName = "/api.plugins.proto.v1.DrainService/Init" DrainService_IsSupported_FullMethodName = "/api.plugins.proto.v1.DrainService/IsSupported" DrainService_IsHealthy_FullMethodName = "/api.plugins.proto.v1.DrainService/IsHealthy" DrainService_IsDrainOk_FullMethodName = "/api.plugins.proto.v1.DrainService/IsDrainOk" DrainService_PreDrain_FullMethodName = "/api.plugins.proto.v1.DrainService/PreDrain" DrainService_PostDrain_FullMethodName = "/api.plugins.proto.v1.DrainService/PostDrain" )
Variables ¶
var ( ConfigFormat_name = map[int32]string{ 0: "CONFIG_FORMAT_UNSPECIFIED", 1: "CONFIG_FORMAT_YAML", 2: "CONFIG_FORMAT_JSON", } ConfigFormat_value = map[string]int32{ "CONFIG_FORMAT_UNSPECIFIED": 0, "CONFIG_FORMAT_YAML": 1, "CONFIG_FORMAT_JSON": 2, } )
Enum value maps for ConfigFormat.
var DrainService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.plugins.proto.v1.DrainService", HandlerType: (*DrainServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "PluginInfo", Handler: _DrainService_PluginInfo_Handler, }, { MethodName: "Init", Handler: _DrainService_Init_Handler, }, { MethodName: "IsSupported", Handler: _DrainService_IsSupported_Handler, }, { MethodName: "IsHealthy", Handler: _DrainService_IsHealthy_Handler, }, { MethodName: "IsDrainOk", Handler: _DrainService_IsDrainOk_Handler, }, { MethodName: "PreDrain", Handler: _DrainService_PreDrain_Handler, }, { MethodName: "PostDrain", Handler: _DrainService_PostDrain_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/plugins/proto/v1/drain_plugin.proto", }
DrainService_ServiceDesc is the grpc.ServiceDesc for DrainService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_api_plugins_proto_v1_drain_plugin_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDrainServiceServer ¶
func RegisterDrainServiceServer(s grpc.ServiceRegistrar, srv DrainServiceServer)
Types ¶
type ConfigFormat ¶ added in v0.0.3
type ConfigFormat int32
const ( ConfigFormat_CONFIG_FORMAT_UNSPECIFIED ConfigFormat = 0 ConfigFormat_CONFIG_FORMAT_YAML ConfigFormat = 1 ConfigFormat_CONFIG_FORMAT_JSON ConfigFormat = 2 )
func (ConfigFormat) Descriptor ¶ added in v0.0.3
func (ConfigFormat) Descriptor() protoreflect.EnumDescriptor
func (ConfigFormat) Enum ¶ added in v0.0.3
func (x ConfigFormat) Enum() *ConfigFormat
func (ConfigFormat) Number ¶ added in v0.0.3
func (x ConfigFormat) Number() protoreflect.EnumNumber
func (ConfigFormat) String ¶ added in v0.0.3
func (x ConfigFormat) String() string
func (ConfigFormat) Type ¶ added in v0.0.3
func (ConfigFormat) Type() protoreflect.EnumType
type DrainServiceClient ¶
type DrainServiceClient interface {
PluginInfo(ctx context.Context, in *PluginInfoRequest, opts ...grpc.CallOption) (*PluginInfoResponse, error)
Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error)
IsSupported(ctx context.Context, in *IsSupportedRequest, opts ...grpc.CallOption) (*IsSupportedResponse, error)
IsHealthy(ctx context.Context, in *IsHealthyRequest, opts ...grpc.CallOption) (*IsHealthyResponse, error)
IsDrainOk(ctx context.Context, in *IsDrainOkRequest, opts ...grpc.CallOption) (*IsDrainOkResponse, error)
PreDrain(ctx context.Context, in *PreDrainRequest, opts ...grpc.CallOption) (*PreDrainResponse, error)
PostDrain(ctx context.Context, in *PostDrainRequest, opts ...grpc.CallOption) (*PostDrainResponse, error)
}
DrainServiceClient is the client API for DrainService 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 NewDrainServiceClient ¶
func NewDrainServiceClient(cc grpc.ClientConnInterface) DrainServiceClient
type DrainServiceServer ¶
type DrainServiceServer interface {
PluginInfo(context.Context, *PluginInfoRequest) (*PluginInfoResponse, error)
Init(context.Context, *InitRequest) (*InitResponse, error)
IsSupported(context.Context, *IsSupportedRequest) (*IsSupportedResponse, error)
IsHealthy(context.Context, *IsHealthyRequest) (*IsHealthyResponse, error)
IsDrainOk(context.Context, *IsDrainOkRequest) (*IsDrainOkResponse, error)
PreDrain(context.Context, *PreDrainRequest) (*PreDrainResponse, error)
PostDrain(context.Context, *PostDrainRequest) (*PostDrainResponse, error)
}
DrainServiceServer is the server API for DrainService service. All implementations should embed UnimplementedDrainServiceServer for forward compatibility.
type InitRequest ¶
type InitRequest struct {
XXX_raceDetectHookData protoimpl.RaceDetectHookData
XXX_presence [1]uint32
// contains filtered or unexported fields
}
func (*InitRequest) ClearConfig ¶ added in v0.0.3
func (x *InitRequest) ClearConfig()
func (*InitRequest) GetConfig ¶ added in v0.0.3
func (x *InitRequest) GetConfig() []byte
func (*InitRequest) HasConfig ¶ added in v0.0.3
func (x *InitRequest) HasConfig() bool
func (*InitRequest) ProtoMessage ¶
func (*InitRequest) ProtoMessage()
func (*InitRequest) ProtoReflect ¶
func (x *InitRequest) ProtoReflect() protoreflect.Message
func (*InitRequest) Reset ¶
func (x *InitRequest) Reset()
func (*InitRequest) SetConfig ¶ added in v0.0.3
func (x *InitRequest) SetConfig(v []byte)
func (*InitRequest) String ¶
func (x *InitRequest) String() string
type InitRequest_builder ¶ added in v0.0.3
type InitRequest_builder struct {
Config []byte
// contains filtered or unexported fields
}
func (InitRequest_builder) Build ¶ added in v0.0.3
func (b0 InitRequest_builder) Build() *InitRequest
type InitResponse ¶
type InitResponse struct {
// contains filtered or unexported fields
}
func (*InitResponse) ProtoMessage ¶
func (*InitResponse) ProtoMessage()
func (*InitResponse) ProtoReflect ¶
func (x *InitResponse) ProtoReflect() protoreflect.Message
func (*InitResponse) Reset ¶
func (x *InitResponse) Reset()
func (*InitResponse) String ¶
func (x *InitResponse) String() string
type InitResponse_builder ¶ added in v0.0.3
type InitResponse_builder struct {
// contains filtered or unexported fields
}
func (InitResponse_builder) Build ¶ added in v0.0.3
func (b0 InitResponse_builder) Build() *InitResponse
type IsDrainOkRequest ¶
type IsDrainOkRequest struct {
XXX_raceDetectHookData protoimpl.RaceDetectHookData
XXX_presence [1]uint32
// contains filtered or unexported fields
}
func (*IsDrainOkRequest) ClearNodeName ¶ added in v0.0.3
func (x *IsDrainOkRequest) ClearNodeName()
func (*IsDrainOkRequest) GetNodeName ¶
func (x *IsDrainOkRequest) GetNodeName() string
func (*IsDrainOkRequest) HasNodeName ¶ added in v0.0.3
func (x *IsDrainOkRequest) HasNodeName() bool
func (*IsDrainOkRequest) ProtoMessage ¶
func (*IsDrainOkRequest) ProtoMessage()
func (*IsDrainOkRequest) ProtoReflect ¶
func (x *IsDrainOkRequest) ProtoReflect() protoreflect.Message
func (*IsDrainOkRequest) Reset ¶
func (x *IsDrainOkRequest) Reset()
func (*IsDrainOkRequest) SetNodeName ¶ added in v0.0.3
func (x *IsDrainOkRequest) SetNodeName(v string)
func (*IsDrainOkRequest) String ¶
func (x *IsDrainOkRequest) String() string
type IsDrainOkRequest_builder ¶ added in v0.0.3
type IsDrainOkRequest_builder struct {
NodeName *string
// contains filtered or unexported fields
}
func (IsDrainOkRequest_builder) Build ¶ added in v0.0.3
func (b0 IsDrainOkRequest_builder) Build() *IsDrainOkRequest
type IsDrainOkResponse ¶
type IsDrainOkResponse struct {
XXX_raceDetectHookData protoimpl.RaceDetectHookData
XXX_presence [1]uint32
// contains filtered or unexported fields
}
func (*IsDrainOkResponse) ClearOk ¶ added in v0.0.3
func (x *IsDrainOkResponse) ClearOk()
func (*IsDrainOkResponse) GetOk ¶
func (x *IsDrainOkResponse) GetOk() bool
func (*IsDrainOkResponse) HasOk ¶ added in v0.0.3
func (x *IsDrainOkResponse) HasOk() bool
func (*IsDrainOkResponse) ProtoMessage ¶
func (*IsDrainOkResponse) ProtoMessage()
func (*IsDrainOkResponse) ProtoReflect ¶
func (x *IsDrainOkResponse) ProtoReflect() protoreflect.Message
func (*IsDrainOkResponse) Reset ¶
func (x *IsDrainOkResponse) Reset()
func (*IsDrainOkResponse) SetOk ¶ added in v0.0.3
func (x *IsDrainOkResponse) SetOk(v bool)
func (*IsDrainOkResponse) String ¶
func (x *IsDrainOkResponse) String() string
type IsDrainOkResponse_builder ¶ added in v0.0.3
type IsDrainOkResponse_builder struct {
Ok *bool
// contains filtered or unexported fields
}
func (IsDrainOkResponse_builder) Build ¶ added in v0.0.3
func (b0 IsDrainOkResponse_builder) Build() *IsDrainOkResponse
type IsHealthyRequest ¶
type IsHealthyRequest struct {
// contains filtered or unexported fields
}
func (*IsHealthyRequest) ProtoMessage ¶
func (*IsHealthyRequest) ProtoMessage()
func (*IsHealthyRequest) ProtoReflect ¶
func (x *IsHealthyRequest) ProtoReflect() protoreflect.Message
func (*IsHealthyRequest) Reset ¶
func (x *IsHealthyRequest) Reset()
func (*IsHealthyRequest) String ¶
func (x *IsHealthyRequest) String() string
type IsHealthyRequest_builder ¶ added in v0.0.3
type IsHealthyRequest_builder struct {
// contains filtered or unexported fields
}
func (IsHealthyRequest_builder) Build ¶ added in v0.0.3
func (b0 IsHealthyRequest_builder) Build() *IsHealthyRequest
type IsHealthyResponse ¶
type IsHealthyResponse struct {
XXX_raceDetectHookData protoimpl.RaceDetectHookData
XXX_presence [1]uint32
// contains filtered or unexported fields
}
func (*IsHealthyResponse) ClearHealthy ¶ added in v0.0.3
func (x *IsHealthyResponse) ClearHealthy()
func (*IsHealthyResponse) GetHealthy ¶
func (x *IsHealthyResponse) GetHealthy() bool
func (*IsHealthyResponse) HasHealthy ¶ added in v0.0.3
func (x *IsHealthyResponse) HasHealthy() bool
func (*IsHealthyResponse) ProtoMessage ¶
func (*IsHealthyResponse) ProtoMessage()
func (*IsHealthyResponse) ProtoReflect ¶
func (x *IsHealthyResponse) ProtoReflect() protoreflect.Message
func (*IsHealthyResponse) Reset ¶
func (x *IsHealthyResponse) Reset()
func (*IsHealthyResponse) SetHealthy ¶ added in v0.0.3
func (x *IsHealthyResponse) SetHealthy(v bool)
func (*IsHealthyResponse) String ¶
func (x *IsHealthyResponse) String() string
type IsHealthyResponse_builder ¶ added in v0.0.3
type IsHealthyResponse_builder struct {
Healthy *bool
// contains filtered or unexported fields
}
func (IsHealthyResponse_builder) Build ¶ added in v0.0.3
func (b0 IsHealthyResponse_builder) Build() *IsHealthyResponse
type IsSupportedRequest ¶
type IsSupportedRequest struct {
// contains filtered or unexported fields
}
func (*IsSupportedRequest) ProtoMessage ¶
func (*IsSupportedRequest) ProtoMessage()
func (*IsSupportedRequest) ProtoReflect ¶
func (x *IsSupportedRequest) ProtoReflect() protoreflect.Message
func (*IsSupportedRequest) Reset ¶
func (x *IsSupportedRequest) Reset()
func (*IsSupportedRequest) String ¶
func (x *IsSupportedRequest) String() string
type IsSupportedRequest_builder ¶ added in v0.0.3
type IsSupportedRequest_builder struct {
// contains filtered or unexported fields
}
func (IsSupportedRequest_builder) Build ¶ added in v0.0.3
func (b0 IsSupportedRequest_builder) Build() *IsSupportedRequest
type IsSupportedResponse ¶
type IsSupportedResponse struct {
XXX_raceDetectHookData protoimpl.RaceDetectHookData
XXX_presence [1]uint32
// contains filtered or unexported fields
}
func (*IsSupportedResponse) ClearSupported ¶ added in v0.0.3
func (x *IsSupportedResponse) ClearSupported()
func (*IsSupportedResponse) GetSupported ¶
func (x *IsSupportedResponse) GetSupported() bool
func (*IsSupportedResponse) HasSupported ¶ added in v0.0.3
func (x *IsSupportedResponse) HasSupported() bool
func (*IsSupportedResponse) ProtoMessage ¶
func (*IsSupportedResponse) ProtoMessage()
func (*IsSupportedResponse) ProtoReflect ¶
func (x *IsSupportedResponse) ProtoReflect() protoreflect.Message
func (*IsSupportedResponse) Reset ¶
func (x *IsSupportedResponse) Reset()
func (*IsSupportedResponse) SetSupported ¶ added in v0.0.3
func (x *IsSupportedResponse) SetSupported(v bool)
func (*IsSupportedResponse) String ¶
func (x *IsSupportedResponse) String() string
type IsSupportedResponse_builder ¶ added in v0.0.3
type IsSupportedResponse_builder struct {
Supported *bool
// contains filtered or unexported fields
}
func (IsSupportedResponse_builder) Build ¶ added in v0.0.3
func (b0 IsSupportedResponse_builder) Build() *IsSupportedResponse
type PluginInfoRequest ¶ added in v0.0.3
type PluginInfoRequest struct {
// contains filtered or unexported fields
}
func (*PluginInfoRequest) ProtoMessage ¶ added in v0.0.3
func (*PluginInfoRequest) ProtoMessage()
func (*PluginInfoRequest) ProtoReflect ¶ added in v0.0.3
func (x *PluginInfoRequest) ProtoReflect() protoreflect.Message
func (*PluginInfoRequest) Reset ¶ added in v0.0.3
func (x *PluginInfoRequest) Reset()
func (*PluginInfoRequest) String ¶ added in v0.0.3
func (x *PluginInfoRequest) String() string
type PluginInfoRequest_builder ¶ added in v0.0.3
type PluginInfoRequest_builder struct {
// contains filtered or unexported fields
}
func (PluginInfoRequest_builder) Build ¶ added in v0.0.3
func (b0 PluginInfoRequest_builder) Build() *PluginInfoRequest
type PluginInfoResponse ¶ added in v0.0.3
type PluginInfoResponse struct {
XXX_raceDetectHookData protoimpl.RaceDetectHookData
XXX_presence [1]uint32
// contains filtered or unexported fields
}
func (*PluginInfoResponse) ClearConfigFormat ¶ added in v0.0.3
func (x *PluginInfoResponse) ClearConfigFormat()
func (*PluginInfoResponse) ClearId ¶ added in v0.0.3
func (x *PluginInfoResponse) ClearId()
func (*PluginInfoResponse) GetConfigFormat ¶ added in v0.0.3
func (x *PluginInfoResponse) GetConfigFormat() ConfigFormat
func (*PluginInfoResponse) GetId ¶ added in v0.0.3
func (x *PluginInfoResponse) GetId() string
func (*PluginInfoResponse) HasConfigFormat ¶ added in v0.0.3
func (x *PluginInfoResponse) HasConfigFormat() bool
func (*PluginInfoResponse) HasId ¶ added in v0.0.3
func (x *PluginInfoResponse) HasId() bool
func (*PluginInfoResponse) ProtoMessage ¶ added in v0.0.3
func (*PluginInfoResponse) ProtoMessage()
func (*PluginInfoResponse) ProtoReflect ¶ added in v0.0.3
func (x *PluginInfoResponse) ProtoReflect() protoreflect.Message
func (*PluginInfoResponse) Reset ¶ added in v0.0.3
func (x *PluginInfoResponse) Reset()
func (*PluginInfoResponse) SetConfigFormat ¶ added in v0.0.3
func (x *PluginInfoResponse) SetConfigFormat(v ConfigFormat)
func (*PluginInfoResponse) SetId ¶ added in v0.0.3
func (x *PluginInfoResponse) SetId(v string)
func (*PluginInfoResponse) String ¶ added in v0.0.3
func (x *PluginInfoResponse) String() string
type PluginInfoResponse_builder ¶ added in v0.0.3
type PluginInfoResponse_builder struct {
Id *string
ConfigFormat *ConfigFormat
// contains filtered or unexported fields
}
func (PluginInfoResponse_builder) Build ¶ added in v0.0.3
func (b0 PluginInfoResponse_builder) Build() *PluginInfoResponse
type PostDrainRequest ¶
type PostDrainRequest struct {
XXX_raceDetectHookData protoimpl.RaceDetectHookData
XXX_presence [1]uint32
// contains filtered or unexported fields
}
func (*PostDrainRequest) ClearNodeName ¶ added in v0.0.3
func (x *PostDrainRequest) ClearNodeName()
func (*PostDrainRequest) GetNodeName ¶
func (x *PostDrainRequest) GetNodeName() string
func (*PostDrainRequest) HasNodeName ¶ added in v0.0.3
func (x *PostDrainRequest) HasNodeName() bool
func (*PostDrainRequest) ProtoMessage ¶
func (*PostDrainRequest) ProtoMessage()
func (*PostDrainRequest) ProtoReflect ¶
func (x *PostDrainRequest) ProtoReflect() protoreflect.Message
func (*PostDrainRequest) Reset ¶
func (x *PostDrainRequest) Reset()
func (*PostDrainRequest) SetNodeName ¶ added in v0.0.3
func (x *PostDrainRequest) SetNodeName(v string)
func (*PostDrainRequest) String ¶
func (x *PostDrainRequest) String() string
type PostDrainRequest_builder ¶ added in v0.0.3
type PostDrainRequest_builder struct {
NodeName *string
// contains filtered or unexported fields
}
func (PostDrainRequest_builder) Build ¶ added in v0.0.3
func (b0 PostDrainRequest_builder) Build() *PostDrainRequest
type PostDrainResponse ¶
type PostDrainResponse struct {
// contains filtered or unexported fields
}
func (*PostDrainResponse) ProtoMessage ¶
func (*PostDrainResponse) ProtoMessage()
func (*PostDrainResponse) ProtoReflect ¶
func (x *PostDrainResponse) ProtoReflect() protoreflect.Message
func (*PostDrainResponse) Reset ¶
func (x *PostDrainResponse) Reset()
func (*PostDrainResponse) String ¶
func (x *PostDrainResponse) String() string
type PostDrainResponse_builder ¶ added in v0.0.3
type PostDrainResponse_builder struct {
// contains filtered or unexported fields
}
func (PostDrainResponse_builder) Build ¶ added in v0.0.3
func (b0 PostDrainResponse_builder) Build() *PostDrainResponse
type PreDrainRequest ¶
type PreDrainRequest struct {
XXX_raceDetectHookData protoimpl.RaceDetectHookData
XXX_presence [1]uint32
// contains filtered or unexported fields
}
func (*PreDrainRequest) ClearNodeName ¶ added in v0.0.3
func (x *PreDrainRequest) ClearNodeName()
func (*PreDrainRequest) GetNodeName ¶
func (x *PreDrainRequest) GetNodeName() string
func (*PreDrainRequest) HasNodeName ¶ added in v0.0.3
func (x *PreDrainRequest) HasNodeName() bool
func (*PreDrainRequest) ProtoMessage ¶
func (*PreDrainRequest) ProtoMessage()
func (*PreDrainRequest) ProtoReflect ¶
func (x *PreDrainRequest) ProtoReflect() protoreflect.Message
func (*PreDrainRequest) Reset ¶
func (x *PreDrainRequest) Reset()
func (*PreDrainRequest) SetNodeName ¶ added in v0.0.3
func (x *PreDrainRequest) SetNodeName(v string)
func (*PreDrainRequest) String ¶
func (x *PreDrainRequest) String() string
type PreDrainRequest_builder ¶ added in v0.0.3
type PreDrainRequest_builder struct {
NodeName *string
// contains filtered or unexported fields
}
func (PreDrainRequest_builder) Build ¶ added in v0.0.3
func (b0 PreDrainRequest_builder) Build() *PreDrainRequest
type PreDrainResponse ¶
type PreDrainResponse struct {
// contains filtered or unexported fields
}
func (*PreDrainResponse) ProtoMessage ¶
func (*PreDrainResponse) ProtoMessage()
func (*PreDrainResponse) ProtoReflect ¶
func (x *PreDrainResponse) ProtoReflect() protoreflect.Message
func (*PreDrainResponse) Reset ¶
func (x *PreDrainResponse) Reset()
func (*PreDrainResponse) String ¶
func (x *PreDrainResponse) String() string
type PreDrainResponse_builder ¶ added in v0.0.3
type PreDrainResponse_builder struct {
// contains filtered or unexported fields
}
func (PreDrainResponse_builder) Build ¶ added in v0.0.3
func (b0 PreDrainResponse_builder) Build() *PreDrainResponse
type UnimplementedDrainServiceServer ¶
type UnimplementedDrainServiceServer struct{}
UnimplementedDrainServiceServer 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 (UnimplementedDrainServiceServer) Init ¶
func (UnimplementedDrainServiceServer) Init(context.Context, *InitRequest) (*InitResponse, error)
func (UnimplementedDrainServiceServer) IsDrainOk ¶
func (UnimplementedDrainServiceServer) IsDrainOk(context.Context, *IsDrainOkRequest) (*IsDrainOkResponse, error)
func (UnimplementedDrainServiceServer) IsHealthy ¶
func (UnimplementedDrainServiceServer) IsHealthy(context.Context, *IsHealthyRequest) (*IsHealthyResponse, error)
func (UnimplementedDrainServiceServer) IsSupported ¶
func (UnimplementedDrainServiceServer) IsSupported(context.Context, *IsSupportedRequest) (*IsSupportedResponse, error)
func (UnimplementedDrainServiceServer) PluginInfo ¶ added in v0.0.3
func (UnimplementedDrainServiceServer) PluginInfo(context.Context, *PluginInfoRequest) (*PluginInfoResponse, error)
func (UnimplementedDrainServiceServer) PostDrain ¶
func (UnimplementedDrainServiceServer) PostDrain(context.Context, *PostDrainRequest) (*PostDrainResponse, error)
func (UnimplementedDrainServiceServer) PreDrain ¶
func (UnimplementedDrainServiceServer) PreDrain(context.Context, *PreDrainRequest) (*PreDrainResponse, error)
type UnsafeDrainServiceServer ¶
type UnsafeDrainServiceServer interface {
// contains filtered or unexported methods
}
UnsafeDrainServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DrainServiceServer will result in compilation errors.