thales

package module

Go to main page

Versions in this module

v0

v0.1.12

Jul 25, 2025

v0.1.11

Nov 27, 2024

v0.1.10-2

Nov 27, 2024

v0.1.10-1

Nov 5, 2024

v0.1.9

Apr 9, 2024

v0.1.8

Apr 9, 2024

Changes in this version

type KubeClient

+ func (c *KubeClient) MetricsClient() versioned.Interface

v0.1.7

Dec 4, 2023

Changes in this version

type KubeClient

+ func (c *KubeClient) AdmissionRegistrationV1() admissionregistrationv1.AdmissionregistrationV1Interface

v0.1.6

Dec 2, 2023

Changes in this version

type KubeClient

+ func (c *KubeClient) Cert() corev1.CoreV1Interface

+ func (c *KubeClient) CertificatesV1() certificatesv1.CertificatesV1Interface

v0.1.5

Dec 1, 2023

Changes in this version

+ func CopyFileFromPod(srcPath, destPath, namespace, podName string, rest rest.Interface) error

+ func CopyFileToPod(podName, destPath, srcPath, ns string, rest rest.Interface) (string, error)

+ func GetHostCaCertFromConfig(config *rest.Config) []byte

+ func TestAnnotatedDeploymentObject(name, ns string, annotations map[string]string) *appsv1.Deployment

+ func TestDeploymentObject(name, ns string) *appsv1.Deployment

+ func TestJobObject(name, ns string, completed bool) *batchv1.Job

+ func TestPodObject(name, ns, access, role string) *corev1.Pod

+ func TestPodObjectWithExit(name, ns string) *corev1.Pod

+ func TestPodSpecVolume(name, secretName string) []corev1.Volume

type KubeClient

+ func NewFakeKubeClient() *KubeClient

+ func NewFromConfig(config []byte) (*KubeClient, error)

+ func (c *KubeClient) ApiextensionsV1() apiextensionsv1.ApiextensionsV1Interface

+ func (c *KubeClient) AppsV1() appsv1.AppsV1Interface

+ func (c *KubeClient) AuthorizationV1() authorizationv1.AuthorizationV1Interface

+ func (c *KubeClient) BatchV1() batchv1.BatchV1Interface

+ func (c *KubeClient) CoreV1() corev1.CoreV1Interface

+ func (c *KubeClient) Discovery() discovery.DiscoveryInterface

+ func (c *KubeClient) Dynamic() dynamic.Interface

+ func (c *KubeClient) Host() string

+ func (c *KubeClient) KubeCliConfig(namespace string) (*genericclioptions.ConfigFlags, error)

+ func (c *KubeClient) RbacV1() rbacv1.RbacV1Interface

+ func (c *KubeClient) RestConfig() *rest.Config

+ func (c *KubeClient) StorageV1() storagev1.StorageV1Interface

v0.1.4

Nov 29, 2023

v0.1.3

Nov 29, 2023

v0.1.2

Nov 29, 2023

v0.1.1

Nov 29, 2023

v0.1.0

Nov 29, 2023

Changes in this version

+ const EnvKubePath

+ const EnvNamespace

+ func CreateAnnotatedDeploymentObject(name, ns string, annotations map[string]string) *appsv1.Deployment

+ func CreateDeploymentForTest(name, ns string, client KubeClient) error

+ func CreateDeploymentObject(name, ns string) *appsv1.Deployment

+ func CreateJobObject(name, ns string, completed bool) *batchv1.Job

+ func CreatePodForTest(name, ns, access, role string, client KubeClient) error

+ func CreatePodObject(name, ns, access, role string) *corev1.Pod

+ func CreatePodObjectWithExit(name, ns string) *corev1.Pod

+ func CreatePodSpecVolume(name, secretName string) []corev1.Volume

+ type Access interface

+ GetServiceAccounts func() (*corev1.ServiceAccountList, error)

+ type AccessImpl struct

