helm

Documentation

Index

• Constants
• Variables
• func ConvertJsonToYaml(data []byte) ([]byte, error)
• func GetLabelString(m map[string]string) string
• func GetStringFromValues(vals map[string]interface{}, key string) (string, bool)
• type HelmHandler
  • func GetHelmHandler(Logger *logger.Logger, runtimeId string) *HelmHandler
  • func (p *HelmHandler) CheckClusterNameIsUnique(clusterName string) error
  • func (p *HelmHandler) DeleteRelease(releaseName string, purge bool) error
  • func (p *HelmHandler) InstallReleaseFromChart(c *chart.Chart, ns string, rawVals []byte, releaseName string) error
  • func (p *HelmHandler) ReleaseStatus(releaseName string) (*rls.GetReleaseStatusResponse, error)
  • func (p *HelmHandler) RollbackRelease(releaseName string) error
  • func (p *HelmHandler) UpdateReleaseFromChart(releaseName string, c *chart.Chart, rawVals []byte) error
• type JobDirective
• type KubeHandler
  • func GetKubeHandler(Logger *logger.Logger, runtimeId string) *KubeHandler
  • func (p *KubeHandler) CheckApiVersionsSupported(apiVersions []string) error
  • func (p *KubeHandler) DescribeRuntimeProviderZones(credential string) ([]string, error)
  • func (p *KubeHandler) GetKubePodsAsClusterNodes(namespace, clusterId, owner string, ...) ([]*pb.ClusterNode, error)
  • func (p *KubeHandler) ValidateCredential(credential, zone string) error
  • func (p *KubeHandler) WaitPodsRunning(runtimeId, namespace string, clusterRoles map[string]*models.ClusterRole, ...) error
• type Parser
  • func (p *Parser) Parse() (*models.ClusterWrapper, error)
• type Provider
  • func NewProvider(l *logger.Logger) *Provider
  • func (p *Provider) CheckResource(ctx context.Context, clusterWrapper *models.ClusterWrapper) error
  • func (p *Provider) DescribeRuntimeProviderZones(url, credential string) ([]string, error)
  • func (p *Provider) DescribeSubnets(ctx context.Context, req *pb.DescribeSubnetsRequest) (*pb.DescribeSubnetsResponse, error)
  • func (p *Provider) DescribeVpc(runtimeId, vpcId string) (*models.Vpc, error)
  • func (p *Provider) HandleSubtask(task *models.Task) error
  • func (p *Provider) ParseClusterConf(versionId, runtimeId, conf string) (*models.ClusterWrapper, error)
  • func (p *Provider) SplitJobIntoTasks(job *models.Job) (*models.TaskLayer, error)
  • func (p *Provider) UpdateClusterStatus(job *models.Job) error
  • func (p *Provider) ValidateCredential(url, credential, zone string) error
  • func (p *Provider) WaitSubtask(task *models.Task, timeout time.Duration, waitInterval time.Duration) error
• type TaskDirective

Constants

const (
	KubeSystemNamespace = "kube-system"

	DeploymentFlag  = "-Deployment"
	StatefulSetFlag = "-StatefulSet"
	DaemonSetFlag   = "-DaemonSet"
)

Variables

var (
	ClusterNameRegExp = regexp.MustCompile(`[a-z0-9]([-a-z0-9]*[a-z0-9])?(\.[a-z0-9]([-a-z0-9]*[a-z0-9])?)*`)
)

var (
	NamespaceRegExp = regexp.MustCompile(`[a-z0-9]([-a-z0-9]*[a-z0-9])?`)
)

Functions

func ConvertJsonToYaml

func ConvertJsonToYaml(data []byte) ([]byte, error)

func GetLabelString

func GetLabelString(m map[string]string) string

func GetStringFromValues

func GetStringFromValues(vals map[string]interface{}, key string) (string, bool)

Types

type HelmHandler

type HelmHandler struct {
	Logger    *logger.Logger
	RuntimeId string
}

func GetHelmHandler

func GetHelmHandler(Logger *logger.Logger, runtimeId string) *HelmHandler

func (*HelmHandler) CheckClusterNameIsUnique

