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 (*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 (*Server) DeleteTableClusterNodes

func (p *Server) DeleteTableClusterNodes(ctx context.Context, req *pb.DeleteTableClusterNodesRequest) (*pbempty.Empty, error)

func (*Server) DescribeAppClusters added in v0.4.0

func (*Server) DescribeClusterNodes

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 (*Server) ModifyCluster

func (p *Server) ModifyCluster(ctx context.Context, req *pb.ModifyClusterRequest) (*pb.ModifyClusterResponse, error)

func (*Server) ModifyClusterAttributes added in v0.1.8

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL