cluster

Documentation

Index

• Variables
• func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)
• type ClusterInfo
  • func (*ClusterInfo) Descriptor() ([]byte, []int)
  • func (x *ClusterInfo) GetControlPlaneNodes() []string
  • func (x *ClusterInfo) GetForceEndpoint() string
  • func (x *ClusterInfo) GetWorkerNodes() []string
  • func (*ClusterInfo) ProtoMessage()
  • func (x *ClusterInfo) ProtoReflect() protoreflect.Message
  • func (x *ClusterInfo) Reset()
  • func (x *ClusterInfo) String() string
• type ClusterServiceClient
  • func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient
• type ClusterServiceServer
• type ClusterService_HealthCheckClient
• type ClusterService_HealthCheckServer
• type HealthCheckProgress
  • func (*HealthCheckProgress) Descriptor() ([]byte, []int)
  • func (x *HealthCheckProgress) GetMessage() string
  • func (x *HealthCheckProgress) GetMetadata() *common.Metadata
  • func (*HealthCheckProgress) ProtoMessage()
  • func (x *HealthCheckProgress) ProtoReflect() protoreflect.Message
  • func (x *HealthCheckProgress) Reset()
  • func (x *HealthCheckProgress) String() string
• type HealthCheckRequest
  • func (*HealthCheckRequest) Descriptor() ([]byte, []int)
  • func (x *HealthCheckRequest) GetClusterInfo() *ClusterInfo
  • func (x *HealthCheckRequest) GetWaitTimeout() *durationpb.Duration
  • func (*HealthCheckRequest) ProtoMessage()
  • func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message
  • func (x *HealthCheckRequest) Reset()
  • func (x *HealthCheckRequest) String() string
• type UnimplementedClusterServiceServer
  • func (UnimplementedClusterServiceServer) HealthCheck(*HealthCheckRequest, ClusterService_HealthCheckServer) error
• type UnsafeClusterServiceServer

Variables

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)

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

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

func (*ClusterInfo) ProtoMessage()

func (*ClusterInfo) ProtoReflect

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

func (*ClusterInfo) Reset

func (x *ClusterInfo) Reset()

func (*ClusterInfo) String

func (x *ClusterInfo) String() string

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

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

func (*HealthCheckProgress) ProtoMessage()

func (*HealthCheckProgress) ProtoReflect

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

func (*HealthCheckProgress) Reset

func (x *HealthCheckProgress) Reset()

func (*HealthCheckProgress) String

func (x *HealthCheckProgress) String() string

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

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

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect

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

func (*HealthCheckRequest) Reset

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String

func (x *HealthCheckRequest) String() string

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.