v1

package
v0.0.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 25, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
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

View Source
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.

View Source
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)

View Source
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) Enum added in v0.0.3

func (x ConfigFormat) Enum() *ConfigFormat

func (ConfigFormat) Number added in v0.0.3

func (ConfigFormat) String added in v0.0.3

func (x ConfigFormat) String() string

func (ConfigFormat) Type added in v0.0.3

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.

type DrainServiceServer

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

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

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

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

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

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

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

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

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

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

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

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

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) IsDrainOk

func (UnimplementedDrainServiceServer) IsHealthy

func (UnimplementedDrainServiceServer) IsSupported

func (UnimplementedDrainServiceServer) PluginInfo added in v0.0.3

func (UnimplementedDrainServiceServer) PostDrain

func (UnimplementedDrainServiceServer) PreDrain

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.

Jump to

Keyboard shortcuts

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