cluster

Documentation

Overview

Package cluster contains Zarf-specific cluster management functions.

Package cluster contains Zarf-specific cluster management functions.

Package cluster contains Zarf-specific cluster management functions.

Package cluster contains Zarf-specific cluster management functions.

Package cluster contains Zarf-specific cluster management functions.

Package cluster contains Zarf-specific cluster management functions.

Package cluster contains Zarf-specific cluster management functions.

Package cluster contains Zarf-specific cluster management functions.

Package cluster contains Zarf-specific cluster management functions.

Index

• Constants
• func IsServiceURL(serviceURL string) bool
• type Cluster
  • func NewCluster() (*Cluster, error)
  • func NewClusterOrDie() *Cluster
  • func NewClusterWithWait(timeout time.Duration) (*Cluster, error)
  • func (c *Cluster) DeleteZarfNamespace()
  • func (c *Cluster) GenerateRegistryPullCreds(namespace, name string) (*corev1.Secret, error)
  • func (c *Cluster) GetDeployedZarfPackages() ([]types.DeployedPackage, error)
  • func (c *Cluster) HandleDataInjection(wg *sync.WaitGroup, data types.ZarfDataInjection, ...)
  • func (c *Cluster) InitZarfState(tempPath types.TempPaths, initOptions types.ZarfInitOptions) error
  • func (c *Cluster) LoadZarfState() (types.ZarfState, error)
  • func (c *Cluster) PostSeedRegistry(tempPath types.TempPaths) error
  • func (c *Cluster) PrintConnectTable() error
  • func (c *Cluster) RecordPackageDeployment(pkg types.ZarfPackage, components []types.DeployedComponent)
  • func (c *Cluster) RunInjectionMadness(tempPath types.TempPaths)
  • func (c *Cluster) SaveZarfState(state types.ZarfState) error
  • func (c *Cluster) StripZarfLabelsAndSecretsFromNamespaces()
• type DockerConfig
• type DockerConfigEntry
• type DockerConfigEntryWithAuth
• type Tunnel
  • func NewTunnel(namespace, resourceType, resourceName string, local, remote int) (*Tunnel, error)
  • func NewTunnelFromServiceURL(serviceURL string) (*Tunnel, error)
  • func NewZarfTunnel() (*Tunnel, error)
  • func (tunnel *Tunnel) AddSpinner(spinner *message.Spinner)
  • func (tunnel *Tunnel) Close()
  • func (tunnel *Tunnel) Connect(target string, blocking bool) error
  • func (tunnel *Tunnel) EnableAutoOpen()
  • func (tunnel *Tunnel) Endpoint() string
  • func (tunnel *Tunnel) HTTPEndpoint() string

Constants

const (
	ZarfNamespace        = "zarf"
	ZarfStateSecretName  = "zarf-state"
	ZarfStateDataKey     = "state"
	ZarfPackageInfoLabel = "package-deploy-info"
)

Zarf Cluster Constants.

const (
	PodResource  = "pod"
	SvcResource  = "svc"
	ZarfRegistry = "REGISTRY"
	ZarfLogging  = "LOGGING"
	ZarfGit      = "GIT"
	ZarfInjector = "INJECTOR"
)

Zarf Tunnel Configuration Constants.

Functions

func IsServiceURL

func IsServiceURL(serviceURL string) bool

IsServiceURL will check if the provided string is a valid serviceURL based on if it properly matches a validating regexp.

Types

type Cluster

type Cluster struct {
	Kube *k8s.K8s
}

Cluster is a wrapper for the k8s package that provides Zarf-specific cluster management functions.

func NewCluster

func NewCluster() (*Cluster, error)

NewCluster creates a new cluster instance without waiting for the cluster to be ready.

func NewClusterOrDie

func NewClusterOrDie() *Cluster

NewClusterOrDie creates a new cluster instance and waits up to 30 seconds for the cluster to be ready or throws a fatal error.

func NewClusterWithWait

func NewClusterWithWait(timeout time.Duration) (*Cluster, error)

NewClusterWithWait creates a new cluster instance and waits for the given timeout for the cluster to be ready.

func (*Cluster) DeleteZarfNamespace

func (c *Cluster) DeleteZarfNamespace()

DeleteZarfNamespace deletes the Zarf namespace from the connected cluster.

func (*Cluster) GenerateRegistryPullCreds

func (c *Cluster) GenerateRegistryPullCreds(namespace, name string) (*corev1.Secret, error)

GenerateRegistryPullCreds generates a secret containing the registry credentials.

func (*Cluster) GetDeployedZarfPackages

func (c *Cluster) GetDeployedZarfPackages() ([]types.DeployedPackage, error)