+ func NewAccessClient(kube kubernetes.Interface, namespace string) (*AccessImpl, error)

+ func (a *AccessImpl) GetServiceAccounts() (*corev1.ServiceAccountList, error)

+ type Certificate interface

+ DeleteCsr func(name string) error

+ ListCsr func() (*v1cert.CertificateSigningRequestList, error)

+ type CertificateImpl struct

+ func NewCertificateClient(kube kubernetes.Interface) (*CertificateImpl, error)

+ func (c *CertificateImpl) DeleteCsr(name string) error

+ func (c *CertificateImpl) ListCsr() (*v1cert.CertificateSigningRequestList, error)

+ type Cluster interface

+ GetCurrentContext func() (string, error)

+ GetHostCaCert func() ([]byte, error)

+ GetHostServer func() (string, error)

+ type ClusterImpl struct

+ func NewClusterClient(config []byte) (*ClusterImpl, error)

+ func (c *ClusterImpl) GetCurrentContext() (string, error)

+ func (c *ClusterImpl) GetHostCaCert() ([]byte, error)

+ func (c *ClusterImpl) GetHostServer() (string, error)

+ type Configuration interface

+ CreateDockerSecret func(namespace, secretName string, data map[string]string) error

+ CreateSecret func(namespace, secretName string, data map[string][]byte) error

+ CreateTlSSecret func(namespace, secretName string, data map[string][]byte, immutable bool) error

+ DeleteSecret func(namespace, secretName string) error

+ GetSecret func(namespace, secretName string) (*corev1.Secret, error)

+ ListSecrets func(namespace string) (*corev1.SecretList, error)

+ UpdateSecret func(namespace, secretName string, data map[string][]byte) error

+ UpdateTLSSecret func(namespace, secretName string, data map[string][]byte, ...) error

+ type ConfigurationImpl struct

+ func NewConfigurationClient(kube kubernetes.Interface) (*ConfigurationImpl, error)

+ func (c *ConfigurationImpl) CreateDockerSecret(namespace, secretName string, data map[string]string) error

+ func (c *ConfigurationImpl) CreateSecret(namespace, secretName string, data map[string][]byte) error

+ func (c *ConfigurationImpl) CreateTlSSecret(namespace, secretName string, data map[string][]byte, immutable bool) error

+ func (c *ConfigurationImpl) DeleteSecret(namespace, secretName string) error

+ func (c *ConfigurationImpl) GetSecret(namespace, secretName string) (*corev1.Secret, error)

+ func (c *ConfigurationImpl) ListSecrets(namespace string) (*corev1.SecretList, error)

+ func (c *ConfigurationImpl) UpdateSecret(namespace, secretName string, data map[string][]byte) error

+ func (c *ConfigurationImpl) UpdateTLSSecret(namespace, secretName string, data map[string][]byte, ...) error

+ type Kube struct

+ func New(clientSet *kubernetes.Clientset, restConfig *rest.Config, config []byte, ...) (*Kube, error)

+ func NewConfigBasedKube(config []byte, ns string) (*Kube, error)

+ func NewInClusterKube(ns string) (*Kube, error)

+ func (k *Kube) Access() Access

+ func (k *Kube) Certificate() Certificate

+ func (k *Kube) Cluster() Cluster

+ func (k *Kube) Configuration() Configuration

+ func (k *Kube) Namespaces() Namespace

+ func (k *Kube) Nodes() Nodes

+ func (k *Kube) Storage() Storage

+ func (k *Kube) Util() Util

+ func (k *Kube) V1Alpha1() V1Alpha1

+ func (k *Kube) Workload() Workload

+ type KubeClient interface

+ Access func() Access

+ Certificate func() Certificate

+ Cluster func() Cluster

+ Configuration func() Configuration

+ Namespaces func() Namespace

+ Nodes func() Nodes

+ Storage func() Storage

+ Util func() Util

+ V1Alpha1 func() V1Alpha1

