Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterClusterInterfaceHTTPServer(s *http.Server, srv ClusterInterfaceHTTPServer)
- func RegisterClusterInterfaceServer(s grpc.ServiceRegistrar, srv ClusterInterfaceServer)
- type Cluster
- func (*Cluster) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster) GetAddons() string
- func (x *Cluster) GetAddonsConfig() string
- func (x *Cluster) GetApiServerAddress() string
- func (x *Cluster) GetConfig() string
- func (x *Cluster) GetId() int64
- func (x *Cluster) GetIsCurrentCluster() bool
- func (x *Cluster) GetLogs() string
- func (x *Cluster) GetName() string
- func (x *Cluster) GetNodes() []*Node
- func (x *Cluster) GetServerVersion() string
- func (x *Cluster) GetState() string
- func (*Cluster) ProtoMessage()
- func (x *Cluster) ProtoReflect() protoreflect.Message
- func (x *Cluster) Reset()
- func (x *Cluster) String() string
- type ClusterID
- type ClusterInterfaceClient
- type ClusterInterfaceHTTPClient
- type ClusterInterfaceHTTPClientImpl
- func (c *ClusterInterfaceHTTPClientImpl) AddNode(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Msg, error)
- func (c *ClusterInterfaceHTTPClientImpl) CheckClusterConfig(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Cluster, error)
- func (c *ClusterInterfaceHTTPClientImpl) Delete(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Msg, error)
- func (c *ClusterInterfaceHTTPClientImpl) DeleteNode(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Msg, error)
- func (c *ClusterInterfaceHTTPClientImpl) Get(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Cluster, error)
- func (c *ClusterInterfaceHTTPClientImpl) GetClusterMockData(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*Cluster, error)
- func (c *ClusterInterfaceHTTPClientImpl) GetCurrentCluster(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*Cluster, error)
- func (c *ClusterInterfaceHTTPClientImpl) List(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*ClusterList, error)
- func (c *ClusterInterfaceHTTPClientImpl) Ping(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*Msg, error)
- func (c *ClusterInterfaceHTTPClientImpl) RemoveNode(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Msg, error)
- func (c *ClusterInterfaceHTTPClientImpl) Save(ctx context.Context, in *Cluster, opts ...http.CallOption) (*Cluster, error)
- func (c *ClusterInterfaceHTTPClientImpl) SetUpCluster(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Msg, error)
- func (c *ClusterInterfaceHTTPClientImpl) UninstallCluster(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Msg, error)
- type ClusterInterfaceHTTPServer
- type ClusterInterfaceServer
- type ClusterList
- type ErrorReason
- func (ErrorReason) Descriptor() protoreflect.EnumDescriptor
- func (x ErrorReason) Enum() *ErrorReason
- func (ErrorReason) EnumDescriptor() ([]byte, []int)deprecated
- func (x ErrorReason) Number() protoreflect.EnumNumber
- func (x ErrorReason) String() string
- func (ErrorReason) Type() protoreflect.EnumType
- type Msg
- type Node
- func (*Node) Descriptor() ([]byte, []int)deprecated
- func (x *Node) GetAnnotations() string
- func (x *Node) GetClusterId() int64
- func (x *Node) GetContainer() string
- func (x *Node) GetExternalIp() string
- func (x *Node) GetId() int64
- func (x *Node) GetInternalIp() string
- func (x *Node) GetKernel() string
- func (x *Node) GetKubeProxy() string
- func (x *Node) GetKubelet() string
- func (x *Node) GetLabels() string
- func (x *Node) GetName() string
- func (x *Node) GetOsImage() string
- func (x *Node) GetPassword() string
- func (x *Node) GetRole() string
- func (x *Node) GetState() string
- func (x *Node) GetSudoPassword() string
- func (x *Node) GetUser() string
- func (*Node) ProtoMessage()
- func (x *Node) ProtoReflect() protoreflect.Message
- func (x *Node) Reset()
- func (x *Node) String() string
- type UnimplementedClusterInterfaceServer
- func (UnimplementedClusterInterfaceServer) AddNode(context.Context, *ClusterID) (*Msg, error)
- func (UnimplementedClusterInterfaceServer) CheckClusterConfig(context.Context, *ClusterID) (*Cluster, error)
- func (UnimplementedClusterInterfaceServer) Delete(context.Context, *ClusterID) (*Msg, error)
- func (UnimplementedClusterInterfaceServer) DeleteNode(context.Context, *ClusterID) (*Msg, error)
- func (UnimplementedClusterInterfaceServer) Get(context.Context, *ClusterID) (*Cluster, error)
- func (UnimplementedClusterInterfaceServer) GetClusterMockData(context.Context, *emptypb.Empty) (*Cluster, error)
- func (UnimplementedClusterInterfaceServer) GetCurrentCluster(context.Context, *emptypb.Empty) (*Cluster, error)
- func (UnimplementedClusterInterfaceServer) List(context.Context, *emptypb.Empty) (*ClusterList, error)
- func (UnimplementedClusterInterfaceServer) Ping(context.Context, *emptypb.Empty) (*Msg, error)
- func (UnimplementedClusterInterfaceServer) RemoveNode(context.Context, *ClusterID) (*Msg, error)
- func (UnimplementedClusterInterfaceServer) Save(context.Context, *Cluster) (*Cluster, error)
- func (UnimplementedClusterInterfaceServer) SetUpCluster(context.Context, *ClusterID) (*Msg, error)
- func (UnimplementedClusterInterfaceServer) UninstallCluster(context.Context, *ClusterID) (*Msg, error)
- type UnsafeClusterInterfaceServer
Constants ¶
const ( ClusterInterface_Ping_FullMethodName = "/cluster.v1alpha1.ClusterInterface/Ping" ClusterInterface_Get_FullMethodName = "/cluster.v1alpha1.ClusterInterface/Get" ClusterInterface_Save_FullMethodName = "/cluster.v1alpha1.ClusterInterface/Save" ClusterInterface_List_FullMethodName = "/cluster.v1alpha1.ClusterInterface/List" ClusterInterface_GetCurrentCluster_FullMethodName = "/cluster.v1alpha1.ClusterInterface/GetCurrentCluster" ClusterInterface_Delete_FullMethodName = "/cluster.v1alpha1.ClusterInterface/Delete" ClusterInterface_DeleteNode_FullMethodName = "/cluster.v1alpha1.ClusterInterface/DeleteNode" ClusterInterface_GetClusterMockData_FullMethodName = "/cluster.v1alpha1.ClusterInterface/GetClusterMockData" ClusterInterface_CheckClusterConfig_FullMethodName = "/cluster.v1alpha1.ClusterInterface/CheckClusterConfig" ClusterInterface_SetUpCluster_FullMethodName = "/cluster.v1alpha1.ClusterInterface/SetUpCluster" ClusterInterface_UninstallCluster_FullMethodName = "/cluster.v1alpha1.ClusterInterface/UninstallCluster" ClusterInterface_AddNode_FullMethodName = "/cluster.v1alpha1.ClusterInterface/AddNode" ClusterInterface_RemoveNode_FullMethodName = "/cluster.v1alpha1.ClusterInterface/RemoveNode" )
const OperationClusterInterfaceAddNode = "/cluster.v1alpha1.ClusterInterface/AddNode"
const OperationClusterInterfaceCheckClusterConfig = "/cluster.v1alpha1.ClusterInterface/CheckClusterConfig"
const OperationClusterInterfaceDelete = "/cluster.v1alpha1.ClusterInterface/Delete"
const OperationClusterInterfaceDeleteNode = "/cluster.v1alpha1.ClusterInterface/DeleteNode"
const OperationClusterInterfaceGet = "/cluster.v1alpha1.ClusterInterface/Get"
const OperationClusterInterfaceGetClusterMockData = "/cluster.v1alpha1.ClusterInterface/GetClusterMockData"
const OperationClusterInterfaceGetCurrentCluster = "/cluster.v1alpha1.ClusterInterface/GetCurrentCluster"
const OperationClusterInterfaceList = "/cluster.v1alpha1.ClusterInterface/List"
const OperationClusterInterfacePing = "/cluster.v1alpha1.ClusterInterface/Ping"
const OperationClusterInterfaceRemoveNode = "/cluster.v1alpha1.ClusterInterface/RemoveNode"
const OperationClusterInterfaceSave = "/cluster.v1alpha1.ClusterInterface/Save"
const OperationClusterInterfaceSetUpCluster = "/cluster.v1alpha1.ClusterInterface/SetUpCluster"
const OperationClusterInterfaceUninstallCluster = "/cluster.v1alpha1.ClusterInterface/UninstallCluster"
Variables ¶
var ( ErrorReason_name = map[int32]string{ 0: "SUCCEED", 1: "FAILED", } ErrorReason_value = map[string]int32{ "SUCCEED": 0, "FAILED": 1, } )
Enum value maps for ErrorReason.
var ClusterInterface_ServiceDesc = grpc.ServiceDesc{ ServiceName: "cluster.v1alpha1.ClusterInterface", HandlerType: (*ClusterInterfaceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Ping", Handler: _ClusterInterface_Ping_Handler, }, { MethodName: "Get", Handler: _ClusterInterface_Get_Handler, }, { MethodName: "Save", Handler: _ClusterInterface_Save_Handler, }, { MethodName: "List", Handler: _ClusterInterface_List_Handler, }, { MethodName: "GetCurrentCluster", Handler: _ClusterInterface_GetCurrentCluster_Handler, }, { MethodName: "Delete", Handler: _ClusterInterface_Delete_Handler, }, { MethodName: "DeleteNode", Handler: _ClusterInterface_DeleteNode_Handler, }, { MethodName: "GetClusterMockData", Handler: _ClusterInterface_GetClusterMockData_Handler, }, { MethodName: "CheckClusterConfig", Handler: _ClusterInterface_CheckClusterConfig_Handler, }, { MethodName: "SetUpCluster", Handler: _ClusterInterface_SetUpCluster_Handler, }, { MethodName: "UninstallCluster", Handler: _ClusterInterface_UninstallCluster_Handler, }, { MethodName: "AddNode", Handler: _ClusterInterface_AddNode_Handler, }, { MethodName: "RemoveNode", Handler: _ClusterInterface_RemoveNode_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/cluster/v1alpha1/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_api_cluster_v1alpha1_cluster_proto protoreflect.FileDescriptor
var File_api_cluster_v1alpha1_error_reason_proto protoreflect.FileDescriptor
var File_api_cluster_v1alpha1_message_proto protoreflect.FileDescriptor
Functions ¶
func RegisterClusterInterfaceHTTPServer ¶
func RegisterClusterInterfaceHTTPServer(s *http.Server, srv ClusterInterfaceHTTPServer)
func RegisterClusterInterfaceServer ¶
func RegisterClusterInterfaceServer(s grpc.ServiceRegistrar, srv ClusterInterfaceServer)
Types ¶
type Cluster ¶
type Cluster struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` ServerVersion string `protobuf:"bytes,3,opt,name=server_version,proto3" json:"server_version,omitempty"` ApiServerAddress string `protobuf:"bytes,4,opt,name=api_server_address,proto3" json:"api_server_address,omitempty"` Config string `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"` Addons string `protobuf:"bytes,6,opt,name=addons,proto3" json:"addons,omitempty"` AddonsConfig string `protobuf:"bytes,7,opt,name=addons_config,proto3" json:"addons_config,omitempty"` State string `protobuf:"bytes,8,opt,name=state,proto3" json:"state,omitempty"` Nodes []*Node `protobuf:"bytes,9,rep,name=nodes,proto3" json:"nodes,omitempty"` Logs string `protobuf:"bytes,10,opt,name=logs,proto3" json:"logs,omitempty"` IsCurrentCluster bool `protobuf:"varint,11,opt,name=is_current_cluster,proto3" json:"is_current_cluster,omitempty"` // 是否是当前集群状态 // contains filtered or unexported fields }
func (*Cluster) Descriptor
deprecated
func (*Cluster) GetAddonsConfig ¶
func (*Cluster) GetApiServerAddress ¶
func (*Cluster) GetIsCurrentCluster ¶
func (*Cluster) GetServerVersion ¶
func (*Cluster) ProtoMessage ¶
func (*Cluster) ProtoMessage()
func (*Cluster) ProtoReflect ¶
func (x *Cluster) ProtoReflect() protoreflect.Message
type ClusterID ¶
type ClusterID struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` NodeId int64 `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // contains filtered or unexported fields }
func (*ClusterID) Descriptor
deprecated
func (*ClusterID) ProtoMessage ¶
func (*ClusterID) ProtoMessage()
func (*ClusterID) ProtoReflect ¶
func (x *ClusterID) ProtoReflect() protoreflect.Message
type ClusterInterfaceClient ¶
type ClusterInterfaceClient interface { Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Msg, error) Get(ctx context.Context, in *ClusterID, opts ...grpc.CallOption) (*Cluster, error) Save(ctx context.Context, in *Cluster, opts ...grpc.CallOption) (*Cluster, error) List(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ClusterList, error) GetCurrentCluster(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Cluster, error) Delete(ctx context.Context, in *ClusterID, opts ...grpc.CallOption) (*Msg, error) DeleteNode(ctx context.Context, in *ClusterID, opts ...grpc.CallOption) (*Msg, error) GetClusterMockData(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Cluster, error) CheckClusterConfig(ctx context.Context, in *ClusterID, opts ...grpc.CallOption) (*Cluster, error) SetUpCluster(ctx context.Context, in *ClusterID, opts ...grpc.CallOption) (*Msg, error) UninstallCluster(ctx context.Context, in *ClusterID, opts ...grpc.CallOption) (*Msg, error) AddNode(ctx context.Context, in *ClusterID, opts ...grpc.CallOption) (*Msg, error) RemoveNode(ctx context.Context, in *ClusterID, opts ...grpc.CallOption) (*Msg, 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 ClusterInterfaceHTTPClient ¶
type ClusterInterfaceHTTPClient interface { AddNode(ctx context.Context, req *ClusterID, opts ...http.CallOption) (rsp *Msg, err error) CheckClusterConfig(ctx context.Context, req *ClusterID, opts ...http.CallOption) (rsp *Cluster, err error) Delete(ctx context.Context, req *ClusterID, opts ...http.CallOption) (rsp *Msg, err error) DeleteNode(ctx context.Context, req *ClusterID, opts ...http.CallOption) (rsp *Msg, err error) Get(ctx context.Context, req *ClusterID, opts ...http.CallOption) (rsp *Cluster, err error) GetClusterMockData(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *Cluster, err error) GetCurrentCluster(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *Cluster, err error) List(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *ClusterList, err error) Ping(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *Msg, err error) RemoveNode(ctx context.Context, req *ClusterID, opts ...http.CallOption) (rsp *Msg, err error) Save(ctx context.Context, req *Cluster, opts ...http.CallOption) (rsp *Cluster, err error) SetUpCluster(ctx context.Context, req *ClusterID, opts ...http.CallOption) (rsp *Msg, err error) UninstallCluster(ctx context.Context, req *ClusterID, opts ...http.CallOption) (rsp *Msg, err error) }
func NewClusterInterfaceHTTPClient ¶
func NewClusterInterfaceHTTPClient(client *http.Client) ClusterInterfaceHTTPClient
type ClusterInterfaceHTTPClientImpl ¶
type ClusterInterfaceHTTPClientImpl struct {
// contains filtered or unexported fields
}
func (*ClusterInterfaceHTTPClientImpl) AddNode ¶
func (c *ClusterInterfaceHTTPClientImpl) AddNode(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Msg, error)
func (*ClusterInterfaceHTTPClientImpl) CheckClusterConfig ¶
func (c *ClusterInterfaceHTTPClientImpl) CheckClusterConfig(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Cluster, error)
func (*ClusterInterfaceHTTPClientImpl) Delete ¶
func (c *ClusterInterfaceHTTPClientImpl) Delete(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Msg, error)
func (*ClusterInterfaceHTTPClientImpl) DeleteNode ¶
func (c *ClusterInterfaceHTTPClientImpl) DeleteNode(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Msg, error)
func (*ClusterInterfaceHTTPClientImpl) Get ¶
func (c *ClusterInterfaceHTTPClientImpl) Get(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Cluster, error)
func (*ClusterInterfaceHTTPClientImpl) GetClusterMockData ¶
func (c *ClusterInterfaceHTTPClientImpl) GetClusterMockData(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*Cluster, error)
func (*ClusterInterfaceHTTPClientImpl) GetCurrentCluster ¶
func (c *ClusterInterfaceHTTPClientImpl) GetCurrentCluster(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*Cluster, error)
func (*ClusterInterfaceHTTPClientImpl) List ¶
func (c *ClusterInterfaceHTTPClientImpl) List(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*ClusterList, error)
func (*ClusterInterfaceHTTPClientImpl) Ping ¶
func (c *ClusterInterfaceHTTPClientImpl) Ping(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*Msg, error)
func (*ClusterInterfaceHTTPClientImpl) RemoveNode ¶
func (c *ClusterInterfaceHTTPClientImpl) RemoveNode(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Msg, error)
func (*ClusterInterfaceHTTPClientImpl) Save ¶
func (c *ClusterInterfaceHTTPClientImpl) Save(ctx context.Context, in *Cluster, opts ...http.CallOption) (*Cluster, error)
func (*ClusterInterfaceHTTPClientImpl) SetUpCluster ¶
func (c *ClusterInterfaceHTTPClientImpl) SetUpCluster(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Msg, error)
func (*ClusterInterfaceHTTPClientImpl) UninstallCluster ¶
func (c *ClusterInterfaceHTTPClientImpl) UninstallCluster(ctx context.Context, in *ClusterID, opts ...http.CallOption) (*Msg, error)
type ClusterInterfaceHTTPServer ¶
type ClusterInterfaceHTTPServer interface { AddNode(context.Context, *ClusterID) (*Msg, error) CheckClusterConfig(context.Context, *ClusterID) (*Cluster, error) Delete(context.Context, *ClusterID) (*Msg, error) DeleteNode(context.Context, *ClusterID) (*Msg, error) Get(context.Context, *ClusterID) (*Cluster, error) GetClusterMockData(context.Context, *emptypb.Empty) (*Cluster, error) GetCurrentCluster(context.Context, *emptypb.Empty) (*Cluster, error) List(context.Context, *emptypb.Empty) (*ClusterList, error) Ping(context.Context, *emptypb.Empty) (*Msg, error) RemoveNode(context.Context, *ClusterID) (*Msg, error) Save(context.Context, *Cluster) (*Cluster, error) SetUpCluster(context.Context, *ClusterID) (*Msg, error) UninstallCluster(context.Context, *ClusterID) (*Msg, error) }
type ClusterInterfaceServer ¶
type ClusterInterfaceServer interface { Ping(context.Context, *emptypb.Empty) (*Msg, error) Get(context.Context, *ClusterID) (*Cluster, error) Save(context.Context, *Cluster) (*Cluster, error) List(context.Context, *emptypb.Empty) (*ClusterList, error) GetCurrentCluster(context.Context, *emptypb.Empty) (*Cluster, error) Delete(context.Context, *ClusterID) (*Msg, error) DeleteNode(context.Context, *ClusterID) (*Msg, error) GetClusterMockData(context.Context, *emptypb.Empty) (*Cluster, error) CheckClusterConfig(context.Context, *ClusterID) (*Cluster, error) SetUpCluster(context.Context, *ClusterID) (*Msg, error) UninstallCluster(context.Context, *ClusterID) (*Msg, error) AddNode(context.Context, *ClusterID) (*Msg, error) RemoveNode(context.Context, *ClusterID) (*Msg, error) // contains filtered or unexported methods }
ClusterInterfaceServer is the server API for ClusterInterface service. All implementations must embed UnimplementedClusterInterfaceServer for forward compatibility
type ClusterList ¶
type ClusterList struct { Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"` // contains filtered or unexported fields }
func (*ClusterList) Descriptor
deprecated
func (*ClusterList) Descriptor() ([]byte, []int)
Deprecated: Use ClusterList.ProtoReflect.Descriptor instead.
func (*ClusterList) GetClusters ¶
func (x *ClusterList) GetClusters() []*Cluster
func (*ClusterList) ProtoMessage ¶
func (*ClusterList) ProtoMessage()
func (*ClusterList) ProtoReflect ¶
func (x *ClusterList) ProtoReflect() protoreflect.Message
func (*ClusterList) Reset ¶
func (x *ClusterList) Reset()
func (*ClusterList) String ¶
func (x *ClusterList) String() string
type ErrorReason ¶
type ErrorReason int32
const ( ErrorReason_SUCCEED ErrorReason = 0 ErrorReason_FAILED ErrorReason = 1 )
func (ErrorReason) Descriptor ¶
func (ErrorReason) Descriptor() protoreflect.EnumDescriptor
func (ErrorReason) Enum ¶
func (x ErrorReason) Enum() *ErrorReason
func (ErrorReason) EnumDescriptor
deprecated
func (ErrorReason) EnumDescriptor() ([]byte, []int)
Deprecated: Use ErrorReason.Descriptor instead.
func (ErrorReason) Number ¶
func (x ErrorReason) Number() protoreflect.EnumNumber
func (ErrorReason) String ¶
func (x ErrorReason) String() string
func (ErrorReason) Type ¶
func (ErrorReason) Type() protoreflect.EnumType
type Msg ¶
type Msg struct { Reason ErrorReason `protobuf:"varint,1,opt,name=Reason,proto3,enum=cluster.v1alpha1.ErrorReason" json:"Reason,omitempty"` Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"` // contains filtered or unexported fields }
func (*Msg) Descriptor
deprecated
func (*Msg) GetMessage ¶
func (*Msg) GetReason ¶
func (x *Msg) GetReason() ErrorReason
func (*Msg) ProtoMessage ¶
func (*Msg) ProtoMessage()
func (*Msg) ProtoReflect ¶
func (x *Msg) ProtoReflect() protoreflect.Message
type Node ¶
type Node struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Labels string `protobuf:"bytes,3,opt,name=labels,proto3" json:"labels,omitempty"` Annotations string `protobuf:"bytes,4,opt,name=annotations,proto3" json:"annotations,omitempty"` OsImage string `protobuf:"bytes,5,opt,name=os_image,proto3" json:"os_image,omitempty"` Kernel string `protobuf:"bytes,6,opt,name=kernel,proto3" json:"kernel,omitempty"` Container string `protobuf:"bytes,7,opt,name=container,proto3" json:"container,omitempty"` Kubelet string `protobuf:"bytes,8,opt,name=kubelet,proto3" json:"kubelet,omitempty"` KubeProxy string `protobuf:"bytes,9,opt,name=kube_proxy,proto3" json:"kube_proxy,omitempty"` InternalIp string `protobuf:"bytes,10,opt,name=internal_ip,proto3" json:"internal_ip,omitempty"` ExternalIp string `protobuf:"bytes,11,opt,name=external_ip,proto3" json:"external_ip,omitempty"` User string `protobuf:"bytes,12,opt,name=user,proto3" json:"user,omitempty"` Password string `protobuf:"bytes,13,opt,name=password,proto3" json:"password,omitempty"` SudoPassword string `protobuf:"bytes,14,opt,name=sudo_password,proto3" json:"sudo_password,omitempty"` Role string `protobuf:"bytes,15,opt,name=role,proto3" json:"role,omitempty"` State string `protobuf:"bytes,16,opt,name=state,proto3" json:"state,omitempty"` ClusterId int64 `protobuf:"varint,17,opt,name=cluster_id,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*Node) Descriptor
deprecated
func (*Node) GetAnnotations ¶
func (*Node) GetClusterId ¶
func (*Node) GetContainer ¶
func (*Node) GetExternalIp ¶
func (*Node) GetInternalIp ¶
func (*Node) GetKubeProxy ¶
func (*Node) GetKubelet ¶
func (*Node) GetOsImage ¶
func (*Node) GetPassword ¶
func (*Node) GetSudoPassword ¶
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) ProtoReflect ¶
func (x *Node) ProtoReflect() protoreflect.Message
type UnimplementedClusterInterfaceServer ¶
type UnimplementedClusterInterfaceServer struct { }
UnimplementedClusterInterfaceServer must be embedded to have forward compatible implementations.
func (UnimplementedClusterInterfaceServer) CheckClusterConfig ¶
func (UnimplementedClusterInterfaceServer) DeleteNode ¶
func (UnimplementedClusterInterfaceServer) GetClusterMockData ¶
func (UnimplementedClusterInterfaceServer) GetCurrentCluster ¶
func (UnimplementedClusterInterfaceServer) List ¶
func (UnimplementedClusterInterfaceServer) List(context.Context, *emptypb.Empty) (*ClusterList, error)
func (UnimplementedClusterInterfaceServer) RemoveNode ¶
func (UnimplementedClusterInterfaceServer) SetUpCluster ¶
func (UnimplementedClusterInterfaceServer) UninstallCluster ¶
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.