func (p *HelmHandler) CheckClusterNameIsUnique(clusterName string) error

func (*HelmHandler) DeleteRelease

func (p *HelmHandler) DeleteRelease(releaseName string, purge bool) error

func (*HelmHandler) InstallReleaseFromChart

func (p *HelmHandler) InstallReleaseFromChart(c *chart.Chart, ns string, rawVals []byte, releaseName string) error

func (*HelmHandler) ReleaseStatus

func (p *HelmHandler) ReleaseStatus(releaseName string) (*rls.GetReleaseStatusResponse, error)

func (*HelmHandler) RollbackRelease

func (p *HelmHandler) RollbackRelease(releaseName string) error

func (*HelmHandler) UpdateReleaseFromChart

func (p *HelmHandler) UpdateReleaseFromChart(releaseName string, c *chart.Chart, rawVals []byte) error

type JobDirective

type JobDirective struct {
	Namespace   string
	RuntimeId   string
	Values      string
	ClusterName string
}

type KubeHandler

type KubeHandler struct {
	Logger    *logger.Logger
	RuntimeId string
}

func GetKubeHandler

func GetKubeHandler(Logger *logger.Logger, runtimeId string) *KubeHandler

func (*KubeHandler) CheckApiVersionsSupported

func (p *KubeHandler) CheckApiVersionsSupported(apiVersions []string) error

func (*KubeHandler) DescribeRuntimeProviderZones

func (p *KubeHandler) DescribeRuntimeProviderZones(credential string) ([]string, error)

func (*KubeHandler) GetKubePodsAsClusterNodes

func (p *KubeHandler) GetKubePodsAsClusterNodes(namespace, clusterId, owner string, clusterRoles map[string]*models.ClusterRole) ([]*pb.ClusterNode, error)

func (*KubeHandler) ValidateCredential

func (p *KubeHandler) ValidateCredential(credential, zone string) error

func (*KubeHandler) WaitPodsRunning

func (p *KubeHandler) WaitPodsRunning(runtimeId, namespace string, clusterRoles map[string]*models.ClusterRole, timeout time.Duration, waitInterval time.Duration) error

type Parser

type Parser struct {
	Logger    *logger.Logger
	Chart     *chart.Chart
	Conf      string
	VersionId string
	RuntimeId string
}

func (*Parser) Parse

func (p *Parser) Parse() (*models.ClusterWrapper, error)

type Provider

type Provider struct {
	Logger *logger.Logger
}

func NewProvider

func NewProvider(l *logger.Logger) *Provider

func (*Provider) CheckResource

func (p *Provider) CheckResource(ctx context.Context, clusterWrapper *models.ClusterWrapper) error

func (*Provider) DescribeRuntimeProviderZones

func (p *Provider) DescribeRuntimeProviderZones(url, credential string) ([]string, error)

func (*Provider) DescribeSubnets

func (p *Provider) DescribeSubnets(ctx context.Context, req *pb.DescribeSubnetsRequest) (*pb.DescribeSubnetsResponse, error)

func (*Provider) DescribeVpc

func (p *Provider) DescribeVpc(runtimeId, vpcId string) (*models.Vpc, error)

func (*Provider) HandleSubtask

func (p *Provider) HandleSubtask(task *models.Task) error

func (*Provider) ParseClusterConf

func (p *Provider) ParseClusterConf(versionId, runtimeId, conf string) (*models.ClusterWrapper, error)

func (*Provider) SplitJobIntoTasks

func (p *Provider) SplitJobIntoTasks(job *models.Job) (*models.TaskLayer, error)

func (*Provider) UpdateClusterStatus

func (p *Provider) UpdateClusterStatus(job *models.Job) error

func (*Provider) ValidateCredential

func (p *Provider) ValidateCredential(url, credential, zone string) error

func (*Provider) WaitSubtask

func (p *Provider) WaitSubtask(task *models.Task, timeout time.Duration, waitInterval time.Duration) error

type TaskDirective

type TaskDirective struct {
	VersionId         string
	Namespace         string
	RuntimeId         string
	Values            string
	ClusterName       string
	RawClusterWrapper string
}