+ Workload func() Workload

+ func CreateKubeClient(OutOfClusterKube bool) (KubeClient, error)

+ func FakeKubeClient(ns string) (KubeClient, error)

+ func NewKubeClient(cfg []byte, ns string) (KubeClient, error)

+ type Namespace interface

+ Create func(namespace string) error

+ Delete func(namespace string) error

+ List func() (*corev1.NamespaceList, error)

+ type NamespaceImpl struct

+ func NewNamespaceClient(kube kubernetes.Interface) (*NamespaceImpl, error)

+ func (n *NamespaceImpl) Create(namespace string) error

+ func (n *NamespaceImpl) Delete(namespace string) error

+ func (n *NamespaceImpl) List() (*corev1.NamespaceList, error)

+ type Nodes interface

+ List func() (*corev1.NodeList, error)

+ type NodesImpl struct

+ func NewNodesClient(kube kubernetes.Interface) (*NodesImpl, error)

+ func (n *NodesImpl) List() (*corev1.NodeList, error)

+ type ServiceMapping interface

+ Create func(mapping *v1alpha.Mapping) (*v1alpha.Mapping, error)

+ CreateInCluster func() (bool, error)

+ Get func(name string) (*v1alpha.Mapping, error)

+ GetDefinition func(name string) (*apiextensionv1.CustomResourceDefinition, error)

+ List func() (*v1alpha.MappingList, error)

+ Parse func(services []v1alpha.Service, name, ns string) (*v1alpha.Mapping, error)

+ Update func(mapping *v1alpha.Mapping) (*v1alpha.Mapping, error)

+ type ServiceMappingsImpl struct

+ Client rest.Interface

+ ExtensionClient clientset.Interface

+ func NewFakeServiceMappingImpl() (*ServiceMappingsImpl, error)

+ func NewServiceMappingImpl(restConfig *rest.Config) (*ServiceMappingsImpl, error)

+ func (s *ServiceMappingsImpl) Create(mapping *v1alpha.Mapping) (*v1alpha.Mapping, error)

+ func (s *ServiceMappingsImpl) CreateInCluster() (bool, error)

+ func (s *ServiceMappingsImpl) Get(name string) (*v1alpha.Mapping, error)

+ func (s *ServiceMappingsImpl) GetDefinition(name string) (*apiextensionv1.CustomResourceDefinition, error)

+ func (s *ServiceMappingsImpl) List() (*v1alpha.MappingList, error)

+ func (s *ServiceMappingsImpl) Parse(services []v1alpha.Service, name, ns string) (*v1alpha.Mapping, error)

+ func (s *ServiceMappingsImpl) Update(mapping *v1alpha.Mapping) (*v1alpha.Mapping, error)

+ type Storage interface

+ DeletePv func(name string) error

+ DeletePvc func(namespace, name string) error

+ ListPv func() (*corev1.PersistentVolumeList, error)

+ ListPvc func(namespace string) (*corev1.PersistentVolumeClaimList, error)

+ type StorageImpl struct

+ func NewStorageClient(kube kubernetes.Interface) (*StorageImpl, error)

+ func (s *StorageImpl) DeletePv(name string) error

+ func (s *StorageImpl) DeletePvc(namespace, name string) error

+ func (s *StorageImpl) ListPv() (*corev1.PersistentVolumeList, error)

+ func (s *StorageImpl) ListPvc(namespace string) (*corev1.PersistentVolumeClaimList, error)

+ type Util interface

+ CopyFileFromPod func(srcPath, destPath, namespace, podName string) error

+ CopyFileToPod func(podName, destPath, srcPath string) (string, error)

+ type UtilImpl struct

+ func NewUtilClient(kube kubernetes.Interface, namespace string) (*UtilImpl, error)

+ func (c *UtilImpl) CopyFileFromPod(srcPath, destPath, namespace, podName string) error

+ func (c *UtilImpl) CopyFileToPod(podName, destPath, srcPath string) (string, error)

