helm

Documentation

Index

• type JobDirective
• type Parser
  • func (p *Parser) Parse(c *chart.Chart, conf []byte, versionId string) (*models.ClusterWrapper, error)
  • func (p *Parser) ParseCluster(name string, description string, versionId string) (*models.Cluster, error)
  • func (p *Parser) ParseClusterRolesAndClusterCommons(c *chart.Chart, vals map[string]interface{}, customVals map[string]interface{}) (map[string]*models.ClusterRole, map[string]*models.ClusterCommon, error)
  • func (p *Parser) ParseCustomValues(conf []byte) (map[string]interface{}, string, string, error)
• type Provider
  • func NewProvider() *Provider
  • func (p *Provider) CheckResourceQuotas(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) SetLogger(logger *logger.Logger)
  • 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

Types

type JobDirective

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

type Parser

type Parser struct {
	Logger *logger.Logger
}

func (*Parser) Parse

func (p *Parser) Parse(c *chart.Chart, conf []byte, versionId string) (*models.ClusterWrapper, error)

func (*Parser) ParseCluster

func (p *Parser) ParseCluster(name string, description string, versionId string) (*models.Cluster, error)

func (*Parser) ParseClusterRolesAndClusterCommons

func (p *Parser) ParseClusterRolesAndClusterCommons(c *chart.Chart, vals map[string]interface{}, customVals map[string]interface{}) (map[string]*models.ClusterRole, map[string]*models.ClusterCommon, error)

func (*Parser) ParseCustomValues

func (p *Parser) ParseCustomValues(conf []byte) (map[string]interface{}, string, string, error)

type Provider

type Provider struct {
	Logger *logger.Logger
}

func NewProvider

func NewProvider() *Provider

func (*Provider) CheckResourceQuotas

func (p *Provider) CheckResourceQuotas(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) SetLogger

func (p *Provider) SetLogger(logger *logger.Logger)

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
}