cluster

Documentation

Index

• Variables
• func RegisterClusterServiceServer(s *grpc.Server, 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() *duration.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

Variables

var File_cluster_cluster_proto protoreflect.FileDescriptor

Functions

func RegisterClusterServiceServer

func RegisterClusterServiceServer(s *grpc.Server, 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClusterServiceClient

func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient

type ClusterServiceServer

type ClusterServiceServer interface {
	HealthCheck(*HealthCheckRequest, ClusterService_HealthCheckServer) error
}

ClusterServiceServer is the server API for ClusterService service.

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 *duration.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() *duration.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 can be embedded to have forward compatible implementations.

func (*UnimplementedClusterServiceServer) HealthCheck

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