kube

Documentation

Index

• Constants
• func CreateScheme() *apiruntime.Scheme
• type ClusterStatus
  • func (cs ClusterStatus) String() string
• type Kube
  • func NewKubeHTTPClient() (Kube, error)
• type KubeClient
  • func New(cliRunner runner.Runner) *KubeClient
  • func (k *KubeClient) AppExistsInCluster(ctx context.Context, namespace string, appHash string) error
  • func (k *KubeClient) Apply(manifests []byte, namespace string) ([]byte, error)
  • func (k *KubeClient) Delete(manifests []byte, namespace string) ([]byte, error)
  • func (k *KubeClient) DeleteByName(name, kind, namespace string) ([]byte, error)
  • func (k *KubeClient) FluxPresent(ctx context.Context) (bool, error)
  • func (k *KubeClient) GetApplication(ctx context.Context, name types.NamespacedName) (*wego.Application, error)
  • func (k *KubeClient) GetApplications(ctx context.Context, ns string) ([]wego.Application, error)
  • func (k *KubeClient) GetClusterName(ctx context.Context) (string, error)
  • func (k *KubeClient) GetClusterStatus(ctx context.Context) ClusterStatus
  • func (k *KubeClient) GetResource(ctx context.Context, name types.NamespacedName, resource Resource) error
  • func (k *KubeClient) SecretPresent(ctx context.Context, secretName, namespace string) (bool, error)
• type KubeHTTP
  • func (c *KubeHTTP) AppExistsInCluster(ctx context.Context, namespace string, appHash string) error
  • func (c *KubeHTTP) Apply(manifests []byte, namespace string) ([]byte, error)
  • func (c *KubeHTTP) Delete(manifests []byte, namespace string) ([]byte, error)
  • func (c *KubeHTTP) DeleteByName(name, kind, namespace string) ([]byte, error)
  • func (c *KubeHTTP) FluxPresent(ctx context.Context) (bool, error)
  • func (c *KubeHTTP) GetApplication(ctx context.Context, name types.NamespacedName) (*wego.Application, error)
  • func (c *KubeHTTP) GetApplications(ctx context.Context, namespace string) ([]wego.Application, error)
  • func (c *KubeHTTP) GetClusterName(ctx context.Context) (string, error)
  • func (c *KubeHTTP) GetClusterStatus(ctx context.Context) ClusterStatus
  • func (c *KubeHTTP) GetResource(ctx context.Context, name types.NamespacedName, resource Resource) error
  • func (c *KubeHTTP) SecretPresent(ctx context.Context, secretName string, namespace string) (bool, error)
• type Resource

Constants

const FluxNamespace = "flux-system"

const WeGOCRDName = "apps.wego.weave.works"

const WeGONamespace = "wego-system"

Functions

func CreateScheme

func CreateScheme() *apiruntime.Scheme

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)
	DeleteByName(name, kind, namespace string) ([]byte, error)
	SecretPresent(ctx context.Context, string, namespace string) (bool, error)
	GetApplications(ctx context.Context, namespace string) ([]wego.Application, error)
	FluxPresent(ctx context.Context) (bool, error)
	GetClusterName(ctx context.Context) (string, error)
	GetClusterStatus(ctx context.Context) ClusterStatus
	AppExistsInCluster(ctx context.Context, namespace string, appHash string) error
	GetApplication(ctx context.Context, name types.NamespacedName) (*wego.Application, error)
	GetResource(ctx context.Context, name types.NamespacedName, resource Resource) error
}

func NewKubeHTTPClient

func NewKubeHTTPClient() (Kube, error)

type KubeClient

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

func New

func New(cliRunner runner.Runner) *KubeClient

func (*KubeClient) AppExistsInCluster

func (k *KubeClient) AppExistsInCluster(ctx context.Context, namespace string, appHash string) error

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) DeleteByName

func (k *KubeClient) DeleteByName(name, kind, namespace string) ([]byte, error)

func (*KubeClient) FluxPresent

func (k *KubeClient) FluxPresent(ctx context.Context) (bool, error)

FluxPresent checks flux presence in the cluster

func (*KubeClient) GetApplication

func (k *KubeClient) GetApplication(ctx context.Context, name types.NamespacedName) (*wego.Application, error)

func (*KubeClient) GetApplications

func (k *KubeClient) GetApplications(ctx context.Context, ns string) ([]wego.Application, error)

func (*KubeClient) GetClusterName

func (k *KubeClient) GetClusterName(ctx context.Context) (string, error)

func (*KubeClient) GetClusterStatus

func (k *KubeClient) GetClusterStatus(ctx context.Context) ClusterStatus

func (*KubeClient) GetResource

func (k *KubeClient) GetResource(ctx context.Context, name types.NamespacedName, resource Resource) error

func (*KubeClient) SecretPresent

func (k *KubeClient) SecretPresent(ctx context.Context, secretName, namespace string) (bool, error)

SecretPresent checks for a specific secret within a specified namespace

type KubeHTTP

type KubeHTTP struct {
	Client      client.Client
	ClusterName string
}

This is an alternative implementation of the kube.Kube interface, specifically designed to query the K8s API directly instead of relying on `kubectl` to be present in the PATH.

func (*KubeHTTP) AppExistsInCluster

func (c *KubeHTTP) AppExistsInCluster(ctx context.Context, namespace string, appHash string) error

func (*KubeHTTP) Apply

func (c *KubeHTTP) Apply(manifests []byte, namespace string) ([]byte, error)

func (*KubeHTTP) Delete

func (c *KubeHTTP) Delete(manifests []byte, namespace string) ([]byte, error)

func (*KubeHTTP) DeleteByName

func (c *KubeHTTP) DeleteByName(name, kind, namespace string) ([]byte, error)

func (*KubeHTTP) FluxPresent

func (c *KubeHTTP) FluxPresent(ctx context.Context) (bool, error)

func (*KubeHTTP) GetApplication

func (c *KubeHTTP) GetApplication(ctx context.Context, name types.NamespacedName) (*wego.Application, error)

func (*KubeHTTP) GetApplications

func (c *KubeHTTP) GetApplications(ctx context.Context, namespace string) ([]wego.Application, error)

func (*KubeHTTP) GetClusterName

func (c *KubeHTTP) GetClusterName(ctx context.Context) (string, error)

func (*KubeHTTP) GetClusterStatus

func (c *KubeHTTP) GetClusterStatus(ctx context.Context) ClusterStatus

func (*KubeHTTP) GetResource

func (c *KubeHTTP) GetResource(ctx context.Context, name types.NamespacedName, resource Resource) error

func (*KubeHTTP) SecretPresent

func (c *KubeHTTP) SecretPresent(ctx context.Context, secretName string, namespace string) (bool, error)

type Resource

type Resource interface {
	metav1.Object
	runtime.Object
}