Documentation ¶
Index ¶
- func GetKubeConfig(clusterName string, manager manager.Manager) ([]byte, error)
- func GetMachineName(clusterName string, hostIp string, manager manager.Manager) (string, error)
- func PrepareNodes(in *pb.CreateClusterMsg) ([]byte, []byte, error)
- func TranslateClusterStatus(crStatus common.ClusterStatusPhase) cmassh.ClusterStatus
- type Server
- func (s *Server) AdjustClusterNodes(ctx context.Context, in *pb.AdjustClusterMsg) (*pb.AdjustClusterReply, error)
- func (s *Server) CreateCluster(ctx context.Context, in *pb.CreateClusterMsg) (*pb.CreateClusterReply, error)
- func (s *Server) DeleteCluster(ctx context.Context, in *pb.DeleteClusterMsg) (*pb.DeleteClusterReply, error)
- func (s *Server) GetCluster(ctx context.Context, in *pb.GetClusterMsg) (*pb.GetClusterReply, error)
- func (s *Server) GetClusterList(ctx context.Context, in *pb.GetClusterListMsg) (reply *pb.GetClusterListReply, err error)
- func (s *Server) GetUpgradeClusterInformation(ctx context.Context, in *pb.GetUpgradeClusterInformationMsg) (*pb.GetUpgradeClusterInformationReply, error)
- func (s *Server) GetVersionInformation(ctx context.Context, in *pb.GetVersionMsg) (*pb.GetVersionReply, error)
- func (s *Server) UpgradeCluster(ctx context.Context, in *pb.UpgradeClusterMsg) (*pb.UpgradeClusterReply, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetKubeConfig ¶
func GetMachineName ¶
func PrepareNodes ¶
func PrepareNodes(in *pb.CreateClusterMsg) ([]byte, []byte, error)
func TranslateClusterStatus ¶
func TranslateClusterStatus(crStatus common.ClusterStatusPhase) cmassh.ClusterStatus
Types ¶
type Server ¶
func (*Server) AdjustClusterNodes ¶
func (s *Server) AdjustClusterNodes(ctx context.Context, in *pb.AdjustClusterMsg) (*pb.AdjustClusterReply, error)
func (*Server) CreateCluster ¶
func (s *Server) CreateCluster(ctx context.Context, in *pb.CreateClusterMsg) (*pb.CreateClusterReply, error)
func (*Server) DeleteCluster ¶
func (s *Server) DeleteCluster(ctx context.Context, in *pb.DeleteClusterMsg) (*pb.DeleteClusterReply, error)
func (*Server) GetCluster ¶
func (s *Server) GetCluster(ctx context.Context, in *pb.GetClusterMsg) (*pb.GetClusterReply, error)
func (*Server) GetClusterList ¶
func (s *Server) GetClusterList(ctx context.Context, in *pb.GetClusterListMsg) (reply *pb.GetClusterListReply, err error)
func (*Server) GetUpgradeClusterInformation ¶
func (s *Server) GetUpgradeClusterInformation(ctx context.Context, in *pb.GetUpgradeClusterInformationMsg) (*pb.GetUpgradeClusterInformationReply, error)
func (*Server) GetVersionInformation ¶
func (s *Server) GetVersionInformation(ctx context.Context, in *pb.GetVersionMsg) (*pb.GetVersionReply, error)
func (*Server) UpgradeCluster ¶
func (s *Server) UpgradeCluster(ctx context.Context, in *pb.UpgradeClusterMsg) (*pb.UpgradeClusterReply, error)
Click to show internal directories.
Click to hide internal directories.