GetDeployedZarfPackages gets metadata information about packages that have been deployed to the cluster. We determine what packages have been deployed to the cluster by looking for specific secrets in the Zarf namespace.

func (*Cluster) HandleDataInjection

func (c *Cluster) HandleDataInjection(wg *sync.WaitGroup, data types.ZarfDataInjection, componentPath types.ComponentPaths)

HandleDataInjection waits for the target pod(s) to come up and inject the data into them todo: this currently requires kubectl but we should have enough k8s work to make this native now.

func (*Cluster) InitZarfState

func (c *Cluster) InitZarfState(tempPath types.TempPaths, initOptions types.ZarfInitOptions) error

InitZarfState initializes the Zarf state with the given temporary directory and init configs.

func (*Cluster) LoadZarfState

func (c *Cluster) LoadZarfState() (types.ZarfState, error)

LoadZarfState returns the current zarf/zarf-state secret data or an empty ZarfState.

func (*Cluster) PostSeedRegistry

func (c *Cluster) PostSeedRegistry(tempPath types.TempPaths) error

PostSeedRegistry handles cleanup once the seed registry is up.

func (*Cluster) PrintConnectTable

func (c *Cluster) PrintConnectTable() error

PrintConnectTable will print a table of all Zarf connect matches found in the cluster.

func (*Cluster) RecordPackageDeployment

func (c *Cluster) RecordPackageDeployment(pkg types.ZarfPackage, components []types.DeployedComponent)

RecordPackageDeployment saves metadata about a package that has been deployed to the cluster.

func (*Cluster) RunInjectionMadness

func (c *Cluster) RunInjectionMadness(tempPath types.TempPaths)

RunInjectionMadness initializes a Zarf injection into the cluster.

func (*Cluster) SaveZarfState

func (c *Cluster) SaveZarfState(state types.ZarfState) error

SaveZarfState takes a given state and persists it to the Zarf/zarf-state secret.

func (*Cluster) StripZarfLabelsAndSecretsFromNamespaces

func (c *Cluster) StripZarfLabelsAndSecretsFromNamespaces()

StripZarfLabelsAndSecretsFromNamespaces removes metadata and secrets from existing namespaces no longer manged by Zarf.

type DockerConfig

type DockerConfig struct {
	Auths DockerConfigEntry `json:"auths"`
}

DockerConfig contains the authentication information from the machine's docker config.

type DockerConfigEntry

type DockerConfigEntry map[string]DockerConfigEntryWithAuth

DockerConfigEntry contains a map of DockerConfigEntryWithAuth for a registry.

type DockerConfigEntryWithAuth

type DockerConfigEntryWithAuth struct {
	Auth string `json:"auth"`
}

DockerConfigEntryWithAuth contains a docker config authentication string.

type Tunnel

type Tunnel struct {
	// contains filtered or unexported fields
}

Tunnel is the main struct that configures and manages port forwarding tunnels to Kubernetes resources.

func NewTunnel

func NewTunnel(namespace, resourceType, resourceName string, local, remote int) (*Tunnel, error)

NewTunnel will create a new Tunnel struct. Note that if you use 0 for the local port, an open port on the host system will be selected automatically, and the Tunnel struct will be updated with the selected port.

func NewTunnelFromServiceURL

func NewTunnelFromServiceURL(serviceURL string) (*Tunnel, error)

NewTunnelFromServiceURL takes a serviceURL and parses it to create a tunnel to the cluster. The string is expected to follow the following format: Example serviceURL: http://{SERVICE_NAME}.{NAMESPACE}.svc.cluster.local:{PORT}.

func NewZarfTunnel

func NewZarfTunnel() (*Tunnel, error)

NewZarfTunnel will create a new Tunnel struct for the Zarf namespace.

func (*Tunnel) AddSpinner

func (tunnel *Tunnel) AddSpinner(spinner *message.Spinner)

AddSpinner will add a spinner to the tunnel to show progress.

func (*Tunnel) Close

func (tunnel *Tunnel) Close()

Close disconnects a tunnel connection by closing the StopChan, thereby stopping the goroutine.

func (*Tunnel) Connect

func (tunnel *Tunnel) Connect(target string, blocking bool) error

Connect will establish a tunnel to the specified target.

func (*Tunnel) EnableAutoOpen

func (tunnel *Tunnel) EnableAutoOpen()

EnableAutoOpen will automatically open the established tunnel in the default browser when it is ready.

func (*Tunnel) Endpoint

func (tunnel *Tunnel) Endpoint() string

Endpoint returns the tunnel endpoint.

func (*Tunnel) HTTPEndpoint

func (tunnel *Tunnel) HTTPEndpoint() string

HTTPEndpoint returns the tunnel endpoint as a HTTP URL string.