operations

Documentation

Index

• func BootstrapAdditionalMasterNode(ctx context.Context, kubeCl *client.KubernetesClient, cfg *config.MetaConfig, ...) (*terraform.PipelineOutputs, error)
• func BootstrapAdditionalNode(ctx context.Context, kubeCl *client.KubernetesClient, cfg *config.MetaConfig, ...) error
• func BootstrapAdditionalNodeForParallelRun(ctx context.Context, kubeCl *client.KubernetesClient, cfg *config.MetaConfig, ...) error
• func BootstrapSequentialTerraNodes(ctx context.Context, kubeCl *client.KubernetesClient, ...) error
• func Edit(data []byte) ([]byte, error)
• func IsSequentialNodesBootstrap() bool
• func NodeName(cfg *config.MetaConfig, nodeGroupName string, index int) string
• func ParallelBootstrapAdditionalNodes(ctx context.Context, kubeCl *client.KubernetesClient, cfg *config.MetaConfig, ...) ([]string, error)
• func ParallelCreateNodeGroup(ctx context.Context, kubeCl *client.KubernetesClient, ...) error
• func SecretEdit(kubeCl *client.KubernetesClient, name string, Namespace string, secret string, ...) error
• type ConvergeExporter
  • func NewConvergeExporter(address, path string, interval time.Duration) *ConvergeExporter
  • func (c *ConvergeExporter) Start(ctx context.Context)

Functions

func BootstrapAdditionalMasterNode

func BootstrapAdditionalMasterNode(
	ctx context.Context,
	kubeCl *client.KubernetesClient,
	cfg *config.MetaConfig,
	index int,
	cloudConfig string,
	isConverge bool,
	terraformContext *terraform.TerraformContext,
) (*terraform.PipelineOutputs, error)

func BootstrapAdditionalNode

func BootstrapAdditionalNode(
	ctx context.Context,
	kubeCl *client.KubernetesClient,
	cfg *config.MetaConfig,
	index int,
	step, nodeGroupName, cloudConfig string,
	isConverge bool,
	terraformContext *terraform.TerraformContext,
) error

func BootstrapAdditionalNodeForParallelRun

func BootstrapAdditionalNodeForParallelRun(
	ctx context.Context,
	kubeCl *client.KubernetesClient,
	cfg *config.MetaConfig,
	index int,
	step, nodeGroupName, cloudConfig string,
	isConverge bool,
	terraformContext *terraform.TerraformContext,
	runnerLogger log.Logger,
) error

func BootstrapSequentialTerraNodes

func BootstrapSequentialTerraNodes(ctx context.Context, kubeCl *client.KubernetesClient, metaConfig *config.MetaConfig, terraNodeGroups []config.TerraNodeGroupSpec, terraformContext *terraform.TerraformContext) error

func Edit

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

func IsSequentialNodesBootstrap

func IsSequentialNodesBootstrap() bool

func NodeName

func NodeName(cfg *config.MetaConfig, nodeGroupName string, index int) string

func ParallelBootstrapAdditionalNodes

func ParallelBootstrapAdditionalNodes(
	ctx context.Context,
	kubeCl *client.KubernetesClient,
	cfg *config.MetaConfig,
	nodesIndexToCreate []int,
	step, nodeGroupName, cloudConfig string,
	isConverge bool,
	terraformContext *terraform.TerraformContext,
	ngLogger log.Logger,
	saveLogToBuffer bool,
) ([]string, error)

func ParallelCreateNodeGroup

func ParallelCreateNodeGroup(
	ctx context.Context,
	kubeCl *client.KubernetesClient,
	metaConfig *config.MetaConfig,
	terraNodeGroups []config.TerraNodeGroupSpec,
	terraformContext *terraform.TerraformContext,
) error

func SecretEdit

func SecretEdit(kubeCl *client.KubernetesClient, name string, Namespace string, secret string, dataKey string) error

Types

type ConvergeExporter

type ConvergeExporter struct {
	MetricsPath   string
	ListenAddress string
	CheckInterval time.Duration

	GaugeMetrics   map[string]*prometheus.GaugeVec
	CounterMetrics map[string]*prometheus.CounterVec
	// contains filtered or unexported fields
}

func NewConvergeExporter

func NewConvergeExporter(address, path string, interval time.Duration) *ConvergeExporter

func (*ConvergeExporter) Start

func (c *ConvergeExporter) Start(ctx context.Context)