kube

Apr 26, 2023

Changes in this version

+ type UserPrefixes struct

+ GroupsPrefix string

+ UsernamePrefix string

Jan 18, 2023

Changes in this version

+ func ConfigWithPrincipal(user *auth.UserPrincipal, config *rest.Config) *rest.Config

Apr 12, 2022

Changes in this version

+ func InClusterConfigClusterName() string

+ type ClientGetter interface

+ Client func(ctx context.Context) (client.Client, error)

+ func NewDefaultClientGetter(configGetter ConfigGetter, clusterName string, ...) ClientGetter

+ type ClusterConfig struct

+ ClusterName string

+ DefaultConfig *rest.Config

+ type ConfigGetter interface

+ Config func(ctx context.Context) *rest.Config

+ type DefaultClientGetter struct

+ func (g *DefaultClientGetter) Client(ctx context.Context) (client.Client, error)

+ type DefaultKubeGetter struct

+ func (g *DefaultKubeGetter) Kube(ctx context.Context) (Kube, error)

+ type ImpersonatingConfigGetter struct

+ func NewImpersonatingConfigGetter(cfg *rest.Config, insecure bool) *ImpersonatingConfigGetter

+ func (r *ImpersonatingConfigGetter) Config(ctx context.Context) *rest.Config

+ type KubeGetter interface

+ Kube func(ctx context.Context) (Kube, error)

+ func NewDefaultKubeGetter(configGetter ConfigGetter, clusterName string) KubeGetter

type WegoConfig

+ ConfigRepo string

Jan 20, 2022

Changes in this version

+ var ErrNamespaceNotFound = errors.New("namespace not found")

type Kube

+ FetchNamespaceWithLabel func(ctx context.Context, key string, value string) (*corev1.Namespace, error)

type KubeHTTP

+ func (k *KubeHTTP) FetchNamespaceWithLabel(ctx context.Context, key string, value string) (*corev1.Namespace, error)

Dec 16, 2021

Changes in this version

+ const WegoConfigMapName

+ var ErrWegoConfigNotFound = errors.New("Wego Config not found")

type Kube

+ GetWegoConfig func(ctx context.Context, namespace string) (*WegoConfig, error)

+ Raw func() client.Client

+ SetWegoConfig func(ctx context.Context, config WegoConfig, namespace string) (*corev1.ConfigMap, error)

type KubeHTTP

+ func (k *KubeHTTP) GetWegoConfig(ctx context.Context, namespace string) (*WegoConfig, error)

+ func (k *KubeHTTP) Raw() client.Client

+ func (k *KubeHTTP) SetWegoConfig(ctx context.Context, config WegoConfig, namespace string) (*corev1.ConfigMap, error)

+ type WegoConfig struct

+ FluxNamespace string

+ WegoNamespace string

Dec 2, 2021

Changes in this version

+ func IsClusterReady(l logger.Logger, k Kube) error

Nov 3, 2021

Changes in this version

type Kube

+ func NewKubeHTTPClientWithConfig(config *rest.Config, contextName string) (Kube, client.Client, error)

+ SetResource func(ctx context.Context, resource Resource) error

type KubeHTTP

+ func (k *KubeHTTP) SetResource(ctx context.Context, resource Resource) error

Oct 22, 2021

Changes in this version

+ var InClusterConfig func() (*rest.Config, error) = func() (*rest.Config, error)

+ func RestConfig() (*rest.Config, string, error)

type Kube

+ NamespacePresent func(ctx context.Context, namespace string) (bool, error)

type KubeHTTP

+ func (k *KubeHTTP) NamespacePresent(ctx context.Context, namespace string) (bool, error)

Sep 23, 2021

Changes in this version

type ClusterStatus

+ const GitOpsInstalled

Sep 8, 2021

Changes in this version

+ var GVRApp schema.GroupVersionResource = wego.GroupVersion.WithResource("apps")

+ var GVRGitRepository schema.GroupVersionResource = sourcev1.GroupVersion.WithResource("gitrepositories")

+ var GVRHelmRelease schema.GroupVersionResource = helmv2.GroupVersion.WithResource("helmreleases")

+ var GVRHelmRepository schema.GroupVersionResource = helmv2.GroupVersion.WithResource("helmrepositories")

+ var GVRKustomization schema.GroupVersionResource = kustomizev1.GroupVersion.WithResource("kustomizations")

+ var GVRSecret schema.GroupVersionResource = corev1.SchemeGroupVersion.WithResource("secrets")

type Kube

+ GetSecret func(ctx context.Context, name types.NamespacedName) (*corev1.Secret, error)

type KubeClient

+ func (k *KubeClient) GetSecret(ctx context.Context, name types.NamespacedName) (*corev1.Secret, error)

type KubeHTTP

+ DynClient dynamic.Interface

+ RestMapper *restmapper.DeferredDiscoveryRESTMapper

+ func (k KubeHTTP) GetSecret(ctx context.Context, name types.NamespacedName) (*corev1.Secret, error)

Aug 23, 2021

Changes in this version

type Kube

+ AppExistsInCluster func(ctx context.Context, namespace string, appHash string) error

+ DeleteByName func(name, kind, namespace string) ([]byte, error)

type KubeClient

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

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

type KubeHTTP

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

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

Jul 19, 2021

Changes in this version

type Kube

+ GetResource func(ctx context.Context, name types.NamespacedName, resource Resource) error

type KubeClient

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

type KubeHTTP

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

+ type Resource interface

Jul 7, 2021

Changes in this version

+ const FluxNamespace

+ const WeGOCRDName

+ const WeGONamespace

+ func CreateScheme() *apiruntime.Scheme

type Kube

+ func NewKubeHTTPClient() (Kube, error)

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

+ LabelExistsInCluster func(ctx context.Context, label string) error

type KubeClient

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

+ func (k *KubeClient) LabelExistsInCluster(ctx context.Context, label string) error

+ type KubeHTTP struct

+ Client client.Client

+ ClusterName string

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

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

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

+ func (c *KubeHTTP) GetApplication(ctx context.Context, name string) (*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) LabelExistsInCluster(ctx context.Context, label string) error

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

Jun 30, 2021

Changes in this version

+ type ClusterStatus int

+ const FluxInstalled

+ const Unknown

+ const Unmodified

+ const WeGOInstalled

+ func (cs ClusterStatus) String() string

+ type Kube interface

+ Apply func(manifests []byte, namespace string) ([]byte, error)

+ Delete func(manifests []byte, namespace string) ([]byte, error)

+ FluxPresent func() (bool, error)

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

+ GetClusterName func() (string, error)

+ GetClusterStatus func() ClusterStatus

+ SecretPresent func(secretName string, namespace string) (bool, error)

+ type KubeClient struct

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