v1

package

Go to main page

Versions in this module

v0

v0.0.10

Sep 25, 2025

v0.0.9

Sep 24, 2025

v0.0.8

Sep 23, 2025

v0.0.7

Sep 23, 2025

v0.0.6

Sep 22, 2025

v0.0.5

Sep 19, 2025

v0.0.4

Sep 18, 2025

v0.0.3

Sep 17, 2025

Changes in this version

+ const DrainService_PluginInfo_FullMethodName

+ var ConfigFormat_name = map[int32]string

+ var ConfigFormat_value = map[string]int32

+ type ConfigFormat int32

+ const ConfigFormat_CONFIG_FORMAT_JSON

+ const ConfigFormat_CONFIG_FORMAT_UNSPECIFIED

+ const ConfigFormat_CONFIG_FORMAT_YAML

+ func (ConfigFormat) Descriptor() protoreflect.EnumDescriptor

+ func (ConfigFormat) Type() protoreflect.EnumType

+ func (x ConfigFormat) Enum() *ConfigFormat

+ func (x ConfigFormat) Number() protoreflect.EnumNumber

+ func (x ConfigFormat) String() string

type DrainServiceClient

+ PluginInfo func(ctx context.Context, in *PluginInfoRequest, opts ...grpc.CallOption) (*PluginInfoResponse, error)

type DrainServiceServer

+ PluginInfo func(context.Context, *PluginInfoRequest) (*PluginInfoResponse, error)

type InitRequest

+ XXX_presence [1]uint32

+ XXX_raceDetectHookData protoimpl.RaceDetectHookData

+ func (x *InitRequest) ClearConfig()

+ func (x *InitRequest) GetConfig() []byte

+ func (x *InitRequest) HasConfig() bool

+ func (x *InitRequest) SetConfig(v []byte)

+ type InitRequest_builder struct

+ Config []byte

+ func (b0 InitRequest_builder) Build() *InitRequest

+ type InitResponse_builder struct

+ func (b0 InitResponse_builder) Build() *InitResponse

type IsDrainOkRequest

+ XXX_presence [1]uint32

+ XXX_raceDetectHookData protoimpl.RaceDetectHookData

+ func (x *IsDrainOkRequest) ClearNodeName()

+ func (x *IsDrainOkRequest) HasNodeName() bool

+ func (x *IsDrainOkRequest) SetNodeName(v string)

+ type IsDrainOkRequest_builder struct

+ NodeName *string

+ func (b0 IsDrainOkRequest_builder) Build() *IsDrainOkRequest

type IsDrainOkResponse

+ XXX_presence [1]uint32

+ XXX_raceDetectHookData protoimpl.RaceDetectHookData

+ func (x *IsDrainOkResponse) ClearOk()

+ func (x *IsDrainOkResponse) HasOk() bool

+ func (x *IsDrainOkResponse) SetOk(v bool)

+ type IsDrainOkResponse_builder struct

+ Ok *bool

+ func (b0 IsDrainOkResponse_builder) Build() *IsDrainOkResponse

+ type IsHealthyRequest_builder struct

+ func (b0 IsHealthyRequest_builder) Build() *IsHealthyRequest

type IsHealthyResponse

+ XXX_presence [1]uint32

+ XXX_raceDetectHookData protoimpl.RaceDetectHookData

+ func (x *IsHealthyResponse) ClearHealthy()

+ func (x *IsHealthyResponse) HasHealthy() bool

+ func (x *IsHealthyResponse) SetHealthy(v bool)

+ type IsHealthyResponse_builder struct

+ Healthy *bool

+ func (b0 IsHealthyResponse_builder) Build() *IsHealthyResponse

+ type IsSupportedRequest_builder struct

+ func (b0 IsSupportedRequest_builder) Build() *IsSupportedRequest

type IsSupportedResponse

+ XXX_presence [1]uint32

+ XXX_raceDetectHookData protoimpl.RaceDetectHookData

+ func (x *IsSupportedResponse) ClearSupported()

+ func (x *IsSupportedResponse) HasSupported() bool

+ func (x *IsSupportedResponse) SetSupported(v bool)

+ type IsSupportedResponse_builder struct

+ Supported *bool

+ func (b0 IsSupportedResponse_builder) Build() *IsSupportedResponse

+ type PluginInfoRequest struct

+ func (*PluginInfoRequest) ProtoMessage()

+ func (x *PluginInfoRequest) ProtoReflect() protoreflect.Message

+ func (x *PluginInfoRequest) Reset()

+ func (x *PluginInfoRequest) String() string

+ type PluginInfoRequest_builder struct

