kube

Documentation

Index

• type ClusterStatus
  • func (cs ClusterStatus) String() string
• type Kube
• type KubeClient
  • func New(cliRunner runner.Runner) *KubeClient
  • func (k *KubeClient) Apply(manifests []byte, namespace string) ([]byte, error)
  • func (k *KubeClient) Delete(manifests []byte, namespace string) ([]byte, error)
  • func (k *KubeClient) FluxPresent() (bool, error)
  • func (k *KubeClient) GetApplication(name string) (*wego.Application, error)
  • func (k *KubeClient) GetClusterName() (string, error)
  • func (k *KubeClient) GetClusterStatus() ClusterStatus
  • func (k *KubeClient) SecretPresent(secretName, namespace string) (bool, error)

Types

type ClusterStatus

type ClusterStatus int

const (
	Unknown ClusterStatus = iota
	Unmodified
	FluxInstalled
	WeGOInstalled
)

func (ClusterStatus) String

func (cs ClusterStatus) String() string

Function to translate ClusterStatus to a string

type Kube

type Kube interface {
	Apply(manifests []byte, namespace string) ([]byte, error)
	Delete(manifests []byte, namespace string) ([]byte, error)
	GetClusterName() (string, error)
	GetClusterStatus() ClusterStatus
	FluxPresent() (bool, error)
	SecretPresent(secretName string, namespace string) (bool, error)
	GetApplication(name string) (*wego.Application, error)
}

type KubeClient

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

func New

func New(cliRunner runner.Runner) *KubeClient

func (*KubeClient) Apply

func (k *KubeClient) Apply(manifests []byte, namespace string) ([]byte, error)

func (*KubeClient) Delete

func (k *KubeClient) Delete(manifests []byte, namespace string) ([]byte, error)

func (*KubeClient) FluxPresent

func (k *KubeClient) FluxPresent() (bool, error)

FluxPresent checks flux presence in the cluster

func (*KubeClient) GetApplication

func (k *KubeClient) GetApplication(name string) (*wego.Application, error)

func (*KubeClient) GetClusterName

func (k *KubeClient) GetClusterName() (string, error)

func (*KubeClient) GetClusterStatus

func (k *KubeClient) GetClusterStatus() ClusterStatus

func (*KubeClient) SecretPresent

func (k *KubeClient) SecretPresent(secretName, namespace string) (bool, error)

SecretPresent checks for a specific secret within a specified namespace