Documentation ¶
Index ¶
- func CheckClusterNodePermission(ctx context.Context, resourceId string) (*models.ClusterNode, error)
- func CheckClusterNodesPermission(ctx context.Context, resourceIds []string) ([]*models.ClusterNode, error)
- func CheckClusterPermission(ctx context.Context, resourceId string) (*models.Cluster, error)
- func CheckClustersPermission(ctx context.Context, resourceIds []string) ([]*models.Cluster, error)
- func CheckKeyPairPermission(ctx context.Context, resourceId string) (*models.KeyPair, error)
- func CheckKeyPairsPermission(ctx context.Context, resourceIds []string) ([]*models.KeyPair, error)
- func CheckVmBasedProvider(ctx context.Context, runtime *models.RuntimeDetails, ...) error
- func RegisterClusterNode(ctx context.Context, clusterNode *models.ClusterNode) error
- func RegisterClusterRole(ctx context.Context, clusterRole *models.ClusterRole) error
- func RegisterClusterWrapper(ctx context.Context, clusterWrapper *models.ClusterWrapper) error
- func Serve(cfg *config.Config)
- type Frontgate
- func (f *Frontgate) ActivateFrontgate(ctx context.Context, frontgateId string) error
- func (f *Frontgate) CreateCluster(ctx context.Context, clusterWrapper *models.ClusterWrapper) (string, error)
- func (f *Frontgate) GetActiveFrontgate(ctx context.Context, clusterWrapper *models.ClusterWrapper) (*models.Cluster, error)
- func (f *Frontgate) GetFrontgate(ctx context.Context, frontgateId string) (*models.Cluster, error)
- func (f *Frontgate) RecoverCluster(ctx context.Context, frontgate *models.Cluster) error
- func (f *Frontgate) StartCluster(ctx context.Context, frontgate *models.Cluster) error
- type Server
- func (p *Server) AddClusterNodes(ctx context.Context, req *pb.AddClusterNodesRequest) (*pb.AddClusterNodesResponse, error)
- func (p *Server) AddNodeKeyPairs(ctx context.Context, req *pb.AddNodeKeyPairsRequest) (*pb.AddNodeKeyPairsResponse, error)
- func (p *Server) AddTableClusterNodes(ctx context.Context, req *pb.AddTableClusterNodesRequest) (*pbempty.Empty, error)
- func (p *Server) AttachKeyPairs(ctx context.Context, req *pb.AttachKeyPairsRequest) (*pb.AttachKeyPairsResponse, error)
- func (p *Server) CeaseClusters(ctx context.Context, req *pb.CeaseClustersRequest) (*pb.CeaseClustersResponse, error)
- func (p *Server) Checker(ctx context.Context, req interface{}) error
- func (p *Server) CreateCluster(ctx context.Context, req *pb.CreateClusterRequest) (*pb.CreateClusterResponse, error)
- func (p *Server) CreateDebugCluster(ctx context.Context, req *pb.CreateClusterRequest) (*pb.CreateClusterResponse, error)
- func (p *Server) CreateKeyPair(ctx context.Context, req *pb.CreateKeyPairRequest) (*pb.CreateKeyPairResponse, error)
- func (p *Server) DeleteClusterInRuntime(ctx context.Context, req *pb.DeleteClusterInRuntimeRequest) (*pb.DeleteClusterInRuntimeResponse, error)
- func (p *Server) DeleteClusterNodes(ctx context.Context, req *pb.DeleteClusterNodesRequest) (*pb.DeleteClusterNodesResponse, error)
- func (p *Server) DeleteClusters(ctx context.Context, req *pb.DeleteClustersRequest) (*pb.DeleteClustersResponse, error)
- func (p *Server) DeleteKeyPairs(ctx context.Context, req *pb.DeleteKeyPairsRequest) (*pb.DeleteKeyPairsResponse, error)
- func (p *Server) DeleteNodeKeyPairs(ctx context.Context, req *pb.DeleteNodeKeyPairsRequest) (*pb.DeleteNodeKeyPairsResponse, error)
- func (p *Server) DeleteTableClusterNodes(ctx context.Context, req *pb.DeleteTableClusterNodesRequest) (*pbempty.Empty, error)
- func (p *Server) DescribeAppClusters(ctx context.Context, req *pb.DescribeAppClustersRequest) (*pb.DescribeAppClustersResponse, error)
- func (p *Server) DescribeClusterNodes(ctx context.Context, req *pb.DescribeClusterNodesRequest) (*pb.DescribeClusterNodesResponse, error)
- func (p *Server) DescribeClusters(ctx context.Context, req *pb.DescribeClustersRequest) (*pb.DescribeClustersResponse, error)
- func (p *Server) DescribeDebugAppClusters(ctx context.Context, req *pb.DescribeAppClustersRequest) (*pb.DescribeAppClustersResponse, error)
- func (p *Server) DescribeDebugClusters(ctx context.Context, req *pb.DescribeClustersRequest) (*pb.DescribeClustersResponse, error)
- func (p *Server) DescribeKeyPairs(ctx context.Context, req *pb.DescribeKeyPairsRequest) (*pb.DescribeKeyPairsResponse, error)
- func (p *Server) DescribeSubnets(ctx context.Context, req *pb.DescribeSubnetsRequest) (*pb.DescribeSubnetsResponse, error)
- func (p *Server) DetachKeyPairs(ctx context.Context, req *pb.DetachKeyPairsRequest) (*pb.DetachKeyPairsResponse, error)
- func (p *Server) GetClusterStatistics(ctx context.Context, req *pb.GetClusterStatisticsRequest) (*pb.GetClusterStatisticsResponse, error)
- func (p *Server) MigrateClusterInRuntime(ctx context.Context, req *pb.MigrateClusterInRuntimeRequest) (*pb.MigrateClusterInRuntimeResponse, error)
- func (p *Server) ModifyCluster(ctx context.Context, req *pb.ModifyClusterRequest) (*pb.ModifyClusterResponse, error)
- func (p *Server) ModifyClusterAttributes(ctx context.Context, req *pb.ModifyClusterAttributesRequest) (*pb.ModifyClusterAttributesResponse, error)
- func (p *Server) ModifyClusterNode(ctx context.Context, req *pb.ModifyClusterNodeRequest) (*pb.ModifyClusterNodeResponse, error)
- func (p *Server) ModifyClusterNodeAttributes(ctx context.Context, req *pb.ModifyClusterNodeAttributesRequest) (*pb.ModifyClusterNodeAttributesResponse, error)
- func (p *Server) RecoverClusters(ctx context.Context, req *pb.RecoverClustersRequest) (*pb.RecoverClustersResponse, error)
- func (p *Server) ResizeCluster(ctx context.Context, req *pb.ResizeClusterRequest) (*pb.ResizeClusterResponse, error)
- func (p *Server) RollbackCluster(ctx context.Context, req *pb.RollbackClusterRequest) (*pb.RollbackClusterResponse, error)
- func (p *Server) StartClusters(ctx context.Context, req *pb.StartClustersRequest) (*pb.StartClustersResponse, error)
- func (p *Server) StopClusters(ctx context.Context, req *pb.StopClustersRequest) (*pb.StopClustersResponse, error)
- func (p *Server) UpdateClusterEnv(ctx context.Context, req *pb.UpdateClusterEnvRequest) (*pb.UpdateClusterEnvResponse, error)
- func (p *Server) UpgradeCluster(ctx context.Context, req *pb.UpgradeClusterRequest) (*pb.UpgradeClusterResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckClusterNodePermission ¶ added in v0.2.3
func CheckClusterNodesPermission ¶ added in v0.2.3
func CheckClusterPermission ¶ added in v0.2.3
func CheckClustersPermission ¶ added in v0.2.3
func CheckKeyPairPermission ¶ added in v0.2.3
func CheckKeyPairsPermission ¶ added in v0.2.3
func CheckVmBasedProvider ¶ added in v0.1.2
func CheckVmBasedProvider(ctx context.Context, runtime *models.RuntimeDetails, providerClient pb.RuntimeProviderManagerClient, clusterWrapper *models.ClusterWrapper) error
func RegisterClusterNode ¶ added in v0.1.2
func RegisterClusterNode(ctx context.Context, clusterNode *models.ClusterNode) error
func RegisterClusterRole ¶ added in v0.2.1
func RegisterClusterRole(ctx context.Context, clusterRole *models.ClusterRole) error
func RegisterClusterWrapper ¶ added in v0.1.2
func RegisterClusterWrapper(ctx context.Context, clusterWrapper *models.ClusterWrapper) error
Types ¶
type Frontgate ¶
type Frontgate struct {
Runtime *models.RuntimeDetails
}
func (*Frontgate) ActivateFrontgate ¶
func (*Frontgate) CreateCluster ¶
func (*Frontgate) GetActiveFrontgate ¶
func (*Frontgate) GetFrontgate ¶
func (*Frontgate) RecoverCluster ¶
type Server ¶
type Server struct { }
func (*Server) AddClusterNodes ¶
func (p *Server) AddClusterNodes(ctx context.Context, req *pb.AddClusterNodesRequest) (*pb.AddClusterNodesResponse, error)
func (*Server) AddNodeKeyPairs ¶ added in v0.1.7
func (p *Server) AddNodeKeyPairs(ctx context.Context, req *pb.AddNodeKeyPairsRequest) (*pb.AddNodeKeyPairsResponse, error)
func (*Server) AddTableClusterNodes ¶
func (*Server) AttachKeyPairs ¶ added in v0.1.7
func (p *Server) AttachKeyPairs(ctx context.Context, req *pb.AttachKeyPairsRequest) (*pb.AttachKeyPairsResponse, error)
func (*Server) CeaseClusters ¶
func (p *Server) CeaseClusters(ctx context.Context, req *pb.CeaseClustersRequest) (*pb.CeaseClustersResponse, error)
func (*Server) CreateCluster ¶
func (p *Server) CreateCluster(ctx context.Context, req *pb.CreateClusterRequest) (*pb.CreateClusterResponse, error)
func (*Server) CreateDebugCluster ¶ added in v0.4.0
func (p *Server) CreateDebugCluster(ctx context.Context, req *pb.CreateClusterRequest) (*pb.CreateClusterResponse, error)
func (*Server) CreateKeyPair ¶ added in v0.1.7
func (p *Server) CreateKeyPair(ctx context.Context, req *pb.CreateKeyPairRequest) (*pb.CreateKeyPairResponse, error)
func (*Server) DeleteClusterInRuntime ¶ added in v0.5.0
func (p *Server) DeleteClusterInRuntime(ctx context.Context, req *pb.DeleteClusterInRuntimeRequest) (*pb.DeleteClusterInRuntimeResponse, error)
func (*Server) DeleteClusterNodes ¶
func (p *Server) DeleteClusterNodes(ctx context.Context, req *pb.DeleteClusterNodesRequest) (*pb.DeleteClusterNodesResponse, error)
func (*Server) DeleteClusters ¶
func (p *Server) DeleteClusters(ctx context.Context, req *pb.DeleteClustersRequest) (*pb.DeleteClustersResponse, error)
func (*Server) DeleteKeyPairs ¶ added in v0.1.7
func (p *Server) DeleteKeyPairs(ctx context.Context, req *pb.DeleteKeyPairsRequest) (*pb.DeleteKeyPairsResponse, error)
func (*Server) DeleteNodeKeyPairs ¶ added in v0.1.7
func (p *Server) DeleteNodeKeyPairs(ctx context.Context, req *pb.DeleteNodeKeyPairsRequest) (*pb.DeleteNodeKeyPairsResponse, error)
func (*Server) DeleteTableClusterNodes ¶
func (*Server) DescribeAppClusters ¶ added in v0.4.0
func (p *Server) DescribeAppClusters(ctx context.Context, req *pb.DescribeAppClustersRequest) (*pb.DescribeAppClustersResponse, error)
func (*Server) DescribeClusterNodes ¶
func (p *Server) DescribeClusterNodes(ctx context.Context, req *pb.DescribeClusterNodesRequest) (*pb.DescribeClusterNodesResponse, error)
func (*Server) DescribeClusters ¶
func (p *Server) DescribeClusters(ctx context.Context, req *pb.DescribeClustersRequest) (*pb.DescribeClustersResponse, error)
func (*Server) DescribeDebugAppClusters ¶ added in v0.4.0
func (p *Server) DescribeDebugAppClusters(ctx context.Context, req *pb.DescribeAppClustersRequest) (*pb.DescribeAppClustersResponse, error)
func (*Server) DescribeDebugClusters ¶ added in v0.4.0
func (p *Server) DescribeDebugClusters(ctx context.Context, req *pb.DescribeClustersRequest) (*pb.DescribeClustersResponse, error)
func (*Server) DescribeKeyPairs ¶ added in v0.1.7
func (p *Server) DescribeKeyPairs(ctx context.Context, req *pb.DescribeKeyPairsRequest) (*pb.DescribeKeyPairsResponse, error)
func (*Server) DescribeSubnets ¶
func (p *Server) DescribeSubnets(ctx context.Context, req *pb.DescribeSubnetsRequest) (*pb.DescribeSubnetsResponse, error)
func (*Server) DetachKeyPairs ¶ added in v0.1.7
func (p *Server) DetachKeyPairs(ctx context.Context, req *pb.DetachKeyPairsRequest) (*pb.DetachKeyPairsResponse, error)
func (*Server) GetClusterStatistics ¶ added in v0.1.5
func (p *Server) GetClusterStatistics(ctx context.Context, req *pb.GetClusterStatisticsRequest) (*pb.GetClusterStatisticsResponse, error)
func (*Server) MigrateClusterInRuntime ¶ added in v0.5.0
func (p *Server) MigrateClusterInRuntime(ctx context.Context, req *pb.MigrateClusterInRuntimeRequest) (*pb.MigrateClusterInRuntimeResponse, error)
func (*Server) ModifyCluster ¶
func (p *Server) ModifyCluster(ctx context.Context, req *pb.ModifyClusterRequest) (*pb.ModifyClusterResponse, error)
func (*Server) ModifyClusterAttributes ¶ added in v0.1.8
func (p *Server) ModifyClusterAttributes(ctx context.Context, req *pb.ModifyClusterAttributesRequest) (*pb.ModifyClusterAttributesResponse, error)
func (*Server) ModifyClusterNode ¶
func (p *Server) ModifyClusterNode(ctx context.Context, req *pb.ModifyClusterNodeRequest) (*pb.ModifyClusterNodeResponse, error)
func (*Server) ModifyClusterNodeAttributes ¶ added in v0.1.8
func (p *Server) ModifyClusterNodeAttributes(ctx context.Context, req *pb.ModifyClusterNodeAttributesRequest) (*pb.ModifyClusterNodeAttributesResponse, error)
func (*Server) RecoverClusters ¶
func (p *Server) RecoverClusters(ctx context.Context, req *pb.RecoverClustersRequest) (*pb.RecoverClustersResponse, error)
func (*Server) ResizeCluster ¶
func (p *Server) ResizeCluster(ctx context.Context, req *pb.ResizeClusterRequest) (*pb.ResizeClusterResponse, error)
func (*Server) RollbackCluster ¶
func (p *Server) RollbackCluster(ctx context.Context, req *pb.RollbackClusterRequest) (*pb.RollbackClusterResponse, error)
func (*Server) StartClusters ¶
func (p *Server) StartClusters(ctx context.Context, req *pb.StartClustersRequest) (*pb.StartClustersResponse, error)
func (*Server) StopClusters ¶
func (p *Server) StopClusters(ctx context.Context, req *pb.StopClustersRequest) (*pb.StopClustersResponse, error)
func (*Server) UpdateClusterEnv ¶
func (p *Server) UpdateClusterEnv(ctx context.Context, req *pb.UpdateClusterEnvRequest) (*pb.UpdateClusterEnvResponse, error)
func (*Server) UpgradeCluster ¶
func (p *Server) UpgradeCluster(ctx context.Context, req *pb.UpgradeClusterRequest) (*pb.UpgradeClusterResponse, error)
Click to show internal directories.
Click to hide internal directories.