Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

thales

package module

Go to main page

Versions in this module

v0

v0.2.1

Jul 3, 2023

v0.2.0

May 17, 2023

v0.1.7

May 1, 2023

v0.1.6

May 1, 2023

v0.1.5

May 1, 2023

v0.1.4

Apr 12, 2023

v0.1.3

Apr 14, 2023

v0.1.2

Apr 14, 2023

v0.1.1

Apr 12, 2023

Changes in this version

+ const EnvKubePath

+ const EnvNamespace

type KubeClient

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

v0.1.0

Apr 12, 2023

Changes in this version

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