cluster

Documentation

Index

• Constants
• Variables
• func RegisterClusterInterfaceServer(s grpc.ServiceRegistrar, srv ClusterInterfaceServer)
• type ClusterInstalled
  • func (*ClusterInstalled) Descriptor() ([]byte, []int)
  • func (x *ClusterInstalled) GetInstalled() bool
  • func (*ClusterInstalled) ProtoMessage()
  • func (x *ClusterInstalled) ProtoReflect() protoreflect.Message
  • func (x *ClusterInstalled) Reset()
  • func (x *ClusterInstalled) String() string
• type ClusterInterfaceClient
  • func NewClusterInterfaceClient(cc grpc.ClientConnInterface) ClusterInterfaceClient
• type ClusterInterfaceServer
• type UnimplementedClusterInterfaceServer
  • func (UnimplementedClusterInterfaceServer) CheckClusterInstalled(context.Context, *biz.Cluster) (*ClusterInstalled, error)
  • func (UnimplementedClusterInterfaceServer) CurrentCluster(context.Context, *biz.Cluster) (*biz.Cluster, error)
  • func (UnimplementedClusterInterfaceServer) HandlerNodes(context.Context, *biz.Cluster) (*biz.Cluster, error)
• type UnsafeClusterInterfaceServer

Constants

const (
	ClusterInterface_CheckClusterInstalled_FullMethodName = "/clusterruntime.api.cluster.ClusterInterface/CheckClusterInstalled"
	ClusterInterface_CurrentCluster_FullMethodName        = "/clusterruntime.api.cluster.ClusterInterface/CurrentCluster"
	ClusterInterface_HandlerNodes_FullMethodName          = "/clusterruntime.api.cluster.ClusterInterface/HandlerNodes"
)

Variables

var ClusterInterface_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "clusterruntime.api.cluster.ClusterInterface",
	HandlerType: (*ClusterInterfaceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CheckClusterInstalled",
			Handler:    _ClusterInterface_CheckClusterInstalled_Handler,
		},
		{
			MethodName: "CurrentCluster",
			Handler:    _ClusterInterface_CurrentCluster_Handler,
		},
		{
			MethodName: "HandlerNodes",
			Handler:    _ClusterInterface_HandlerNodes_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/repository/clusterruntime/api/cluster/cluster.proto",
}

ClusterInterface_ServiceDesc is the grpc.ServiceDesc for ClusterInterface service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var File_internal_repository_clusterruntime_api_cluster_cluster_proto protoreflect.FileDescriptor

var File_internal_repository_clusterruntime_api_cluster_message_proto protoreflect.FileDescriptor

Functions

func RegisterClusterInterfaceServer

func RegisterClusterInterfaceServer(s grpc.ServiceRegistrar, srv ClusterInterfaceServer)

Types

type ClusterInstalled

type ClusterInstalled struct {
	Installed bool `protobuf:"varint,1,opt,name=installed,proto3" json:"installed,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterInstalled) Descriptor

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

Deprecated: Use ClusterInstalled.ProtoReflect.Descriptor instead.

func (*ClusterInstalled) GetInstalled

func (x *ClusterInstalled) GetInstalled() bool

func (*ClusterInstalled) ProtoMessage

func (*ClusterInstalled) ProtoMessage()

func (*ClusterInstalled) ProtoReflect

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

func (*ClusterInstalled) Reset

func (x *ClusterInstalled) Reset()

func (*ClusterInstalled) String

func (x *ClusterInstalled) String() string

type ClusterInterfaceClient

type ClusterInterfaceClient interface {
	CheckClusterInstalled(ctx context.Context, in *biz.Cluster, opts ...grpc.CallOption) (*ClusterInstalled, error)
	CurrentCluster(ctx context.Context, in *biz.Cluster, opts ...grpc.CallOption) (*biz.Cluster, error)
	HandlerNodes(ctx context.Context, in *biz.Cluster, opts ...grpc.CallOption) (*biz.Cluster, error)
}

ClusterInterfaceClient is the client API for ClusterInterface 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 NewClusterInterfaceClient

func NewClusterInterfaceClient(cc grpc.ClientConnInterface) ClusterInterfaceClient

type ClusterInterfaceServer

type ClusterInterfaceServer interface {
	CheckClusterInstalled(context.Context, *biz.Cluster) (*ClusterInstalled, error)
	CurrentCluster(context.Context, *biz.Cluster) (*biz.Cluster, error)
	HandlerNodes(context.Context, *biz.Cluster) (*biz.Cluster, error)
	// contains filtered or unexported methods
}

ClusterInterfaceServer is the server API for ClusterInterface service. All implementations must embed UnimplementedClusterInterfaceServer for forward compatibility.

type UnimplementedClusterInterfaceServer

type UnimplementedClusterInterfaceServer struct{}

UnimplementedClusterInterfaceServer must 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 (UnimplementedClusterInterfaceServer) CheckClusterInstalled

func (UnimplementedClusterInterfaceServer) CheckClusterInstalled(context.Context, *biz.Cluster) (*ClusterInstalled, error)

func (UnimplementedClusterInterfaceServer) CurrentCluster

func (UnimplementedClusterInterfaceServer) CurrentCluster(context.Context, *biz.Cluster) (*biz.Cluster, error)

func (UnimplementedClusterInterfaceServer) HandlerNodes

func (UnimplementedClusterInterfaceServer) HandlerNodes(context.Context, *biz.Cluster) (*biz.Cluster, error)

type UnsafeClusterInterfaceServer

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

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