+ func (b0 PluginInfoRequest_builder) Build() *PluginInfoRequest

+ type PluginInfoResponse struct

+ XXX_presence [1]uint32

+ XXX_raceDetectHookData protoimpl.RaceDetectHookData

+ func (*PluginInfoResponse) ProtoMessage()

+ 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 (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 struct

+ ConfigFormat *ConfigFormat

+ Id *string

+ func (b0 PluginInfoResponse_builder) Build() *PluginInfoResponse

type PostDrainRequest

+ XXX_presence [1]uint32

+ XXX_raceDetectHookData protoimpl.RaceDetectHookData

+ func (x *PostDrainRequest) ClearNodeName()

+ func (x *PostDrainRequest) HasNodeName() bool

+ func (x *PostDrainRequest) SetNodeName(v string)

+ type PostDrainRequest_builder struct

+ NodeName *string

+ func (b0 PostDrainRequest_builder) Build() *PostDrainRequest

+ type PostDrainResponse_builder struct

+ func (b0 PostDrainResponse_builder) Build() *PostDrainResponse

type PreDrainRequest

+ XXX_presence [1]uint32

+ XXX_raceDetectHookData protoimpl.RaceDetectHookData

+ func (x *PreDrainRequest) ClearNodeName()

+ func (x *PreDrainRequest) HasNodeName() bool

+ func (x *PreDrainRequest) SetNodeName(v string)

+ type PreDrainRequest_builder struct

+ NodeName *string

+ func (b0 PreDrainRequest_builder) Build() *PreDrainRequest

+ type PreDrainResponse_builder struct

+ func (b0 PreDrainResponse_builder) Build() *PreDrainResponse

type UnimplementedDrainServiceServer

+ func (UnimplementedDrainServiceServer) PluginInfo(context.Context, *PluginInfoRequest) (*PluginInfoResponse, error)

v0.0.2

Sep 3, 2025

v0.0.1

Sep 3, 2025

Changes in this version

+ const DrainService_Init_FullMethodName

+ const DrainService_IsDrainOk_FullMethodName

+ const DrainService_IsHealthy_FullMethodName

+ const DrainService_IsSupported_FullMethodName

+ const DrainService_PostDrain_FullMethodName

+ const DrainService_PreDrain_FullMethodName

+ var DrainService_ServiceDesc = grpc.ServiceDesc

+ var File_api_plugins_proto_v1_drain_plugin_proto protoreflect.FileDescriptor

+ func RegisterDrainServiceServer(s grpc.ServiceRegistrar, srv DrainServiceServer)

+ type DrainServiceClient interface

+ Init func(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error)

+ IsDrainOk func(ctx context.Context, in *IsDrainOkRequest, opts ...grpc.CallOption) (*IsDrainOkResponse, error)

+ IsHealthy func(ctx context.Context, in *IsHealthyRequest, opts ...grpc.CallOption) (*IsHealthyResponse, error)

+ IsSupported func(ctx context.Context, in *IsSupportedRequest, opts ...grpc.CallOption) (*IsSupportedResponse, error)

+ PostDrain func(ctx context.Context, in *PostDrainRequest, opts ...grpc.CallOption) (*PostDrainResponse, error)

+ PreDrain func(ctx context.Context, in *PreDrainRequest, opts ...grpc.CallOption) (*PreDrainResponse, error)

+ func NewDrainServiceClient(cc grpc.ClientConnInterface) DrainServiceClient

+ type DrainServiceServer interface

+ Init func(context.Context, *InitRequest) (*InitResponse, error)

+ IsDrainOk func(context.Context, *IsDrainOkRequest) (*IsDrainOkResponse, error)

+ IsHealthy func(context.Context, *IsHealthyRequest) (*IsHealthyResponse, error)

+ IsSupported func(context.Context, *IsSupportedRequest) (*IsSupportedResponse, error)

+ PostDrain func(context.Context, *PostDrainRequest) (*PostDrainResponse, error)

+ PreDrain func(context.Context, *PreDrainRequest) (*PreDrainResponse, error)

+ type InitRequest struct

+ func (*InitRequest) Descriptor() ([]byte, []int)

+ func (*InitRequest) ProtoMessage()

+ func (x *InitRequest) ProtoReflect() protoreflect.Message

+ func (x *InitRequest) Reset()

+ func (x *InitRequest) String() string

+ type InitResponse struct

+ Id string

+ func (*InitResponse) Descriptor() ([]byte, []int)

+ func (*InitResponse) ProtoMessage()

+ func (x *InitResponse) GetId() string

+ func (x *InitResponse) ProtoReflect() protoreflect.Message

+ func (x *InitResponse) Reset()

+ func (x *InitResponse) String() string

+ type IsDrainOkRequest struct

+ NodeName string

+ func (*IsDrainOkRequest) Descriptor() ([]byte, []int)

+ func (*IsDrainOkRequest) ProtoMessage()

+ func (x *IsDrainOkRequest) GetNodeName() string

+ func (x *IsDrainOkRequest) ProtoReflect() protoreflect.Message

+ func (x *IsDrainOkRequest) Reset()

+ func (x *IsDrainOkRequest) String() string

+ type IsDrainOkResponse struct

+ Ok bool

+ func (*IsDrainOkResponse) Descriptor() ([]byte, []int)

+ func (*IsDrainOkResponse) ProtoMessage()

+ func (x *IsDrainOkResponse) GetOk() bool

+ func (x *IsDrainOkResponse) ProtoReflect() protoreflect.Message

+ func (x *IsDrainOkResponse) Reset()

+ func (x *IsDrainOkResponse) String() string

+ type IsHealthyRequest struct

+ func (*IsHealthyRequest) Descriptor() ([]byte, []int)

+ func (*IsHealthyRequest) ProtoMessage()

+ func (x *IsHealthyRequest) ProtoReflect() protoreflect.Message

+ func (x *IsHealthyRequest) Reset()

+ func (x *IsHealthyRequest) String() string

+ type IsHealthyResponse struct

+ Healthy bool

+ func (*IsHealthyResponse) Descriptor() ([]byte, []int)

+ func (*IsHealthyResponse) ProtoMessage()

+ func (x *IsHealthyResponse) GetHealthy() bool

+ func (x *IsHealthyResponse) ProtoReflect() protoreflect.Message

+ func (x *IsHealthyResponse) Reset()

+ func (x *IsHealthyResponse) String() string

+ type IsSupportedRequest struct

+ func (*IsSupportedRequest) Descriptor() ([]byte, []int)

+ func (*IsSupportedRequest) ProtoMessage()

+ func (x *IsSupportedRequest) ProtoReflect() protoreflect.Message

+ func (x *IsSupportedRequest) Reset()

+ func (x *IsSupportedRequest) String() string

+ type IsSupportedResponse struct

+ Supported bool

+ func (*IsSupportedResponse) Descriptor() ([]byte, []int)

+ func (*IsSupportedResponse) ProtoMessage()

+ func (x *IsSupportedResponse) GetSupported() bool

+ func (x *IsSupportedResponse) ProtoReflect() protoreflect.Message

+ func (x *IsSupportedResponse) Reset()

+ func (x *IsSupportedResponse) String() string

+ type PostDrainRequest struct

+ NodeName string

+ func (*PostDrainRequest) Descriptor() ([]byte, []int)

+ func (*PostDrainRequest) ProtoMessage()

+ func (x *PostDrainRequest) GetNodeName() string

+ func (x *PostDrainRequest) ProtoReflect() protoreflect.Message

+ func (x *PostDrainRequest) Reset()

+ func (x *PostDrainRequest) String() string

+ type PostDrainResponse struct

+ func (*PostDrainResponse) Descriptor() ([]byte, []int)

+ func (*PostDrainResponse) ProtoMessage()

+ func (x *PostDrainResponse) ProtoReflect() protoreflect.Message

+ func (x *PostDrainResponse) Reset()

+ func (x *PostDrainResponse) String() string

+ type PreDrainRequest struct

+ NodeName string

+ func (*PreDrainRequest) Descriptor() ([]byte, []int)

+ func (*PreDrainRequest) ProtoMessage()

+ func (x *PreDrainRequest) GetNodeName() string

+ func (x *PreDrainRequest) ProtoReflect() protoreflect.Message

+ func (x *PreDrainRequest) Reset()

+ func (x *PreDrainRequest) String() string

+ type PreDrainResponse struct

+ func (*PreDrainResponse) Descriptor() ([]byte, []int)

+ func (*PreDrainResponse) ProtoMessage()

+ func (x *PreDrainResponse) ProtoReflect() protoreflect.Message

+ func (x *PreDrainResponse) Reset()

+ func (x *PreDrainResponse) String() string

+ type UnimplementedDrainServiceServer struct

+ 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) PostDrain(context.Context, *PostDrainRequest) (*PostDrainResponse, error)

+ func (UnimplementedDrainServiceServer) PreDrain(context.Context, *PreDrainRequest) (*PreDrainResponse, error)

+ type UnsafeDrainServiceServer interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL