v1alpha1

package
v0.0.0-...-5b5d069 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 12, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ClusterInterface_Ping_FullMethodName               = "/cluster.v1alpha1.ClusterInterface/Ping"
	ClusterInterface_GetClusterTypes_FullMethodName    = "/cluster.v1alpha1.ClusterInterface/GetClusterTypes"
	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"
)
View Source 
const OperationClusterInterfaceDelete = "/cluster.v1alpha1.ClusterInterface/Delete"
View Source 
const OperationClusterInterfaceGet = "/cluster.v1alpha1.ClusterInterface/Get"
View Source 
const OperationClusterInterfaceGetClusterLevels = "/cluster.v1alpha1.ClusterInterface/GetClusterLevels"
View Source 
const OperationClusterInterfaceGetClusterStatuses = "/cluster.v1alpha1.ClusterInterface/GetClusterStatuses"
View Source 
const OperationClusterInterfaceGetClusterTypes = "/cluster.v1alpha1.ClusterInterface/GetClusterTypes"
View Source 
const OperationClusterInterfaceGetNodeGroupTypes = "/cluster.v1alpha1.ClusterInterface/GetNodeGroupTypes"
View Source 
const OperationClusterInterfaceGetNodeRoles = "/cluster.v1alpha1.ClusterInterface/GetNodeRoles"
View Source 
const OperationClusterInterfaceGetNodeStatuses = "/cluster.v1alpha1.ClusterInterface/GetNodeStatuses"
View Source 
const OperationClusterInterfaceGetRegions = "/cluster.v1alpha1.ClusterInterface/GetRegions"
View Source 
const OperationClusterInterfaceGetResourceTypes = "/cluster.v1alpha1.ClusterInterface/GetResourceTypes"
View Source 
const OperationClusterInterfaceList = "/cluster.v1alpha1.ClusterInterface/List"
View Source 
const OperationClusterInterfacePing = "/cluster.v1alpha1.ClusterInterface/Ping"
View Source 
const OperationClusterInterfacePollingLogs = "/cluster.v1alpha1.ClusterInterface/PollingLogs"
View Source 
const OperationClusterInterfaceSave = "/cluster.v1alpha1.ClusterInterface/Save"
View Source 
const OperationClusterInterfaceStart = "/cluster.v1alpha1.ClusterInterface/Start"
View Source 
const OperationClusterInterfaceStop = "/cluster.v1alpha1.ClusterInterface/Stop"

Variables

View Source 
var ClusterInterface_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cluster.v1alpha1.ClusterInterface",
	HandlerType: (*ClusterInterfaceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _ClusterInterface_Ping_Handler,
		},
		{
			MethodName: "GetClusterTypes",
			Handler:    _ClusterInterface_GetClusterTypes_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)

View Source 
var File_api_cluster_v1alpha1_cluster_proto protoreflect.FileDescriptor
View Source 
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 BostionHost 

type BostionHost struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	User       string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Os         string `protobuf:"bytes,3,opt,name=os,proto3" json:"os,omitempty"`
	Arch       string `protobuf:"bytes,4,opt,name=arch,proto3" json:"arch,omitempty"`
	Cpu        int32  `protobuf:"varint,5,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory     int32  `protobuf:"varint,6,opt,name=memory,proto3" json:"memory,omitempty"`
	Hostname   string `protobuf:"bytes,7,opt,name=hostname,proto3" json:"hostname,omitempty"`
	ExternalIp string `protobuf:"bytes,8,opt,name=external_ip,proto3" json:"external_ip,omitempty"`
	InternalIp string `protobuf:"bytes,9,opt,name=internal_ip,proto3" json:"internal_ip,omitempty"`
	SshPort    int32  `protobuf:"varint,10,opt,name=ssh_port,proto3" json:"ssh_port,omitempty"`
	Status     int32  `protobuf:"varint,11,opt,name=status,proto3" json:"status,omitempty"`
	InstanceId string `protobuf:"bytes,12,opt,name=instance_id,proto3" json:"instance_id,omitempty"`
	UpdateAt   string `protobuf:"bytes,13,opt,name=update_at,proto3" json:"update_at,omitempty"`
	// contains filtered or unexported fields
}

func (*BostionHost) Descriptor deprecated 

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

Deprecated: Use BostionHost.ProtoReflect.Descriptor instead.

func (*BostionHost) GetArch 

func (x *BostionHost) GetArch() string

func (*BostionHost) GetCpu 

func (x *BostionHost) GetCpu() int32

func (*BostionHost) GetExternalIp 

func (x *BostionHost) GetExternalIp() string

func (*BostionHost) GetHostname 

func (x *BostionHost) GetHostname() string

func (*BostionHost) GetId 

func (x *BostionHost) GetId() string

func (*BostionHost) GetInstanceId 

func (x *BostionHost) GetInstanceId() string

func (*BostionHost) GetInternalIp 

func (x *BostionHost) GetInternalIp() string

func (*BostionHost) GetMemory 

func (x *BostionHost) GetMemory() int32

func (*BostionHost) GetOs 

func (x *BostionHost) GetOs() string

func (*BostionHost) GetSshPort 

func (x *BostionHost) GetSshPort() int32

func (*BostionHost) GetStatus 

func (x *BostionHost) GetStatus() int32

func (*BostionHost) GetUpdateAt 

func (x *BostionHost) GetUpdateAt() string

func (*BostionHost) GetUser 

func (x *BostionHost) GetUser() string

func (*BostionHost) ProtoMessage 

func (*BostionHost) ProtoMessage()

func (*BostionHost) ProtoReflect 

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

func (*BostionHost) Reset 

func (x *BostionHost) Reset()

func (*BostionHost) String 

func (x *BostionHost) String() string

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"`
	Version          string       `protobuf:"bytes,3,opt,name=version,proto3" json:"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"`
	Type             int32        `protobuf:"varint,6,opt,name=type,proto3" json:"type,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"`
	AccessId         string       `protobuf:"bytes,10,opt,name=access_id,proto3" json:"access_id,omitempty"`
	AccessKey        string       `protobuf:"bytes,11,opt,name=access_key,proto3" json:"access_key,omitempty"`
	CreateAt         string       `protobuf:"bytes,12,opt,name=create_at,proto3" json:"create_at,omitempty"`
	UpdateAt         string       `protobuf:"bytes,13,opt,name=update_at,proto3" json:"update_at,omitempty"`
	Nodes            []*Node      `protobuf:"bytes,14,rep,name=nodes,proto3" json:"nodes,omitempty"`
	NodeGroups       []*NodeGroup `protobuf:"bytes,15,rep,name=node_groups,proto3" json:"node_groups,omitempty"`
	BostionHost      *BostionHost `protobuf:"bytes,16,opt,name=bostion_host,proto3" json:"bostion_host,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster) Descriptor deprecated 

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetAccessId 

func (x *Cluster) GetAccessId() string

func (*Cluster) GetAccessKey 

func (x *Cluster) GetAccessKey() string

func (*Cluster) GetApiServerAddress 

func (x *Cluster) GetApiServerAddress() string

func (*Cluster) GetBostionHost 

func (x *Cluster) GetBostionHost() *BostionHost

func (*Cluster) GetCreateAt 

func (x *Cluster) GetCreateAt() string

func (*Cluster) GetId 

func (x *Cluster) GetId() int64

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) GetNodeGroups 

func (x *Cluster) GetNodeGroups() []*NodeGroup

func (*Cluster) GetNodes 

func (x *Cluster) GetNodes() []*Node

func (*Cluster) GetPrivateKey 

func (x *Cluster) GetPrivateKey() string

func (*Cluster) GetPublicKey 

func (x *Cluster) GetPublicKey() string

func (*Cluster) GetRegion 

func (x *Cluster) GetRegion() string

func (*Cluster) GetStatus 

func (x *Cluster) GetStatus() int32

func (*Cluster) GetType 

func (x *Cluster) GetType() int32

func (*Cluster) GetUpdateAt 

func (x *Cluster) GetUpdateAt() string

func (*Cluster) GetVersion 

func (x *Cluster) GetVersion() string

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

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

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) String 

func (x *Cluster) String() string

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)
	GetClusterTypes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ClusterTypes, 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 *ClusterIdMessge, 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)
	GetClusterStatuses(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *ClusterStatuses, err error)
	GetClusterTypes(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *ClusterTypes, 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 *ClusterIdMessge, 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) GetClusterStatuses 

func (c *ClusterInterfaceHTTPClientImpl) GetClusterStatuses(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*ClusterStatuses, error)

func (*ClusterInterfaceHTTPClientImpl) GetClusterTypes 

func (c *ClusterInterfaceHTTPClientImpl) GetClusterTypes(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*ClusterTypes, 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 *ClusterIdMessge, 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)
	GetClusterStatuses(context.Context, *emptypb.Empty) (*ClusterStatuses, error)
	GetClusterTypes(context.Context, *emptypb.Empty) (*ClusterTypes, 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, *ClusterIdMessge) (*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)
	GetClusterTypes(context.Context, *emptypb.Empty) (*ClusterTypes, 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, *ClusterIdMessge) (*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 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"`
	Type       int32           `protobuf:"varint,3,opt,name=type,proto3" json:"type,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"`
	Region     string          `protobuf:"bytes,6,opt,name=region,proto3" json:"region,omitempty"`
	AccessId   string          `protobuf:"bytes,7,opt,name=access_id,proto3" json:"access_id,omitempty"`
	AccessKey  string          `protobuf:"bytes,8,opt,name=access_key,proto3" json:"access_key,omitempty"`
	Nodes      []*NodeSaveArgs `protobuf:"bytes,9,rep,name=nodes,proto3" json:"nodes,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) GetNodes 

func (x *ClusterSaveArgs) GetNodes() []*NodeSaveArgs

func (*ClusterSaveArgs) GetPrivateKey 

func (x *ClusterSaveArgs) GetPrivateKey() string

func (*ClusterSaveArgs) GetPublicKey 

func (x *ClusterSaveArgs) GetPublicKey() string

func (*ClusterSaveArgs) GetRegion 

func (x *ClusterSaveArgs) GetRegion() string

func (*ClusterSaveArgs) GetType 

func (x *ClusterSaveArgs) GetType() int32

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 ClusterType 

type ClusterType 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 (*ClusterType) Descriptor deprecated 

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

Deprecated: Use ClusterType.ProtoReflect.Descriptor instead.

func (*ClusterType) GetId 

func (x *ClusterType) GetId() int32

func (*ClusterType) GetIsCloud 

func (x *ClusterType) GetIsCloud() bool

func (*ClusterType) GetName 

func (x *ClusterType) GetName() string

func (*ClusterType) ProtoMessage 

func (*ClusterType) ProtoMessage()

func (*ClusterType) ProtoReflect 

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

func (*ClusterType) Reset 

func (x *ClusterType) Reset()

func (*ClusterType) String 

func (x *ClusterType) String() string

type ClusterTypes 

type ClusterTypes struct {
	ClusterTypes []*ClusterType `protobuf:"bytes,1,rep,name=cluster_types,proto3" json:"cluster_types,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterTypes) Descriptor deprecated 

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

Deprecated: Use ClusterTypes.ProtoReflect.Descriptor instead.

func (*ClusterTypes) GetClusterTypes 

func (x *ClusterTypes) GetClusterTypes() []*ClusterType

func (*ClusterTypes) ProtoMessage 

func (*ClusterTypes) ProtoMessage()

func (*ClusterTypes) ProtoReflect 

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

func (*ClusterTypes) Reset 

func (x *ClusterTypes) Reset()

func (*ClusterTypes) String 

func (x *ClusterTypes) 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) Descriptor() ([]byte, []int)

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetId 

func (x *Node) GetId() int64

func (*Node) GetInstanceId 

func (x *Node) GetInstanceId() string

func (*Node) GetIp 

func (x *Node) GetIp() string

func (*Node) GetName 

func (x *Node) GetName() string

func (*Node) GetRole 

func (x *Node) GetRole() int32

func (*Node) GetStatus 

func (x *Node) GetStatus() int32

func (*Node) GetUpdateAt 

func (x *Node) GetUpdateAt() string

func (*Node) GetUser 

func (x *Node) GetUser() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use NodeGroup.ProtoReflect.Descriptor instead.

func (*NodeGroup) GetArch 

func (x *NodeGroup) GetArch() string

func (*NodeGroup) GetCpu 

func (x *NodeGroup) GetCpu() int32

func (*NodeGroup) GetDataDiskSize 

func (x *NodeGroup) GetDataDiskSize() int32

func (*NodeGroup) GetGpu 

func (x *NodeGroup) GetGpu() int32

func (*NodeGroup) GetGpuSpec 

func (x *NodeGroup) GetGpuSpec() string

func (*NodeGroup) GetId 

func (x *NodeGroup) GetId() string

func (*NodeGroup) GetMaxSize 

func (x *NodeGroup) GetMaxSize() int32

func (*NodeGroup) GetMemory 

func (x *NodeGroup) GetMemory() int32

func (*NodeGroup) GetMinSize 

func (x *NodeGroup) GetMinSize() int32

func (*NodeGroup) GetName 

func (x *NodeGroup) GetName() string

func (*NodeGroup) GetOs 

func (x *NodeGroup) GetOs() string

func (*NodeGroup) GetSystemDiskSize 

func (x *NodeGroup) GetSystemDiskSize() int32

func (*NodeGroup) GetTargetSize 

func (x *NodeGroup) GetTargetSize() int32

func (*NodeGroup) GetType 

func (x *NodeGroup) GetType() int32

func (*NodeGroup) GetUpdateAt 

func (x *NodeGroup) GetUpdateAt() string

func (*NodeGroup) ProtoMessage 

func (*NodeGroup) ProtoMessage()

func (*NodeGroup) ProtoReflect 

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

func (*NodeGroup) Reset 

func (x *NodeGroup) Reset()

func (*NodeGroup) String 

func (x *NodeGroup) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use NodeRole.ProtoReflect.Descriptor instead.

func (*NodeRole) GetId 

func (x *NodeRole) GetId() int32

func (*NodeRole) GetName 

func (x *NodeRole) GetName() string

func (*NodeRole) ProtoMessage 

func (*NodeRole) ProtoMessage()

func (*NodeRole) ProtoReflect 

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

func (*NodeRole) Reset 

func (x *NodeRole) Reset()

func (*NodeRole) String 

func (x *NodeRole) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use NodeRoles.ProtoReflect.Descriptor instead.

func (*NodeRoles) GetNodeRoles 

func (x *NodeRoles) GetNodeRoles() []*NodeRole

func (*NodeRoles) ProtoMessage 

func (*NodeRoles) ProtoMessage()

func (*NodeRoles) ProtoReflect 

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

func (*NodeRoles) Reset 

func (x *NodeRoles) Reset()

func (*NodeRoles) String 

func (x *NodeRoles) String() string

type NodeSaveArgs 

type NodeSaveArgs struct {
	Ip   string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Role int32  `protobuf:"varint,3,opt,name=role,proto3" json:"role,omitempty"`
	Id   int64  `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeSaveArgs) Descriptor deprecated 

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

Deprecated: Use NodeSaveArgs.ProtoReflect.Descriptor instead.

func (*NodeSaveArgs) GetId 

func (x *NodeSaveArgs) GetId() int64

func (*NodeSaveArgs) GetIp 

func (x *NodeSaveArgs) GetIp() string

func (*NodeSaveArgs) GetRole 

func (x *NodeSaveArgs) GetRole() int32

func (*NodeSaveArgs) GetUser 

func (x *NodeSaveArgs) GetUser() string

func (*NodeSaveArgs) ProtoMessage 

func (*NodeSaveArgs) ProtoMessage()

func (*NodeSaveArgs) ProtoReflect 

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

func (*NodeSaveArgs) Reset 

func (x *NodeSaveArgs) Reset()

func (*NodeSaveArgs) String 

func (x *NodeSaveArgs) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Region.ProtoReflect.Descriptor instead.

func (*Region) GetId 

func (x *Region) GetId() string

func (*Region) GetName 

func (x *Region) GetName() string

func (*Region) ProtoMessage 

func (*Region) ProtoMessage()

func (*Region) ProtoReflect 

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

func (*Region) Reset 

func (x *Region) Reset()

func (*Region) String 

func (x *Region) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Regions.ProtoReflect.Descriptor instead.

func (*Regions) GetRegions 

func (x *Regions) GetRegions() []*Region

func (*Regions) ProtoMessage 

func (*Regions) ProtoMessage()

func (*Regions) ProtoReflect 

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

func (*Regions) Reset 

func (x *Regions) Reset()

func (*Regions) String 

func (x *Regions) String() string

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

func (UnimplementedClusterInterfaceServer) GetClusterStatuses(context.Context, *emptypb.Empty) (*ClusterStatuses, error)

func (UnimplementedClusterInterfaceServer) GetClusterTypes 

func (UnimplementedClusterInterfaceServer) GetClusterTypes(context.Context, *emptypb.Empty) (*ClusterTypes, error)

func (UnimplementedClusterInterfaceServer) GetLogs 

func (UnimplementedClusterInterfaceServer) GetLogs(grpc.BidiStreamingServer[ClusterLogsRequest, ClusterLogsResponse]) error

func (UnimplementedClusterInterfaceServer) GetNodeGroupTypes 

func (UnimplementedClusterInterfaceServer) GetNodeGroupTypes(context.Context, *emptypb.Empty) (*NodeGroupTypes, error)

func (UnimplementedClusterInterfaceServer) GetNodeRoles 

func (UnimplementedClusterInterfaceServer) GetNodeRoles(context.Context, *emptypb.Empty) (*NodeRoles, error)

func (UnimplementedClusterInterfaceServer) GetNodeStatuses 

func (UnimplementedClusterInterfaceServer) GetNodeStatuses(context.Context, *emptypb.Empty) (*NodeStatuses, error)

func (UnimplementedClusterInterfaceServer) GetRegions 

func (UnimplementedClusterInterfaceServer) GetRegions(context.Context, *ClusterIdMessge) (*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) Ping 

func (UnimplementedClusterInterfaceServer) Ping(context.Context, *emptypb.Empty) (*common.Msg, 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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.