cluster_manager_api

Documentation

Index

• Constants
• func SetLogger()
• type Server
  • func NewServerFromDefaults() (*Server, error)
  • 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) DeleteHelmChart(ctx context.Context, in *pb.DeleteHelmChartMsg) (*pb.DeleteHelmChartReply, 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) InstallHelmChart(ctx context.Context, in *pb.InstallHelmChartMsg) (*pb.InstallHelmChartReply, error)
  • func (s *Server) ProvisionTiller(ctx context.Context, in *pb.ProvisionTillerMsg) (*pb.ProvisionTillerReply, error)
  • func (s *Server) UpdateAWSCredentials(ctx context.Context, in *pb.UpdateAWSCredentialsMsg) (*pb.UpdateAWSCredentialsReply, error)
  • func (s *Server) UpdateAzureCredentials(ctx context.Context, in *pb.UpdateAzureCredentialsMsg) (*pb.UpdateAzureCredentialsReply, error)
  • func (s *Server) UpgradeCluster(ctx context.Context, in *pb.UpgradeClusterMsg) (*pb.UpgradeClusterReply, error)

Constants

const (
	InvalidProviderErrorMessage           = "valid provider not selected"
	UpgradeNotImplementedErrorMessage     = "upgrades for this cluster/provider not supported yet"
	AdjustNodesNotImplementedErrorMessage = "adjusting nodes for this cluster/provider not supported yet"
)

Functions

func SetLogger

func SetLogger()

Types

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServerFromDefaults

func NewServerFromDefaults() (*Server, error)

func (*Server) AdjustClusterNodes

func (s *Server) AdjustClusterNodes(ctx context.Context, in *pb.AdjustClusterMsg) (*pb.AdjustClusterReply, error)

Will adjust a provision a cluster

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

func (s *Server) DeleteHelmChart(ctx context.Context, in *pb.DeleteHelmChartMsg) (*pb.DeleteHelmChartReply, error)

Will delete deployed helm chart

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)

Will return upgrade options for a given cluster

func (*Server) GetVersionInformation

func (s *Server) GetVersionInformation(ctx context.Context, in *pb.GetVersionMsg) (*pb.GetVersionReply, error)

func (*Server) InstallHelmChart

func (s *Server) InstallHelmChart(ctx context.Context, in *pb.InstallHelmChartMsg) (*pb.InstallHelmChartReply, error)

Will install (or reinstall) helm chart This will be destructive if a chart has already been deployed with the same name

func (*Server) ProvisionTiller

func (s *Server) ProvisionTiller(ctx context.Context, in *pb.ProvisionTillerMsg) (*pb.ProvisionTillerReply, error)

Will install (or reinstall) tiller

func (*Server) UpdateAWSCredentials

func (s *Server) UpdateAWSCredentials(ctx context.Context, in *pb.UpdateAWSCredentialsMsg) (*pb.UpdateAWSCredentialsReply, error)

func (*Server) UpdateAzureCredentials

func (s *Server) UpdateAzureCredentials(ctx context.Context, in *pb.UpdateAzureCredentialsMsg) (*pb.UpdateAzureCredentialsReply, error)

func (*Server) UpgradeCluster

func (s *Server) UpgradeCluster(ctx context.Context, in *pb.UpgradeClusterMsg) (*pb.UpgradeClusterReply, error)

Will attempt to upgrade a cluster