cluster

package
v1.7.7 Latest Latest
Warning

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

 Go to latest Published: Sep 26, 2024 License: MPL-2.0 Imports: 15 Imported by: 3

Documentation

Index

Constants

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

Variables

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.

func NewClusterServiceClient 

func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient

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 

func (UnimplementedClusterServiceServer) HealthCheck(*HealthCheckRequest, ClusterService_HealthCheckServer) error

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.