cluster

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: May 9, 2019 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CheckClusterNodePermission added in v0.2.3 

func CheckClusterNodePermission(ctx context.Context, resourceId string) (*models.ClusterNode, error)

func CheckClusterNodesPermission added in v0.2.3 

func CheckClusterNodesPermission(ctx context.Context, resourceIds []string) ([]*models.ClusterNode, error)

func CheckClusterPermission added in v0.2.3 

func CheckClusterPermission(ctx context.Context, resourceId string) (*models.Cluster, error)

func CheckClustersPermission added in v0.2.3 

func CheckClustersPermission(ctx context.Context, resourceIds []string) ([]*models.Cluster, error)

func CheckKeyPairPermission added in v0.2.3 

func CheckKeyPairPermission(ctx context.Context, resourceId string) (*models.KeyPair, error)

func CheckKeyPairsPermission added in v0.2.3 

func CheckKeyPairsPermission(ctx context.Context, resourceIds []string) ([]*models.KeyPair, error)

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

func Serve 

func Serve(cfg *config.Config)

Types

type Frontgate 

type Frontgate struct {
	Runtime *models.RuntimeDetails
}

func (*Frontgate) ActivateFrontgate 

func (f *Frontgate) ActivateFrontgate(ctx context.Context, frontgateId string) error

func (*Frontgate) CreateCluster 

func (f *Frontgate) CreateCluster(ctx context.Context, clusterWrapper *models.ClusterWrapper) (string, error)

func (*Frontgate) GetActiveFrontgate 

func (f *Frontgate) GetActiveFrontgate(ctx context.Context, clusterWrapper *models.ClusterWrapper) (*models.Cluster, error)

func (*Frontgate) GetFrontgate 

func (f *Frontgate) GetFrontgate(ctx context.Context, frontgateId string) (*models.Cluster, error)

func (*Frontgate) RecoverCluster 

func (f *Frontgate) RecoverCluster(ctx context.Context, frontgate *models.Cluster) error

func (*Frontgate) StartCluster 

func (f *Frontgate) StartCluster(ctx context.Context, frontgate *models.Cluster) error

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 (p *Server) AddTableClusterNodes(ctx context.Context, req *pb.AddTableClusterNodesRequest) (*pbempty.Empty, error)

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) Checker added in v0.1.2 

func (p *Server) Checker(ctx context.Context, req interface{}) 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) 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 (p *Server) DeleteTableClusterNodes(ctx context.Context, req *pb.DeleteTableClusterNodesRequest) (*pbempty.Empty, error)

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

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.