operations

Documentation

Index

• func ConnectToKubernetesAPI(sshClient *ssh.Client) (*client.KubernetesClient, error)
• func Edit(data []byte) ([]byte, error)
• func MirrorDeckhouseToLocalFS(mirrorCtx *mirror.Context, versions []semver.Version) error
• func PullExternalModulesToLocalFS(sourceYmlPath, mirrorDirectoryPath, moduleFilterExpression string, ...) error
• func PushDeckhouseToRegistry(mirrorCtx *mirror.Context) error
• func PushModulesToRegistry(modulesDir string, registryPath string, authProvider authn.Authenticator, ...) error
• type ConvergeExporter
  • func NewConvergeExporter(address, path string, interval time.Duration) *ConvergeExporter
  • func (c *ConvergeExporter) Start()

Functions

func ConnectToKubernetesAPI

func ConnectToKubernetesAPI(sshClient *ssh.Client) (*client.KubernetesClient, error)

func Edit

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

func MirrorDeckhouseToLocalFS

func MirrorDeckhouseToLocalFS(
	mirrorCtx *mirror.Context,
	versions []semver.Version,
) error

func PullExternalModulesToLocalFS

func PullExternalModulesToLocalFS(
	sourceYmlPath, mirrorDirectoryPath, moduleFilterExpression string,
	skipVerifyTLS bool,
) error

func PushDeckhouseToRegistry

func PushDeckhouseToRegistry(mirrorCtx *mirror.Context) error

func PushModulesToRegistry

func PushModulesToRegistry(
	modulesDir string,
	registryPath string,
	authProvider authn.Authenticator,
	insecure, skipVerifyTLS bool,
) 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()