+ type V1Alpha1 interface

+ ServiceMapping func() ServiceMapping

+ type V1Alpha1Impl struct

+ func NewV1AlphaClient(restConfig *rest.Config) (*V1Alpha1Impl, error)

+ func NewV1FakeAlphaClient() (*V1Alpha1Impl, error)

+ func (v *V1Alpha1Impl) ServiceMapping() ServiceMapping

+ type Workload interface

+ CreateDeployment func(namespace string, deployment *appsv1.Deployment) (*appsv1.Deployment, error)

+ CreateJob func(namespace string, spec *batchv1.Job) (*batchv1.Job, error)

+ CreatePod func(namespace string, pod *corev1.Pod) (*corev1.Pod, error)

+ CreatePodSpec func(namespace, name, podImage string, command []string) *corev1.Pod

+ DeletePod func(namespace, podName string) error

+ ExecNamedPod func(namespace, podName string, command []string) (string, error)

+ GetDeployment func(namespace, name string) (*appsv1.Deployment, error)

+ GetDeploymentStatus func(namespace string) (bool, error)

+ GetJob func(namespace, name string) (*batchv1.Job, error)

+ GetNewLock func(lockName, podName, namespace string) *resourcelock.LeaseLock

+ GetPodByName func(namespace, name string) (*corev1.Pod, error)

+ GetPodsBySelector func(namespace, selector string) (*corev1.PodList, error)

+ GetStatefulSets func(namespace string) (*appsv1.StatefulSetList, error)

+ List func(namespace string) (*corev1.PodList, error)

+ ListDeployments func(namespace string) (*appsv1.DeploymentList, error)

+ ListJobs func(namespace string) (*batchv1.JobList, error)

+ UpdateDeploymentViaAnnotation func(namespace, name string, annotation map[string]string) (*appsv1.Deployment, error)

+ type WorkloadImpl struct

+ func NewWorkloadClient(kube kubernetes.Interface) (*WorkloadImpl, error)

+ func (w *WorkloadImpl) CreateDeployment(namespace string, deployment *appsv1.Deployment) (*appsv1.Deployment, error)

+ func (w *WorkloadImpl) CreateJob(namespace string, spec *batchv1.Job) (*batchv1.Job, error)

+ func (w *WorkloadImpl) CreatePod(namespace string, pod *corev1.Pod) (*corev1.Pod, error)

+ func (w *WorkloadImpl) CreatePodSpec(namespace, name, podImage string, command []string) *corev1.Pod

+ func (w *WorkloadImpl) DeletePod(namespace, podName string) error

+ func (w *WorkloadImpl) ExecNamedPod(namespace, podName string, command []string) (string, error)

+ func (w *WorkloadImpl) GetDeployment(namespace, name string) (*appsv1.Deployment, error)

+ func (w *WorkloadImpl) GetDeploymentStatus(namespace string) (bool, error)

+ func (w *WorkloadImpl) GetJob(namespace, name string) (*batchv1.Job, error)

+ func (w *WorkloadImpl) GetNewLock(lockName, podName, namespace string) *resourcelock.LeaseLock

+ func (w *WorkloadImpl) GetPodByName(namespace, name string) (*corev1.Pod, error)

+ func (w *WorkloadImpl) GetPodsBySelector(namespace, selector string) (*corev1.PodList, error)

+ func (w *WorkloadImpl) GetStatefulSets(namespace string) (*appsv1.StatefulSetList, error)

+ func (w *WorkloadImpl) List(namespace string) (*corev1.PodList, error)

+ func (w *WorkloadImpl) ListDeployments(namespace string) (*appsv1.DeploymentList, error)

+ func (w *WorkloadImpl) ListJobs(namespace string) (*batchv1.JobList, error)

+ func (w *WorkloadImpl) UpdateDeploymentViaAnnotation(namespace, name string, annotation map[string]string) (*appsv1.Deployment, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL