cluster

package
v1.6.0-beta.0 Latest Latest
Warning

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

Go to latest
Published: Dec 1, 2023 License: MPL-2.0 Imports: 14 Imported by: 3

Documentation

Index

Constants

View Source
const (
	ClusterService_HealthCheck_FullMethodName = "/cluster.ClusterService/HealthCheck"
)

Variables

View Source
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source
var ClusterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cluster.ClusterService",
	HandlerType: (*ClusterServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "HealthCheck",
			Handler:       _ClusterService_HealthCheck_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cluster/cluster.proto",
}

ClusterService_ServiceDesc is the grpc.ServiceDesc for ClusterService 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_cluster_cluster_proto protoreflect.FileDescriptor

Functions

func RegisterClusterServiceServer

func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)

Types

type ClusterInfo

type ClusterInfo struct {
	ControlPlaneNodes []string `protobuf:"bytes,1,rep,name=control_plane_nodes,json=controlPlaneNodes,proto3" json:"control_plane_nodes,omitempty"`
	WorkerNodes       []string `protobuf:"bytes,2,rep,name=worker_nodes,json=workerNodes,proto3" json:"worker_nodes,omitempty"`
	ForceEndpoint     string   `protobuf:"bytes,3,opt,name=force_endpoint,json=forceEndpoint,proto3" json:"force_endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterInfo) Descriptor deprecated

func (*ClusterInfo) Descriptor() ([]byte, []int)

Deprecated: Use ClusterInfo.ProtoReflect.Descriptor instead.

func (*ClusterInfo) GetControlPlaneNodes

func (x *ClusterInfo) GetControlPlaneNodes() []string

func (*ClusterInfo) GetForceEndpoint

func (x *ClusterInfo) GetForceEndpoint() string

func (*ClusterInfo) GetWorkerNodes

func (x *ClusterInfo) GetWorkerNodes() []string

func (*ClusterInfo) MarshalToSizedBufferVT

func (m *ClusterInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ClusterInfo) MarshalToVT

func (m *ClusterInfo) MarshalToVT(dAtA []byte) (int, error)

func (*ClusterInfo) MarshalVT

func (m *ClusterInfo) MarshalVT() (dAtA []byte, err error)

func (*ClusterInfo) ProtoMessage

func (*ClusterInfo) ProtoMessage()

func (*ClusterInfo) ProtoReflect

func (x *ClusterInfo) ProtoReflect() protoreflect.Message

func (*ClusterInfo) Reset

func (x *ClusterInfo) Reset()

func (*ClusterInfo) SizeVT

func (m *ClusterInfo) SizeVT() (n int)

func (*ClusterInfo) String

func (x *ClusterInfo) String() string

func (*ClusterInfo) UnmarshalVT

func (m *ClusterInfo) UnmarshalVT(dAtA []byte) error

type ClusterServiceClient

type ClusterServiceClient interface {
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (ClusterService_HealthCheckClient, error)
}

ClusterServiceClient is the client API for ClusterService 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 ClusterServiceServer

type ClusterServiceServer interface {
	HealthCheck(*HealthCheckRequest, ClusterService_HealthCheckServer) error
	// contains filtered or unexported methods
}

ClusterServiceServer is the server API for ClusterService service. All implementations must embed UnimplementedClusterServiceServer for forward compatibility

type ClusterService_HealthCheckClient

type ClusterService_HealthCheckClient interface {
	Recv() (*HealthCheckProgress, error)
	grpc.ClientStream
}

type ClusterService_HealthCheckServer

type ClusterService_HealthCheckServer interface {
	Send(*HealthCheckProgress) error
	grpc.ServerStream
}

type HealthCheckProgress

type HealthCheckProgress struct {
	Metadata *common.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Message  string           `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckProgress) Descriptor deprecated

func (*HealthCheckProgress) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheckProgress.ProtoReflect.Descriptor instead.

func (*HealthCheckProgress) GetMessage

func (x *HealthCheckProgress) GetMessage() string

func (*HealthCheckProgress) GetMetadata

func (x *HealthCheckProgress) GetMetadata() *common.Metadata

func (*HealthCheckProgress) MarshalToSizedBufferVT

func (m *HealthCheckProgress) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*HealthCheckProgress) MarshalToVT

func (m *HealthCheckProgress) MarshalToVT(dAtA []byte) (int, error)

func (*HealthCheckProgress) MarshalVT

func (m *HealthCheckProgress) MarshalVT() (dAtA []byte, err error)

func (*HealthCheckProgress) ProtoMessage

func (*HealthCheckProgress) ProtoMessage()

func (*HealthCheckProgress) ProtoReflect

func (x *HealthCheckProgress) ProtoReflect() protoreflect.Message

func (*HealthCheckProgress) Reset

func (x *HealthCheckProgress) Reset()

func (*HealthCheckProgress) SizeVT

func (m *HealthCheckProgress) SizeVT() (n int)

func (*HealthCheckProgress) String

func (x *HealthCheckProgress) String() string

func (*HealthCheckProgress) UnmarshalVT

func (m *HealthCheckProgress) UnmarshalVT(dAtA []byte) error

type HealthCheckRequest

type HealthCheckRequest struct {
	WaitTimeout *durationpb.Duration `protobuf:"bytes,1,opt,name=wait_timeout,json=waitTimeout,proto3" json:"wait_timeout,omitempty"`
	ClusterInfo *ClusterInfo         `protobuf:"bytes,2,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckRequest) Descriptor deprecated

func (*HealthCheckRequest) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) GetClusterInfo

func (x *HealthCheckRequest) GetClusterInfo() *ClusterInfo

func (*HealthCheckRequest) GetWaitTimeout

func (x *HealthCheckRequest) GetWaitTimeout() *durationpb.Duration

func (*HealthCheckRequest) MarshalToSizedBufferVT

func (m *HealthCheckRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*HealthCheckRequest) MarshalToVT

func (m *HealthCheckRequest) MarshalToVT(dAtA []byte) (int, error)

func (*HealthCheckRequest) MarshalVT

func (m *HealthCheckRequest) MarshalVT() (dAtA []byte, err error)

func (*HealthCheckRequest) ProtoMessage

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect

func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message

func (*HealthCheckRequest) Reset

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) SizeVT

func (m *HealthCheckRequest) SizeVT() (n int)

func (*HealthCheckRequest) String

func (x *HealthCheckRequest) String() string

func (*HealthCheckRequest) UnmarshalVT

func (m *HealthCheckRequest) UnmarshalVT(dAtA []byte) error

type UnimplementedClusterServiceServer

type UnimplementedClusterServiceServer struct {
}

UnimplementedClusterServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedClusterServiceServer) HealthCheck

type UnsafeClusterServiceServer

type UnsafeClusterServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeClusterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterServiceServer will result in compilation errors.

Jump to

Keyboard shortcuts

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