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(ctx context.Context, 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(ctx context.Context, runtimeId string) *KubeHandler
  • func (p *KubeHandler) CheckApiVersionsSupported(apiVersions []string) error
  • func (p *KubeHandler) DescribeClusterDetails(clusterWrapper *models.ClusterWrapper) error
  • func (p *KubeHandler) DescribeRuntimeProviderZones(credential string) ([]string, error)
  • func (p *KubeHandler) ValidateCredential(credential, zone string) error
  • func (p *KubeHandler) WaitWorkloadReady(runtimeId, namespace string, clusterRoles map[string]*models.ClusterRole, ...) error
• type Parser
  • func (p *Parser) Parse(clusterWrapper *models.ClusterWrapper) error
• type Provider
  • func NewProvider() *Provider
  • func (p *Provider) CheckResource(ctx context.Context, clusterWrapper *models.ClusterWrapper) error
  • func (p *Provider) DescribeClusterDetails(ctx context.Context, clusterWrapper *models.ClusterWrapper) error
  • func (p *Provider) DescribeRuntimeProviderZones(ctx context.Context, url, credential string) ([]string, error)
  • func (p *Provider) DescribeSubnets(ctx context.Context, req *pb.DescribeSubnetsRequest) (*pb.DescribeSubnetsResponse, error)
  • func (p *Provider) DescribeVpc(ctx context.Context, runtimeId, vpcId string) (*models.Vpc, error)
  • func (p *Provider) HandleSubtask(ctx context.Context, task *models.Task) error
  • func (p *Provider) ParseClusterConf(ctx context.Context, versionId, runtimeId, conf string, ...) error
  • func (p *Provider) SplitJobIntoTasks(ctx context.Context, job *models.Job) (*models.TaskLayer, error)
  • func (p *Provider) UpdateClusterStatus(ctx context.Context, job *models.Job) error
  • func (p *Provider) ValidateCredential(ctx context.Context, runtimeId, url, credential, zone string) error
  • func (p *Provider) WaitSubtask(ctx context.Context, task *models.Task) error
• type TaskDirective

Constants

const (
	RuntimeAnnotationKey = "openpitrix_runtime"

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

Variables

var (
	ClusterNameReg    = `^[a-z]([-a-z0-9]*[a-z0-9])?$`
	ClusterNameRegExp = regexp.MustCompile(ClusterNameReg)
)

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

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 {
	RuntimeId string
	// contains filtered or unexported fields
}

func GetHelmHandler

func GetHelmHandler(ctx context.Context, 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 {
	RuntimeId string
	// contains filtered or unexported fields
}

func GetKubeHandler

func GetKubeHandler(ctx context.Context, runtimeId string) *KubeHandler

func (*KubeHandler) CheckApiVersionsSupported

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

func (*KubeHandler) DescribeClusterDetails

func (p *KubeHandler) DescribeClusterDetails(clusterWrapper *models.ClusterWrapper) error

func (*KubeHandler) DescribeRuntimeProviderZones

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

func (*KubeHandler) ValidateCredential

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

func (*KubeHandler) WaitWorkloadReady

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

type Parser

type Parser struct {
	Chart     *chart.Chart
	Conf      string
	VersionId string
	RuntimeId string
	Namespace string
	// contains filtered or unexported fields
}

func (*Parser) Parse

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

type Provider

type Provider struct{}

func NewProvider

func NewProvider() *Provider

func (*Provider) CheckResource

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

func (*Provider) DescribeClusterDetails

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

func (*Provider) DescribeRuntimeProviderZones

func (p *Provider) DescribeRuntimeProviderZones(ctx context.Context, 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(ctx context.Context, runtimeId, vpcId string) (*models.Vpc, error)

func (*Provider) HandleSubtask

func (p *Provider) HandleSubtask(ctx context.Context, task *models.Task) error

func (*Provider) ParseClusterConf

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

func (*Provider) SplitJobIntoTasks

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

func (*Provider) UpdateClusterStatus

func (p *Provider) UpdateClusterStatus(ctx context.Context, job *models.Job) error

func (*Provider) ValidateCredential

func (p *Provider) ValidateCredential(ctx context.Context, runtimeId, url, credential, zone string) error

func (*Provider) WaitSubtask

func (p *Provider) WaitSubtask(ctx context.Context, task *models.Task) error

type TaskDirective

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