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) GetAccessId() string
- func (x *Cluster) GetAccessKey() string
- func (x *Cluster) GetApiServerAddress() string
- func (x *Cluster) GetClusterResource() *ClusterResource
- func (x *Cluster) GetCreateAt() string
- func (x *Cluster) GetId() int64
- func (x *Cluster) GetKuberentesVersion() string
- func (x *Cluster) GetName() string
- func (x *Cluster) GetNodeEndIp() string
- func (x *Cluster) GetNodeGroups() []*NodeGroup
- func (x *Cluster) GetNodeStartIp() string
- func (x *Cluster) GetNodeUsername() string
- func (x *Cluster) GetNodes() []*Node
- func (x *Cluster) GetPrivateKey() string
- func (x *Cluster) GetProvider() int32
- func (x *Cluster) GetPublicKey() string
- func (x *Cluster) GetRegion() string
- func (x *Cluster) GetRegionName() string
- func (x *Cluster) GetStatus() int32
- func (x *Cluster) GetUpdateAt() string
- func (*Cluster) ProtoMessage()
- func (x *Cluster) ProtoReflect() protoreflect.Message
- func (x *Cluster) Reset()
- func (x *Cluster) String() string
- type ClusterIdMessge
- type ClusterInterfaceClient
- type ClusterInterfaceHTTPClient
- type ClusterInterfaceHTTPClientImpl
- func (c *ClusterInterfaceHTTPClientImpl) Delete(ctx context.Context, in *ClusterIdMessge, opts ...http.CallOption) (*common.Msg, error)
- func (c *ClusterInterfaceHTTPClientImpl) Get(ctx context.Context, in *ClusterIdMessge, opts ...http.CallOption) (*Cluster, error)
- func (c *ClusterInterfaceHTTPClientImpl) GetClusterLevels(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*ClusterLevels, error)
- func (c *ClusterInterfaceHTTPClientImpl) GetClusterProviders(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*ClusterProviders, error)
- func (c *ClusterInterfaceHTTPClientImpl) GetClusterStatuses(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*ClusterStatuses, error)
- func (c *ClusterInterfaceHTTPClientImpl) GetNodeGroupTypes(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*NodeGroupTypes, error)
- func (c *ClusterInterfaceHTTPClientImpl) GetNodeRoles(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*NodeRoles, error)
- func (c *ClusterInterfaceHTTPClientImpl) GetNodeStatuses(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*NodeStatuses, error)
- func (c *ClusterInterfaceHTTPClientImpl) GetRegions(ctx context.Context, in *ClusterRegionArgs, opts ...http.CallOption) (*Regions, error)
- func (c *ClusterInterfaceHTTPClientImpl) GetResourceTypes(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*ResourceTypes, 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) (*common.Msg, error)
- func (c *ClusterInterfaceHTTPClientImpl) PollingLogs(ctx context.Context, in *ClusterLogsRequest, opts ...http.CallOption) (*ClusterLogsResponse, error)
- func (c *ClusterInterfaceHTTPClientImpl) Save(ctx context.Context, in *ClusterSaveArgs, opts ...http.CallOption) (*ClusterIdMessge, error)
- func (c *ClusterInterfaceHTTPClientImpl) Start(ctx context.Context, in *ClusterIdMessge, opts ...http.CallOption) (*common.Msg, error)
- func (c *ClusterInterfaceHTTPClientImpl) Stop(ctx context.Context, in *ClusterIdMessge, opts ...http.CallOption) (*common.Msg, error)
- type ClusterInterfaceHTTPServer
- type ClusterInterfaceServer
- type ClusterInterface_GetLogsClient
- type ClusterInterface_GetLogsServer
- type ClusterLevel
- func (*ClusterLevel) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterLevel) GetId() int32
- func (x *ClusterLevel) GetName() string
- func (*ClusterLevel) ProtoMessage()
- func (x *ClusterLevel) ProtoReflect() protoreflect.Message
- func (x *ClusterLevel) Reset()
- func (x *ClusterLevel) String() string
- type ClusterLevels
- type ClusterList
- type ClusterLogsRequest
- func (*ClusterLogsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterLogsRequest) GetClusterId() int64
- func (x *ClusterLogsRequest) GetClusterName() string
- func (x *ClusterLogsRequest) GetCurrentLine() int32
- func (x *ClusterLogsRequest) GetTailLines() int32
- func (*ClusterLogsRequest) ProtoMessage()
- func (x *ClusterLogsRequest) ProtoReflect() protoreflect.Message
- func (x *ClusterLogsRequest) Reset()
- func (x *ClusterLogsRequest) String() string
- type ClusterLogsResponse
- func (*ClusterLogsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterLogsResponse) GetLastLine() int32
- func (x *ClusterLogsResponse) GetLogs() string
- func (*ClusterLogsResponse) ProtoMessage()
- func (x *ClusterLogsResponse) ProtoReflect() protoreflect.Message
- func (x *ClusterLogsResponse) Reset()
- func (x *ClusterLogsResponse) String() string
- type ClusterProvider
- func (*ClusterProvider) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterProvider) GetId() int32
- func (x *ClusterProvider) GetIsCloud() bool
- func (x *ClusterProvider) GetName() string
- func (*ClusterProvider) ProtoMessage()
- func (x *ClusterProvider) ProtoReflect() protoreflect.Message
- func (x *ClusterProvider) Reset()
- func (x *ClusterProvider) String() string
- type ClusterProviders
- func (*ClusterProviders) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterProviders) GetClusterProviders() []*ClusterProvider
- func (*ClusterProviders) ProtoMessage()
- func (x *ClusterProviders) ProtoReflect() protoreflect.Message
- func (x *ClusterProviders) Reset()
- func (x *ClusterProviders) String() string
- type ClusterRegionArgs
- func (*ClusterRegionArgs) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterRegionArgs) GetAccessId() string
- func (x *ClusterRegionArgs) GetAccessKey() string
- func (x *ClusterRegionArgs) GetType() int32
- func (*ClusterRegionArgs) ProtoMessage()
- func (x *ClusterRegionArgs) ProtoReflect() protoreflect.Message
- func (x *ClusterRegionArgs) Reset()
- func (x *ClusterRegionArgs) String() string
- type ClusterResource
- func (*ClusterResource) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterResource) GetCpu() int32
- func (x *ClusterResource) GetDisk() int32
- func (x *ClusterResource) GetGpu() int32
- func (x *ClusterResource) GetMemory() int32
- func (*ClusterResource) ProtoMessage()
- func (x *ClusterResource) ProtoReflect() protoreflect.Message
- func (x *ClusterResource) Reset()
- func (x *ClusterResource) String() string
- type ClusterSaveArgs
- func (*ClusterSaveArgs) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterSaveArgs) GetAccessId() string
- func (x *ClusterSaveArgs) GetAccessKey() string
- func (x *ClusterSaveArgs) GetId() int64
- func (x *ClusterSaveArgs) GetName() string
- func (x *ClusterSaveArgs) GetNodeEndIp() string
- func (x *ClusterSaveArgs) GetNodeStartIp() string
- func (x *ClusterSaveArgs) GetNodeUsername() string
- func (x *ClusterSaveArgs) GetPrivateKey() string
- func (x *ClusterSaveArgs) GetProvider() int32
- func (x *ClusterSaveArgs) GetPublicKey() string
- func (x *ClusterSaveArgs) GetRegion() string
- func (*ClusterSaveArgs) ProtoMessage()
- func (x *ClusterSaveArgs) ProtoReflect() protoreflect.Message
- func (x *ClusterSaveArgs) Reset()
- func (x *ClusterSaveArgs) String() string
- type ClusterStatus
- func (*ClusterStatus) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterStatus) GetId() int32
- func (x *ClusterStatus) GetName() string
- func (*ClusterStatus) ProtoMessage()
- func (x *ClusterStatus) ProtoReflect() protoreflect.Message
- func (x *ClusterStatus) Reset()
- func (x *ClusterStatus) String() string
- type ClusterStatuses
- func (*ClusterStatuses) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterStatuses) GetClusterStatuses() []*ClusterStatus
- func (*ClusterStatuses) ProtoMessage()
- func (x *ClusterStatuses) ProtoReflect() protoreflect.Message
- func (x *ClusterStatuses) Reset()
- func (x *ClusterStatuses) String() string
- type Node
- func (*Node) Descriptor() ([]byte, []int)deprecated
- func (x *Node) GetId() int64
- func (x *Node) GetInstanceId() string
- func (x *Node) GetIp() string
- func (x *Node) GetName() string
- func (x *Node) GetRole() int32
- func (x *Node) GetStatus() int32
- func (x *Node) GetUpdateAt() 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 NodeGroup
- func (*NodeGroup) Descriptor() ([]byte, []int)deprecated
- func (x *NodeGroup) GetArch() string
- func (x *NodeGroup) GetCpu() int32
- func (x *NodeGroup) GetDataDiskSize() int32
- func (x *NodeGroup) GetGpu() int32
- func (x *NodeGroup) GetGpuSpec() string
- func (x *NodeGroup) GetId() string
- func (x *NodeGroup) GetMaxSize() int32
- func (x *NodeGroup) GetMemory() int32
- func (x *NodeGroup) GetMinSize() int32
- func (x *NodeGroup) GetName() string
- func (x *NodeGroup) GetOs() string
- func (x *NodeGroup) GetSystemDiskSize() int32
- func (x *NodeGroup) GetTargetSize() int32
- func (x *NodeGroup) GetType() int32
- func (x *NodeGroup) GetUpdateAt() string
- func (*NodeGroup) ProtoMessage()
- func (x *NodeGroup) ProtoReflect() protoreflect.Message
- func (x *NodeGroup) Reset()
- func (x *NodeGroup) String() string
- type NodeGroupType
- func (*NodeGroupType) Descriptor() ([]byte, []int)deprecated
- func (x *NodeGroupType) GetId() int32
- func (x *NodeGroupType) GetName() string
- func (*NodeGroupType) ProtoMessage()
- func (x *NodeGroupType) ProtoReflect() protoreflect.Message
- func (x *NodeGroupType) Reset()
- func (x *NodeGroupType) String() string
- type NodeGroupTypes
- type NodeRole
- type NodeRoles
- type NodeStatus
- type NodeStatuses
- type Region
- type Regions
- type ResourceType
- func (*ResourceType) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceType) GetId() int32
- func (x *ResourceType) GetName() string
- func (*ResourceType) ProtoMessage()
- func (x *ResourceType) ProtoReflect() protoreflect.Message
- func (x *ResourceType) Reset()
- func (x *ResourceType) String() string
- type ResourceTypes
- type UnimplementedClusterInterfaceServer
- func (UnimplementedClusterInterfaceServer) Delete(context.Context, *ClusterIdMessge) (*common.Msg, error)
- func (UnimplementedClusterInterfaceServer) Get(context.Context, *ClusterIdMessge) (*Cluster, error)
- func (UnimplementedClusterInterfaceServer) GetClusterLevels(context.Context, *emptypb.Empty) (*ClusterLevels, error)
- func (UnimplementedClusterInterfaceServer) GetClusterProviders(context.Context, *emptypb.Empty) (*ClusterProviders, error)
- func (UnimplementedClusterInterfaceServer) GetClusterStatuses(context.Context, *emptypb.Empty) (*ClusterStatuses, error)
- func (UnimplementedClusterInterfaceServer) GetLogs(grpc.BidiStreamingServer[ClusterLogsRequest, ClusterLogsResponse]) error
- func (UnimplementedClusterInterfaceServer) GetNodeGroupTypes(context.Context, *emptypb.Empty) (*NodeGroupTypes, error)
- func (UnimplementedClusterInterfaceServer) GetNodeRoles(context.Context, *emptypb.Empty) (*NodeRoles, error)
- func (UnimplementedClusterInterfaceServer) GetNodeStatuses(context.Context, *emptypb.Empty) (*NodeStatuses, error)
- func (UnimplementedClusterInterfaceServer) GetRegions(context.Context, *ClusterRegionArgs) (*Regions, error)
- func (UnimplementedClusterInterfaceServer) GetResourceTypes(context.Context, *emptypb.Empty) (*ResourceTypes, error)
- func (UnimplementedClusterInterfaceServer) List(context.Context, *emptypb.Empty) (*ClusterList, error)
- func (UnimplementedClusterInterfaceServer) Ping(context.Context, *emptypb.Empty) (*common.Msg, error)
- func (UnimplementedClusterInterfaceServer) PollingLogs(context.Context, *ClusterLogsRequest) (*ClusterLogsResponse, error)
- func (UnimplementedClusterInterfaceServer) Save(context.Context, *ClusterSaveArgs) (*ClusterIdMessge, error)
- func (UnimplementedClusterInterfaceServer) Start(context.Context, *ClusterIdMessge) (*common.Msg, error)
- func (UnimplementedClusterInterfaceServer) Stop(context.Context, *ClusterIdMessge) (*common.Msg, error)
- type UnsafeClusterInterfaceServer
Constants ¶
const ( ClusterInterface_Ping_FullMethodName = "/cluster.v1alpha1.ClusterInterface/Ping" ClusterInterface_GetClusterProviders_FullMethodName = "/cluster.v1alpha1.ClusterInterface/GetClusterProviders" ClusterInterface_GetClusterStatuses_FullMethodName = "/cluster.v1alpha1.ClusterInterface/GetClusterStatuses" ClusterInterface_GetClusterLevels_FullMethodName = "/cluster.v1alpha1.ClusterInterface/GetClusterLevels" ClusterInterface_GetNodeRoles_FullMethodName = "/cluster.v1alpha1.ClusterInterface/GetNodeRoles" ClusterInterface_GetNodeStatuses_FullMethodName = "/cluster.v1alpha1.ClusterInterface/GetNodeStatuses" ClusterInterface_GetNodeGroupTypes_FullMethodName = "/cluster.v1alpha1.ClusterInterface/GetNodeGroupTypes" ClusterInterface_GetResourceTypes_FullMethodName = "/cluster.v1alpha1.ClusterInterface/GetResourceTypes" ClusterInterface_Get_FullMethodName = "/cluster.v1alpha1.ClusterInterface/Get" ClusterInterface_Save_FullMethodName = "/cluster.v1alpha1.ClusterInterface/Save" ClusterInterface_List_FullMethodName = "/cluster.v1alpha1.ClusterInterface/List" ClusterInterface_Delete_FullMethodName = "/cluster.v1alpha1.ClusterInterface/Delete" ClusterInterface_Start_FullMethodName = "/cluster.v1alpha1.ClusterInterface/Start" ClusterInterface_Stop_FullMethodName = "/cluster.v1alpha1.ClusterInterface/Stop" ClusterInterface_GetRegions_FullMethodName = "/cluster.v1alpha1.ClusterInterface/GetRegions" ClusterInterface_PollingLogs_FullMethodName = "/cluster.v1alpha1.ClusterInterface/PollingLogs" ClusterInterface_GetLogs_FullMethodName = "/cluster.v1alpha1.ClusterInterface/GetLogs" )
const OperationClusterInterfaceDelete = "/cluster.v1alpha1.ClusterInterface/Delete"
const OperationClusterInterfaceGet = "/cluster.v1alpha1.ClusterInterface/Get"
const OperationClusterInterfaceGetClusterLevels = "/cluster.v1alpha1.ClusterInterface/GetClusterLevels"
const OperationClusterInterfaceGetClusterProviders = "/cluster.v1alpha1.ClusterInterface/GetClusterProviders"
const OperationClusterInterfaceGetClusterStatuses = "/cluster.v1alpha1.ClusterInterface/GetClusterStatuses"
const OperationClusterInterfaceGetNodeGroupTypes = "/cluster.v1alpha1.ClusterInterface/GetNodeGroupTypes"
const OperationClusterInterfaceGetNodeRoles = "/cluster.v1alpha1.ClusterInterface/GetNodeRoles"
const OperationClusterInterfaceGetNodeStatuses = "/cluster.v1alpha1.ClusterInterface/GetNodeStatuses"
const OperationClusterInterfaceGetRegions = "/cluster.v1alpha1.ClusterInterface/GetRegions"
const OperationClusterInterfaceGetResourceTypes = "/cluster.v1alpha1.ClusterInterface/GetResourceTypes"
const OperationClusterInterfaceList = "/cluster.v1alpha1.ClusterInterface/List"
const OperationClusterInterfacePing = "/cluster.v1alpha1.ClusterInterface/Ping"
const OperationClusterInterfacePollingLogs = "/cluster.v1alpha1.ClusterInterface/PollingLogs"
const OperationClusterInterfaceSave = "/cluster.v1alpha1.ClusterInterface/Save"
const OperationClusterInterfaceStart = "/cluster.v1alpha1.ClusterInterface/Start"
const OperationClusterInterfaceStop = "/cluster.v1alpha1.ClusterInterface/Stop"
Variables ¶
var ClusterInterface_ServiceDesc = grpc.ServiceDesc{ ServiceName: "cluster.v1alpha1.ClusterInterface", HandlerType: (*ClusterInterfaceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Ping", Handler: _ClusterInterface_Ping_Handler, }, { MethodName: "GetClusterProviders", Handler: _ClusterInterface_GetClusterProviders_Handler, }, { MethodName: "GetClusterStatuses", Handler: _ClusterInterface_GetClusterStatuses_Handler, }, { MethodName: "GetClusterLevels", Handler: _ClusterInterface_GetClusterLevels_Handler, }, { MethodName: "GetNodeRoles", Handler: _ClusterInterface_GetNodeRoles_Handler, }, { MethodName: "GetNodeStatuses", Handler: _ClusterInterface_GetNodeStatuses_Handler, }, { MethodName: "GetNodeGroupTypes", Handler: _ClusterInterface_GetNodeGroupTypes_Handler, }, { MethodName: "GetResourceTypes", Handler: _ClusterInterface_GetResourceTypes_Handler, }, { MethodName: "Get", Handler: _ClusterInterface_Get_Handler, }, { MethodName: "Save", Handler: _ClusterInterface_Save_Handler, }, { MethodName: "List", Handler: _ClusterInterface_List_Handler, }, { MethodName: "Delete", Handler: _ClusterInterface_Delete_Handler, }, { MethodName: "Start", Handler: _ClusterInterface_Start_Handler, }, { MethodName: "Stop", Handler: _ClusterInterface_Stop_Handler, }, { MethodName: "GetRegions", Handler: _ClusterInterface_GetRegions_Handler, }, { MethodName: "PollingLogs", Handler: _ClusterInterface_PollingLogs_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetLogs", Handler: _ClusterInterface_GetLogs_Handler, ServerStreams: true, ClientStreams: true, }, }, 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_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"`
KuberentesVersion string `protobuf:"bytes,3,opt,name=kuberentes_version,proto3" json:"kuberentes_version,omitempty"`
ApiServerAddress string `protobuf:"bytes,4,opt,name=api_server_address,proto3" json:"api_server_address,omitempty"`
Status int32 `protobuf:"varint,5,opt,name=status,proto3" json:"status,omitempty"`
Provider int32 `protobuf:"varint,6,opt,name=provider,proto3" json:"provider,omitempty"`
PublicKey string `protobuf:"bytes,7,opt,name=public_key,proto3" json:"public_key,omitempty"`
PrivateKey string `protobuf:"bytes,8,opt,name=private_key,proto3" json:"private_key,omitempty"`
Region string `protobuf:"bytes,9,opt,name=region,proto3" json:"region,omitempty"`
RegionName string `protobuf:"bytes,10,opt,name=region_name,proto3" json:"region_name,omitempty"`
AccessId string `protobuf:"bytes,11,opt,name=access_id,proto3" json:"access_id,omitempty"`
AccessKey string `protobuf:"bytes,12,opt,name=access_key,proto3" json:"access_key,omitempty"`
CreateAt string `protobuf:"bytes,13,opt,name=create_at,proto3" json:"create_at,omitempty"`
UpdateAt string `protobuf:"bytes,14,opt,name=update_at,proto3" json:"update_at,omitempty"`
Nodes []*Node `protobuf:"bytes,15,rep,name=nodes,proto3" json:"nodes,omitempty"`
NodeGroups []*NodeGroup `protobuf:"bytes,16,rep,name=node_groups,proto3" json:"node_groups,omitempty"`
NodeUsername string `protobuf:"bytes,17,opt,name=node_username,proto3" json:"node_username,omitempty"`
NodeStartIp string `protobuf:"bytes,18,opt,name=node_start_ip,proto3" json:"node_start_ip,omitempty"`
NodeEndIp string `protobuf:"bytes,19,opt,name=node_end_ip,proto3" json:"node_end_ip,omitempty"`
ClusterResource *ClusterResource `protobuf:"bytes,20,opt,name=cluster_resource,proto3" json:"cluster_resource,omitempty"`
// contains filtered or unexported fields
}
func (*Cluster) Descriptor
deprecated
func (*Cluster) GetAccessId ¶
func (*Cluster) GetAccessKey ¶
func (*Cluster) GetApiServerAddress ¶
func (*Cluster) GetClusterResource ¶
func (x *Cluster) GetClusterResource() *ClusterResource
func (*Cluster) GetCreateAt ¶
func (*Cluster) GetKuberentesVersion ¶
func (*Cluster) GetNodeEndIp ¶
func (*Cluster) GetNodeGroups ¶
func (*Cluster) GetNodeStartIp ¶
func (*Cluster) GetNodeUsername ¶
func (*Cluster) GetPrivateKey ¶
func (*Cluster) GetProvider ¶
func (*Cluster) GetPublicKey ¶
func (*Cluster) GetRegionName ¶
func (*Cluster) GetUpdateAt ¶
func (*Cluster) ProtoMessage ¶
func (*Cluster) ProtoMessage()
func (*Cluster) ProtoReflect ¶
func (x *Cluster) ProtoReflect() protoreflect.Message
type ClusterIdMessge ¶
type ClusterIdMessge struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterIdMessge) Descriptor
deprecated
func (*ClusterIdMessge) Descriptor() ([]byte, []int)
Deprecated: Use ClusterIdMessge.ProtoReflect.Descriptor instead.
func (*ClusterIdMessge) GetId ¶
func (x *ClusterIdMessge) GetId() int64
func (*ClusterIdMessge) ProtoMessage ¶
func (*ClusterIdMessge) ProtoMessage()
func (*ClusterIdMessge) ProtoReflect ¶
func (x *ClusterIdMessge) ProtoReflect() protoreflect.Message
func (*ClusterIdMessge) Reset ¶
func (x *ClusterIdMessge) Reset()
func (*ClusterIdMessge) String ¶
func (x *ClusterIdMessge) String() string
type ClusterInterfaceClient ¶
type ClusterInterfaceClient interface {
Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*common.Msg, error)
GetClusterProviders(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ClusterProviders, error)
GetClusterStatuses(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ClusterStatuses, error)
GetClusterLevels(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ClusterLevels, error)
GetNodeRoles(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NodeRoles, error)
GetNodeStatuses(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NodeStatuses, error)
GetNodeGroupTypes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NodeGroupTypes, error)
GetResourceTypes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ResourceTypes, error)
Get(ctx context.Context, in *ClusterIdMessge, opts ...grpc.CallOption) (*Cluster, error)
Save(ctx context.Context, in *ClusterSaveArgs, opts ...grpc.CallOption) (*ClusterIdMessge, error)
List(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ClusterList, error)
Delete(ctx context.Context, in *ClusterIdMessge, opts ...grpc.CallOption) (*common.Msg, error)
Start(ctx context.Context, in *ClusterIdMessge, opts ...grpc.CallOption) (*common.Msg, error)
Stop(ctx context.Context, in *ClusterIdMessge, opts ...grpc.CallOption) (*common.Msg, error)
GetRegions(ctx context.Context, in *ClusterRegionArgs, opts ...grpc.CallOption) (*Regions, error)
PollingLogs(ctx context.Context, in *ClusterLogsRequest, opts ...grpc.CallOption) (*ClusterLogsResponse, error)
GetLogs(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ClusterLogsRequest, ClusterLogsResponse], 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 {
Delete(ctx context.Context, req *ClusterIdMessge, opts ...http.CallOption) (rsp *common.Msg, err error)
Get(ctx context.Context, req *ClusterIdMessge, opts ...http.CallOption) (rsp *Cluster, err error)
GetClusterLevels(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *ClusterLevels, err error)
GetClusterProviders(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *ClusterProviders, err error)
GetClusterStatuses(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *ClusterStatuses, err error)
GetNodeGroupTypes(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *NodeGroupTypes, err error)
GetNodeRoles(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *NodeRoles, err error)
GetNodeStatuses(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *NodeStatuses, err error)
GetRegions(ctx context.Context, req *ClusterRegionArgs, opts ...http.CallOption) (rsp *Regions, err error)
GetResourceTypes(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *ResourceTypes, 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 *common.Msg, err error)
PollingLogs(ctx context.Context, req *ClusterLogsRequest, opts ...http.CallOption) (rsp *ClusterLogsResponse, err error)
Save(ctx context.Context, req *ClusterSaveArgs, opts ...http.CallOption) (rsp *ClusterIdMessge, err error)
Start(ctx context.Context, req *ClusterIdMessge, opts ...http.CallOption) (rsp *common.Msg, err error)
Stop(ctx context.Context, req *ClusterIdMessge, opts ...http.CallOption) (rsp *common.Msg, err error)
}
func NewClusterInterfaceHTTPClient ¶
func NewClusterInterfaceHTTPClient(client *http.Client) ClusterInterfaceHTTPClient
type ClusterInterfaceHTTPClientImpl ¶
type ClusterInterfaceHTTPClientImpl struct {
// contains filtered or unexported fields
}
func (*ClusterInterfaceHTTPClientImpl) Delete ¶
func (c *ClusterInterfaceHTTPClientImpl) Delete(ctx context.Context, in *ClusterIdMessge, opts ...http.CallOption) (*common.Msg, error)
func (*ClusterInterfaceHTTPClientImpl) Get ¶
func (c *ClusterInterfaceHTTPClientImpl) Get(ctx context.Context, in *ClusterIdMessge, opts ...http.CallOption) (*Cluster, error)
func (*ClusterInterfaceHTTPClientImpl) GetClusterLevels ¶
func (c *ClusterInterfaceHTTPClientImpl) GetClusterLevels(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*ClusterLevels, error)
func (*ClusterInterfaceHTTPClientImpl) GetClusterProviders ¶
func (c *ClusterInterfaceHTTPClientImpl) GetClusterProviders(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*ClusterProviders, error)
func (*ClusterInterfaceHTTPClientImpl) GetClusterStatuses ¶
func (c *ClusterInterfaceHTTPClientImpl) GetClusterStatuses(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*ClusterStatuses, error)
func (*ClusterInterfaceHTTPClientImpl) GetNodeGroupTypes ¶
func (c *ClusterInterfaceHTTPClientImpl) GetNodeGroupTypes(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*NodeGroupTypes, error)
func (*ClusterInterfaceHTTPClientImpl) GetNodeRoles ¶
func (c *ClusterInterfaceHTTPClientImpl) GetNodeRoles(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*NodeRoles, error)
func (*ClusterInterfaceHTTPClientImpl) GetNodeStatuses ¶
func (c *ClusterInterfaceHTTPClientImpl) GetNodeStatuses(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*NodeStatuses, error)
func (*ClusterInterfaceHTTPClientImpl) GetRegions ¶
func (c *ClusterInterfaceHTTPClientImpl) GetRegions(ctx context.Context, in *ClusterRegionArgs, opts ...http.CallOption) (*Regions, error)
func (*ClusterInterfaceHTTPClientImpl) GetResourceTypes ¶
func (c *ClusterInterfaceHTTPClientImpl) GetResourceTypes(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*ResourceTypes, 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) (*common.Msg, error)
func (*ClusterInterfaceHTTPClientImpl) PollingLogs ¶
func (c *ClusterInterfaceHTTPClientImpl) PollingLogs(ctx context.Context, in *ClusterLogsRequest, opts ...http.CallOption) (*ClusterLogsResponse, error)
func (*ClusterInterfaceHTTPClientImpl) Save ¶
func (c *ClusterInterfaceHTTPClientImpl) Save(ctx context.Context, in *ClusterSaveArgs, opts ...http.CallOption) (*ClusterIdMessge, error)
func (*ClusterInterfaceHTTPClientImpl) Start ¶
func (c *ClusterInterfaceHTTPClientImpl) Start(ctx context.Context, in *ClusterIdMessge, opts ...http.CallOption) (*common.Msg, error)
func (*ClusterInterfaceHTTPClientImpl) Stop ¶
func (c *ClusterInterfaceHTTPClientImpl) Stop(ctx context.Context, in *ClusterIdMessge, opts ...http.CallOption) (*common.Msg, error)
type ClusterInterfaceHTTPServer ¶
type ClusterInterfaceHTTPServer interface {
Delete(context.Context, *ClusterIdMessge) (*common.Msg, error)
Get(context.Context, *ClusterIdMessge) (*Cluster, error)
GetClusterLevels(context.Context, *emptypb.Empty) (*ClusterLevels, error)
GetClusterProviders(context.Context, *emptypb.Empty) (*ClusterProviders, error)
GetClusterStatuses(context.Context, *emptypb.Empty) (*ClusterStatuses, error)
GetNodeGroupTypes(context.Context, *emptypb.Empty) (*NodeGroupTypes, error)
GetNodeRoles(context.Context, *emptypb.Empty) (*NodeRoles, error)
GetNodeStatuses(context.Context, *emptypb.Empty) (*NodeStatuses, error)
GetRegions(context.Context, *ClusterRegionArgs) (*Regions, error)
GetResourceTypes(context.Context, *emptypb.Empty) (*ResourceTypes, error)
List(context.Context, *emptypb.Empty) (*ClusterList, error)
Ping(context.Context, *emptypb.Empty) (*common.Msg, error)
PollingLogs(context.Context, *ClusterLogsRequest) (*ClusterLogsResponse, error)
Save(context.Context, *ClusterSaveArgs) (*ClusterIdMessge, error)
Start(context.Context, *ClusterIdMessge) (*common.Msg, error)
Stop(context.Context, *ClusterIdMessge) (*common.Msg, error)
}
type ClusterInterfaceServer ¶
type ClusterInterfaceServer interface {
Ping(context.Context, *emptypb.Empty) (*common.Msg, error)
GetClusterProviders(context.Context, *emptypb.Empty) (*ClusterProviders, error)
GetClusterStatuses(context.Context, *emptypb.Empty) (*ClusterStatuses, error)
GetClusterLevels(context.Context, *emptypb.Empty) (*ClusterLevels, error)
GetNodeRoles(context.Context, *emptypb.Empty) (*NodeRoles, error)
GetNodeStatuses(context.Context, *emptypb.Empty) (*NodeStatuses, error)
GetNodeGroupTypes(context.Context, *emptypb.Empty) (*NodeGroupTypes, error)
GetResourceTypes(context.Context, *emptypb.Empty) (*ResourceTypes, error)
Get(context.Context, *ClusterIdMessge) (*Cluster, error)
Save(context.Context, *ClusterSaveArgs) (*ClusterIdMessge, error)
List(context.Context, *emptypb.Empty) (*ClusterList, error)
Delete(context.Context, *ClusterIdMessge) (*common.Msg, error)
Start(context.Context, *ClusterIdMessge) (*common.Msg, error)
Stop(context.Context, *ClusterIdMessge) (*common.Msg, error)
GetRegions(context.Context, *ClusterRegionArgs) (*Regions, error)
PollingLogs(context.Context, *ClusterLogsRequest) (*ClusterLogsResponse, error)
GetLogs(grpc.BidiStreamingServer[ClusterLogsRequest, ClusterLogsResponse]) error
// contains filtered or unexported methods
}
ClusterInterfaceServer is the server API for ClusterInterface service. All implementations must embed UnimplementedClusterInterfaceServer for forward compatibility.
type ClusterInterface_GetLogsClient ¶
type ClusterInterface_GetLogsClient = grpc.BidiStreamingClient[ClusterLogsRequest, ClusterLogsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ClusterInterface_GetLogsServer ¶
type ClusterInterface_GetLogsServer = grpc.BidiStreamingServer[ClusterLogsRequest, ClusterLogsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ClusterLevel ¶
type ClusterLevel struct {
Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterLevel) Descriptor
deprecated
func (*ClusterLevel) Descriptor() ([]byte, []int)
Deprecated: Use ClusterLevel.ProtoReflect.Descriptor instead.
func (*ClusterLevel) GetId ¶
func (x *ClusterLevel) GetId() int32
func (*ClusterLevel) GetName ¶
func (x *ClusterLevel) GetName() string
func (*ClusterLevel) ProtoMessage ¶
func (*ClusterLevel) ProtoMessage()
func (*ClusterLevel) ProtoReflect ¶
func (x *ClusterLevel) ProtoReflect() protoreflect.Message
func (*ClusterLevel) Reset ¶
func (x *ClusterLevel) Reset()
func (*ClusterLevel) String ¶
func (x *ClusterLevel) String() string
type ClusterLevels ¶
type ClusterLevels struct {
ClusterLevels []*ClusterLevel `protobuf:"bytes,1,rep,name=cluster_levels,proto3" json:"cluster_levels,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterLevels) Descriptor
deprecated
func (*ClusterLevels) Descriptor() ([]byte, []int)
Deprecated: Use ClusterLevels.ProtoReflect.Descriptor instead.
func (*ClusterLevels) GetClusterLevels ¶
func (x *ClusterLevels) GetClusterLevels() []*ClusterLevel
func (*ClusterLevels) ProtoMessage ¶
func (*ClusterLevels) ProtoMessage()
func (*ClusterLevels) ProtoReflect ¶
func (x *ClusterLevels) ProtoReflect() protoreflect.Message
func (*ClusterLevels) Reset ¶
func (x *ClusterLevels) Reset()
func (*ClusterLevels) String ¶
func (x *ClusterLevels) String() string
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 ClusterLogsRequest ¶
type ClusterLogsRequest struct {
ClusterId int64 `protobuf:"varint,1,opt,name=cluster_id,proto3" json:"cluster_id,omitempty"`
TailLines int32 `protobuf:"varint,2,opt,name=tail_lines,proto3" json:"tail_lines,omitempty"`
ClusterName string `protobuf:"bytes,3,opt,name=cluster_name,proto3" json:"cluster_name,omitempty"`
CurrentLine int32 `protobuf:"varint,4,opt,name=current_line,proto3" json:"current_line,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterLogsRequest) Descriptor
deprecated
func (*ClusterLogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClusterLogsRequest.ProtoReflect.Descriptor instead.
func (*ClusterLogsRequest) GetClusterId ¶
func (x *ClusterLogsRequest) GetClusterId() int64
func (*ClusterLogsRequest) GetClusterName ¶
func (x *ClusterLogsRequest) GetClusterName() string
func (*ClusterLogsRequest) GetCurrentLine ¶
func (x *ClusterLogsRequest) GetCurrentLine() int32
func (*ClusterLogsRequest) GetTailLines ¶
func (x *ClusterLogsRequest) GetTailLines() int32
func (*ClusterLogsRequest) ProtoMessage ¶
func (*ClusterLogsRequest) ProtoMessage()
func (*ClusterLogsRequest) ProtoReflect ¶
func (x *ClusterLogsRequest) ProtoReflect() protoreflect.Message
func (*ClusterLogsRequest) Reset ¶
func (x *ClusterLogsRequest) Reset()
func (*ClusterLogsRequest) String ¶
func (x *ClusterLogsRequest) String() string
type ClusterLogsResponse ¶
type ClusterLogsResponse struct {
Logs string `protobuf:"bytes,1,opt,name=logs,proto3" json:"logs,omitempty"`
LastLine int32 `protobuf:"varint,2,opt,name=last_line,proto3" json:"last_line,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterLogsResponse) Descriptor
deprecated
func (*ClusterLogsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ClusterLogsResponse.ProtoReflect.Descriptor instead.
func (*ClusterLogsResponse) GetLastLine ¶
func (x *ClusterLogsResponse) GetLastLine() int32
func (*ClusterLogsResponse) GetLogs ¶
func (x *ClusterLogsResponse) GetLogs() string
func (*ClusterLogsResponse) ProtoMessage ¶
func (*ClusterLogsResponse) ProtoMessage()
func (*ClusterLogsResponse) ProtoReflect ¶
func (x *ClusterLogsResponse) ProtoReflect() protoreflect.Message
func (*ClusterLogsResponse) Reset ¶
func (x *ClusterLogsResponse) Reset()
func (*ClusterLogsResponse) String ¶
func (x *ClusterLogsResponse) String() string
type ClusterProvider ¶
type ClusterProvider struct {
Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
IsCloud bool `protobuf:"varint,3,opt,name=is_cloud,proto3" json:"is_cloud,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterProvider) Descriptor
deprecated
func (*ClusterProvider) Descriptor() ([]byte, []int)
Deprecated: Use ClusterProvider.ProtoReflect.Descriptor instead.
func (*ClusterProvider) GetId ¶
func (x *ClusterProvider) GetId() int32
func (*ClusterProvider) GetIsCloud ¶
func (x *ClusterProvider) GetIsCloud() bool
func (*ClusterProvider) GetName ¶
func (x *ClusterProvider) GetName() string
func (*ClusterProvider) ProtoMessage ¶
func (*ClusterProvider) ProtoMessage()
func (*ClusterProvider) ProtoReflect ¶
func (x *ClusterProvider) ProtoReflect() protoreflect.Message
func (*ClusterProvider) Reset ¶
func (x *ClusterProvider) Reset()
func (*ClusterProvider) String ¶
func (x *ClusterProvider) String() string
type ClusterProviders ¶
type ClusterProviders struct {
ClusterProviders []*ClusterProvider `protobuf:"bytes,1,rep,name=cluster_providers,proto3" json:"cluster_providers,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterProviders) Descriptor
deprecated
func (*ClusterProviders) Descriptor() ([]byte, []int)
Deprecated: Use ClusterProviders.ProtoReflect.Descriptor instead.
func (*ClusterProviders) GetClusterProviders ¶
func (x *ClusterProviders) GetClusterProviders() []*ClusterProvider
func (*ClusterProviders) ProtoMessage ¶
func (*ClusterProviders) ProtoMessage()
func (*ClusterProviders) ProtoReflect ¶
func (x *ClusterProviders) ProtoReflect() protoreflect.Message
func (*ClusterProviders) Reset ¶
func (x *ClusterProviders) Reset()
func (*ClusterProviders) String ¶
func (x *ClusterProviders) String() string
type ClusterRegionArgs ¶
type ClusterRegionArgs struct {
AccessId string `protobuf:"bytes,1,opt,name=access_id,proto3" json:"access_id,omitempty"`
AccessKey string `protobuf:"bytes,2,opt,name=access_key,proto3" json:"access_key,omitempty"`
Type int32 `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterRegionArgs) Descriptor
deprecated
func (*ClusterRegionArgs) Descriptor() ([]byte, []int)
Deprecated: Use ClusterRegionArgs.ProtoReflect.Descriptor instead.
func (*ClusterRegionArgs) GetAccessId ¶
func (x *ClusterRegionArgs) GetAccessId() string
func (*ClusterRegionArgs) GetAccessKey ¶
func (x *ClusterRegionArgs) GetAccessKey() string
func (*ClusterRegionArgs) GetType ¶
func (x *ClusterRegionArgs) GetType() int32
func (*ClusterRegionArgs) ProtoMessage ¶
func (*ClusterRegionArgs) ProtoMessage()
func (*ClusterRegionArgs) ProtoReflect ¶
func (x *ClusterRegionArgs) ProtoReflect() protoreflect.Message
func (*ClusterRegionArgs) Reset ¶
func (x *ClusterRegionArgs) Reset()
func (*ClusterRegionArgs) String ¶
func (x *ClusterRegionArgs) String() string
type ClusterResource ¶
type ClusterResource struct {
Cpu int32 `protobuf:"varint,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
Memory int32 `protobuf:"varint,2,opt,name=memory,proto3" json:"memory,omitempty"`
Gpu int32 `protobuf:"varint,3,opt,name=gpu,proto3" json:"gpu,omitempty"`
Disk int32 `protobuf:"varint,4,opt,name=disk,proto3" json:"disk,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterResource) Descriptor
deprecated
func (*ClusterResource) Descriptor() ([]byte, []int)
Deprecated: Use ClusterResource.ProtoReflect.Descriptor instead.
func (*ClusterResource) GetCpu ¶
func (x *ClusterResource) GetCpu() int32
func (*ClusterResource) GetDisk ¶
func (x *ClusterResource) GetDisk() int32
func (*ClusterResource) GetGpu ¶
func (x *ClusterResource) GetGpu() int32
func (*ClusterResource) GetMemory ¶
func (x *ClusterResource) GetMemory() int32
func (*ClusterResource) ProtoMessage ¶
func (*ClusterResource) ProtoMessage()
func (*ClusterResource) ProtoReflect ¶
func (x *ClusterResource) ProtoReflect() protoreflect.Message
func (*ClusterResource) Reset ¶
func (x *ClusterResource) Reset()
func (*ClusterResource) String ¶
func (x *ClusterResource) String() string
type ClusterSaveArgs ¶
type ClusterSaveArgs 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"`
Provider int32 `protobuf:"varint,3,opt,name=provider,proto3" json:"provider,omitempty"`
PublicKey string `protobuf:"bytes,4,opt,name=public_key,proto3" json:"public_key,omitempty"`
PrivateKey string `protobuf:"bytes,5,opt,name=private_key,proto3" json:"private_key,omitempty"`
AccessId string `protobuf:"bytes,6,opt,name=access_id,proto3" json:"access_id,omitempty"`
AccessKey string `protobuf:"bytes,7,opt,name=access_key,proto3" json:"access_key,omitempty"`
Region string `protobuf:"bytes,8,opt,name=region,proto3" json:"region,omitempty"`
NodeUsername string `protobuf:"bytes,9,opt,name=node_username,proto3" json:"node_username,omitempty"`
NodeStartIp string `protobuf:"bytes,10,opt,name=node_start_ip,proto3" json:"node_start_ip,omitempty"`
NodeEndIp string `protobuf:"bytes,11,opt,name=node_end_ip,proto3" json:"node_end_ip,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterSaveArgs) Descriptor
deprecated
func (*ClusterSaveArgs) Descriptor() ([]byte, []int)
Deprecated: Use ClusterSaveArgs.ProtoReflect.Descriptor instead.
func (*ClusterSaveArgs) GetAccessId ¶
func (x *ClusterSaveArgs) GetAccessId() string
func (*ClusterSaveArgs) GetAccessKey ¶
func (x *ClusterSaveArgs) GetAccessKey() string
func (*ClusterSaveArgs) GetId ¶
func (x *ClusterSaveArgs) GetId() int64
func (*ClusterSaveArgs) GetName ¶
func (x *ClusterSaveArgs) GetName() string
func (*ClusterSaveArgs) GetNodeEndIp ¶
func (x *ClusterSaveArgs) GetNodeEndIp() string
func (*ClusterSaveArgs) GetNodeStartIp ¶
func (x *ClusterSaveArgs) GetNodeStartIp() string
func (*ClusterSaveArgs) GetNodeUsername ¶
func (x *ClusterSaveArgs) GetNodeUsername() string
func (*ClusterSaveArgs) GetPrivateKey ¶
func (x *ClusterSaveArgs) GetPrivateKey() string
func (*ClusterSaveArgs) GetProvider ¶
func (x *ClusterSaveArgs) GetProvider() int32
func (*ClusterSaveArgs) GetPublicKey ¶
func (x *ClusterSaveArgs) GetPublicKey() string
func (*ClusterSaveArgs) GetRegion ¶
func (x *ClusterSaveArgs) GetRegion() string
func (*ClusterSaveArgs) ProtoMessage ¶
func (*ClusterSaveArgs) ProtoMessage()
func (*ClusterSaveArgs) ProtoReflect ¶
func (x *ClusterSaveArgs) ProtoReflect() protoreflect.Message
func (*ClusterSaveArgs) Reset ¶
func (x *ClusterSaveArgs) Reset()
func (*ClusterSaveArgs) String ¶
func (x *ClusterSaveArgs) String() string
type ClusterStatus ¶
type ClusterStatus struct {
Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterStatus) Descriptor
deprecated
func (*ClusterStatus) Descriptor() ([]byte, []int)
Deprecated: Use ClusterStatus.ProtoReflect.Descriptor instead.
func (*ClusterStatus) GetId ¶
func (x *ClusterStatus) GetId() int32
func (*ClusterStatus) GetName ¶
func (x *ClusterStatus) GetName() string
func (*ClusterStatus) ProtoMessage ¶
func (*ClusterStatus) ProtoMessage()
func (*ClusterStatus) ProtoReflect ¶
func (x *ClusterStatus) ProtoReflect() protoreflect.Message
func (*ClusterStatus) Reset ¶
func (x *ClusterStatus) Reset()
func (*ClusterStatus) String ¶
func (x *ClusterStatus) String() string
type ClusterStatuses ¶
type ClusterStatuses struct {
ClusterStatuses []*ClusterStatus `protobuf:"bytes,1,rep,name=cluster_statuses,proto3" json:"cluster_statuses,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterStatuses) Descriptor
deprecated
func (*ClusterStatuses) Descriptor() ([]byte, []int)
Deprecated: Use ClusterStatuses.ProtoReflect.Descriptor instead.
func (*ClusterStatuses) GetClusterStatuses ¶
func (x *ClusterStatuses) GetClusterStatuses() []*ClusterStatus
func (*ClusterStatuses) ProtoMessage ¶
func (*ClusterStatuses) ProtoMessage()
func (*ClusterStatuses) ProtoReflect ¶
func (x *ClusterStatuses) ProtoReflect() protoreflect.Message
func (*ClusterStatuses) Reset ¶
func (x *ClusterStatuses) Reset()
func (*ClusterStatuses) String ¶
func (x *ClusterStatuses) String() string
type Node ¶
type Node struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Ip string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
User string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
Role int32 `protobuf:"varint,5,opt,name=role,proto3" json:"role,omitempty"`
Status int32 `protobuf:"varint,6,opt,name=status,proto3" json:"status,omitempty"`
InstanceId string `protobuf:"bytes,7,opt,name=instance_id,proto3" json:"instance_id,omitempty"`
UpdateAt string `protobuf:"bytes,8,opt,name=update_at,proto3" json:"update_at,omitempty"`
// contains filtered or unexported fields
}
func (*Node) Descriptor
deprecated
func (*Node) GetInstanceId ¶
func (*Node) GetUpdateAt ¶
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) ProtoReflect ¶
func (x *Node) ProtoReflect() protoreflect.Message
type NodeGroup ¶
type NodeGroup struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Type int32 `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"`
Os string `protobuf:"bytes,4,opt,name=os,proto3" json:"os,omitempty"`
Arch string `protobuf:"bytes,5,opt,name=arch,proto3" json:"arch,omitempty"`
Cpu int32 `protobuf:"varint,6,opt,name=cpu,proto3" json:"cpu,omitempty"`
Memory int32 `protobuf:"varint,7,opt,name=memory,proto3" json:"memory,omitempty"`
Gpu int32 `protobuf:"varint,8,opt,name=gpu,proto3" json:"gpu,omitempty"`
GpuSpec string `protobuf:"bytes,9,opt,name=gpu_spec,proto3" json:"gpu_spec,omitempty"`
SystemDiskSize int32 `protobuf:"varint,10,opt,name=system_disk_size,proto3" json:"system_disk_size,omitempty"`
DataDiskSize int32 `protobuf:"varint,11,opt,name=data_disk_size,proto3" json:"data_disk_size,omitempty"`
MinSize int32 `protobuf:"varint,12,opt,name=min_size,proto3" json:"min_size,omitempty"`
MaxSize int32 `protobuf:"varint,13,opt,name=max_size,proto3" json:"max_size,omitempty"`
TargetSize int32 `protobuf:"varint,14,opt,name=target_size,proto3" json:"target_size,omitempty"`
UpdateAt string `protobuf:"bytes,15,opt,name=update_at,proto3" json:"update_at,omitempty"`
// contains filtered or unexported fields
}
func (*NodeGroup) Descriptor
deprecated
func (*NodeGroup) GetDataDiskSize ¶
func (*NodeGroup) GetGpuSpec ¶
func (*NodeGroup) GetMaxSize ¶
func (*NodeGroup) GetMinSize ¶
func (*NodeGroup) GetSystemDiskSize ¶
func (*NodeGroup) GetTargetSize ¶
func (*NodeGroup) GetUpdateAt ¶
func (*NodeGroup) ProtoMessage ¶
func (*NodeGroup) ProtoMessage()
func (*NodeGroup) ProtoReflect ¶
func (x *NodeGroup) ProtoReflect() protoreflect.Message
type NodeGroupType ¶
type NodeGroupType struct {
Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*NodeGroupType) Descriptor
deprecated
func (*NodeGroupType) Descriptor() ([]byte, []int)
Deprecated: Use NodeGroupType.ProtoReflect.Descriptor instead.
func (*NodeGroupType) GetId ¶
func (x *NodeGroupType) GetId() int32
func (*NodeGroupType) GetName ¶
func (x *NodeGroupType) GetName() string
func (*NodeGroupType) ProtoMessage ¶
func (*NodeGroupType) ProtoMessage()
func (*NodeGroupType) ProtoReflect ¶
func (x *NodeGroupType) ProtoReflect() protoreflect.Message
func (*NodeGroupType) Reset ¶
func (x *NodeGroupType) Reset()
func (*NodeGroupType) String ¶
func (x *NodeGroupType) String() string
type NodeGroupTypes ¶
type NodeGroupTypes struct {
NodeGroupTypes []*NodeGroupType `protobuf:"bytes,1,rep,name=node_group_types,proto3" json:"node_group_types,omitempty"`
// contains filtered or unexported fields
}
func (*NodeGroupTypes) Descriptor
deprecated
func (*NodeGroupTypes) Descriptor() ([]byte, []int)
Deprecated: Use NodeGroupTypes.ProtoReflect.Descriptor instead.
func (*NodeGroupTypes) GetNodeGroupTypes ¶
func (x *NodeGroupTypes) GetNodeGroupTypes() []*NodeGroupType
func (*NodeGroupTypes) ProtoMessage ¶
func (*NodeGroupTypes) ProtoMessage()
func (*NodeGroupTypes) ProtoReflect ¶
func (x *NodeGroupTypes) ProtoReflect() protoreflect.Message
func (*NodeGroupTypes) Reset ¶
func (x *NodeGroupTypes) Reset()
func (*NodeGroupTypes) String ¶
func (x *NodeGroupTypes) String() string
type NodeRole ¶
type NodeRole struct {
Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*NodeRole) Descriptor
deprecated
func (*NodeRole) ProtoMessage ¶
func (*NodeRole) ProtoMessage()
func (*NodeRole) ProtoReflect ¶
func (x *NodeRole) ProtoReflect() protoreflect.Message
type NodeRoles ¶
type NodeRoles struct {
NodeRoles []*NodeRole `protobuf:"bytes,1,rep,name=node_roles,proto3" json:"node_roles,omitempty"`
// contains filtered or unexported fields
}
func (*NodeRoles) Descriptor
deprecated
func (*NodeRoles) GetNodeRoles ¶
func (*NodeRoles) ProtoMessage ¶
func (*NodeRoles) ProtoMessage()
func (*NodeRoles) ProtoReflect ¶
func (x *NodeRoles) ProtoReflect() protoreflect.Message
type NodeStatus ¶
type NodeStatus struct {
Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*NodeStatus) Descriptor
deprecated
func (*NodeStatus) Descriptor() ([]byte, []int)
Deprecated: Use NodeStatus.ProtoReflect.Descriptor instead.
func (*NodeStatus) GetId ¶
func (x *NodeStatus) GetId() int32
func (*NodeStatus) GetName ¶
func (x *NodeStatus) GetName() string
func (*NodeStatus) ProtoMessage ¶
func (*NodeStatus) ProtoMessage()
func (*NodeStatus) ProtoReflect ¶
func (x *NodeStatus) ProtoReflect() protoreflect.Message
func (*NodeStatus) Reset ¶
func (x *NodeStatus) Reset()
func (*NodeStatus) String ¶
func (x *NodeStatus) String() string
type NodeStatuses ¶
type NodeStatuses struct {
NodeStatuses []*NodeStatus `protobuf:"bytes,1,rep,name=node_statuses,proto3" json:"node_statuses,omitempty"`
// contains filtered or unexported fields
}
func (*NodeStatuses) Descriptor
deprecated
func (*NodeStatuses) Descriptor() ([]byte, []int)
Deprecated: Use NodeStatuses.ProtoReflect.Descriptor instead.
func (*NodeStatuses) GetNodeStatuses ¶
func (x *NodeStatuses) GetNodeStatuses() []*NodeStatus
func (*NodeStatuses) ProtoMessage ¶
func (*NodeStatuses) ProtoMessage()
func (*NodeStatuses) ProtoReflect ¶
func (x *NodeStatuses) ProtoReflect() protoreflect.Message
func (*NodeStatuses) Reset ¶
func (x *NodeStatuses) Reset()
func (*NodeStatuses) String ¶
func (x *NodeStatuses) String() string
type Region ¶
type Region struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*Region) Descriptor
deprecated
func (*Region) ProtoMessage ¶
func (*Region) ProtoMessage()
func (*Region) ProtoReflect ¶
func (x *Region) ProtoReflect() protoreflect.Message
type Regions ¶
type Regions struct {
Regions []*Region `protobuf:"bytes,1,rep,name=regions,proto3" json:"regions,omitempty"`
// contains filtered or unexported fields
}
func (*Regions) Descriptor
deprecated
func (*Regions) GetRegions ¶
func (*Regions) ProtoMessage ¶
func (*Regions) ProtoMessage()
func (*Regions) ProtoReflect ¶
func (x *Regions) ProtoReflect() protoreflect.Message
type ResourceType ¶
type ResourceType struct {
Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*ResourceType) Descriptor
deprecated
func (*ResourceType) Descriptor() ([]byte, []int)
Deprecated: Use ResourceType.ProtoReflect.Descriptor instead.
func (*ResourceType) GetId ¶
func (x *ResourceType) GetId() int32
func (*ResourceType) GetName ¶
func (x *ResourceType) GetName() string
func (*ResourceType) ProtoMessage ¶
func (*ResourceType) ProtoMessage()
func (*ResourceType) ProtoReflect ¶
func (x *ResourceType) ProtoReflect() protoreflect.Message
func (*ResourceType) Reset ¶
func (x *ResourceType) Reset()
func (*ResourceType) String ¶
func (x *ResourceType) String() string
type ResourceTypes ¶
type ResourceTypes struct {
ResourceTypes []*ResourceType `protobuf:"bytes,1,rep,name=resource_types,proto3" json:"resource_types,omitempty"`
// contains filtered or unexported fields
}
func (*ResourceTypes) Descriptor
deprecated
func (*ResourceTypes) Descriptor() ([]byte, []int)
Deprecated: Use ResourceTypes.ProtoReflect.Descriptor instead.
func (*ResourceTypes) GetResourceTypes ¶
func (x *ResourceTypes) GetResourceTypes() []*ResourceType
func (*ResourceTypes) ProtoMessage ¶
func (*ResourceTypes) ProtoMessage()
func (*ResourceTypes) ProtoReflect ¶
func (x *ResourceTypes) ProtoReflect() protoreflect.Message
func (*ResourceTypes) Reset ¶
func (x *ResourceTypes) Reset()
func (*ResourceTypes) String ¶
func (x *ResourceTypes) String() string
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) Delete ¶
func (UnimplementedClusterInterfaceServer) Delete(context.Context, *ClusterIdMessge) (*common.Msg, error)
func (UnimplementedClusterInterfaceServer) Get ¶
func (UnimplementedClusterInterfaceServer) Get(context.Context, *ClusterIdMessge) (*Cluster, error)
func (UnimplementedClusterInterfaceServer) GetClusterLevels ¶
func (UnimplementedClusterInterfaceServer) GetClusterLevels(context.Context, *emptypb.Empty) (*ClusterLevels, error)
func (UnimplementedClusterInterfaceServer) GetClusterProviders ¶
func (UnimplementedClusterInterfaceServer) GetClusterProviders(context.Context, *emptypb.Empty) (*ClusterProviders, error)
func (UnimplementedClusterInterfaceServer) GetClusterStatuses ¶
func (UnimplementedClusterInterfaceServer) GetClusterStatuses(context.Context, *emptypb.Empty) (*ClusterStatuses, error)
func (UnimplementedClusterInterfaceServer) GetNodeGroupTypes ¶
func (UnimplementedClusterInterfaceServer) GetNodeGroupTypes(context.Context, *emptypb.Empty) (*NodeGroupTypes, error)
func (UnimplementedClusterInterfaceServer) GetNodeRoles ¶
func (UnimplementedClusterInterfaceServer) GetNodeStatuses ¶
func (UnimplementedClusterInterfaceServer) GetNodeStatuses(context.Context, *emptypb.Empty) (*NodeStatuses, error)
func (UnimplementedClusterInterfaceServer) GetRegions ¶
func (UnimplementedClusterInterfaceServer) GetRegions(context.Context, *ClusterRegionArgs) (*Regions, error)
func (UnimplementedClusterInterfaceServer) GetResourceTypes ¶
func (UnimplementedClusterInterfaceServer) GetResourceTypes(context.Context, *emptypb.Empty) (*ResourceTypes, error)
func (UnimplementedClusterInterfaceServer) List ¶
func (UnimplementedClusterInterfaceServer) List(context.Context, *emptypb.Empty) (*ClusterList, error)
func (UnimplementedClusterInterfaceServer) PollingLogs ¶
func (UnimplementedClusterInterfaceServer) PollingLogs(context.Context, *ClusterLogsRequest) (*ClusterLogsResponse, error)
func (UnimplementedClusterInterfaceServer) Save ¶
func (UnimplementedClusterInterfaceServer) Save(context.Context, *ClusterSaveArgs) (*ClusterIdMessge, error)
func (UnimplementedClusterInterfaceServer) Start ¶
func (UnimplementedClusterInterfaceServer) Start(context.Context, *ClusterIdMessge) (*common.Msg, error)
func (UnimplementedClusterInterfaceServer) Stop ¶
func (UnimplementedClusterInterfaceServer) Stop(context.Context, *ClusterIdMessge) (*common.Msg, 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.