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

k8s

package

Go to main page

Versions in this module

v1

v1.0.0

Feb 24, 2020

Changes in this version

+ func GetRedisPassword(s Services, rf *redisfailoverv1.RedisFailover) (string, error)

+ type CRD interface

+ EnsureCRD func(conf CRDConf) error

+ type CRDConf = crd.Conf

+ type CRDService struct

+ func NewCRDService(aeClient apiextensionscli.Interface, logger log.Logger) *CRDService

+ func (c *CRDService) EnsureCRD(conf CRDConf) error

+ type ConfigMap interface

+ CreateConfigMap func(namespace string, configMap *corev1.ConfigMap) error

+ CreateOrUpdateConfigMap func(namespace string, np *corev1.ConfigMap) error

+ DeleteConfigMap func(namespace string, name string) error

+ GetConfigMap func(namespace string, name string) (*corev1.ConfigMap, error)

+ ListConfigMaps func(namespace string) (*corev1.ConfigMapList, error)

+ UpdateConfigMap func(namespace string, configMap *corev1.ConfigMap) error

+ type ConfigMapService struct

+ func NewConfigMapService(kubeClient kubernetes.Interface, logger log.Logger) *ConfigMapService

+ func (p *ConfigMapService) CreateConfigMap(namespace string, configMap *corev1.ConfigMap) error

+ func (p *ConfigMapService) CreateOrUpdateConfigMap(namespace string, configMap *corev1.ConfigMap) error

+ func (p *ConfigMapService) DeleteConfigMap(namespace string, name string) error

+ func (p *ConfigMapService) GetConfigMap(namespace string, name string) (*corev1.ConfigMap, error)

+ func (p *ConfigMapService) ListConfigMaps(namespace string) (*corev1.ConfigMapList, error)

+ func (p *ConfigMapService) UpdateConfigMap(namespace string, configMap *corev1.ConfigMap) error

+ type Deployment interface

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

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

+ DeleteDeployment func(namespace string, name string) error

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

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

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

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

+ type DeploymentService struct

+ func NewDeploymentService(kubeClient kubernetes.Interface, logger log.Logger) *DeploymentService

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

+ func (d *DeploymentService) CreateOrUpdateDeployment(namespace string, deployment *appsv1.Deployment) error

+ func (d *DeploymentService) DeleteDeployment(namespace, name string) error

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

+ func (d *DeploymentService) GetDeploymentPods(namespace, name string) (*corev1.PodList, error)

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

+ func (d *DeploymentService) UpdateDeployment(namespace string, deployment *appsv1.Deployment) error

+ type Pod interface

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

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

+ DeletePod func(namespace string, name string) error

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

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

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

+ type PodDisruptionBudget interface

+ CreateOrUpdatePodDisruptionBudget func(namespace string, podDisruptionBudget *policyv1beta1.PodDisruptionBudget) error

+ CreatePodDisruptionBudget func(namespace string, podDisruptionBudget *policyv1beta1.PodDisruptionBudget) error

+ DeletePodDisruptionBudget func(namespace string, name string) error

+ GetPodDisruptionBudget func(namespace string, name string) (*policyv1beta1.PodDisruptionBudget, error)

+ UpdatePodDisruptionBudget func(namespace string, podDisruptionBudget *policyv1beta1.PodDisruptionBudget) error

+ type PodDisruptionBudgetService struct

+ func NewPodDisruptionBudgetService(kubeClient kubernetes.Interface, logger log.Logger) *PodDisruptionBudgetService

+ func (p *PodDisruptionBudgetService) CreateOrUpdatePodDisruptionBudget(namespace string, podDisruptionBudget *policyv1beta1.PodDisruptionBudget) error

+ func (p *PodDisruptionBudgetService) CreatePodDisruptionBudget(namespace string, podDisruptionBudget *policyv1beta1.PodDisruptionBudget) error

+ func (p *PodDisruptionBudgetService) DeletePodDisruptionBudget(namespace string, name string) error

+ func (p *PodDisruptionBudgetService) GetPodDisruptionBudget(namespace string, name string) (*policyv1beta1.PodDisruptionBudget, error)

+ func (p *PodDisruptionBudgetService) UpdatePodDisruptionBudget(namespace string, podDisruptionBudget *policyv1beta1.PodDisruptionBudget) error

+ type PodService struct

+ func NewPodService(kubeClient kubernetes.Interface, logger log.Logger) *PodService

+ func (p *PodService) CreateOrUpdatePod(namespace string, pod *corev1.Pod) error

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

+ func (p *PodService) DeletePod(namespace string, name string) error

+ func (p *PodService) GetPod(namespace string, name string) (*corev1.Pod, error)

+ func (p *PodService) ListPods(namespace string) (*corev1.PodList, error)

+ func (p *PodService) UpdatePod(namespace string, pod *corev1.Pod) error

+ type RBAC interface

+ CreateOrUpdateRole func(namespace string, binding *rbacv1.Role) error

+ CreateOrUpdateRoleBinding func(namespace string, binding *rbacv1.RoleBinding) error

+ CreateRole func(namespace string, tole *rbacv1.Role) error

+ CreateRoleBinding func(namespace string, binding *rbacv1.RoleBinding) error

+ GetClusterRole func(name string) (*rbacv1.ClusterRole, error)

+ GetRole func(namespace, name string) (*rbacv1.Role, error)

+ GetRoleBinding func(namespace, name string) (*rbacv1.RoleBinding, error)

+ UpdateRole func(namespace string, role *rbacv1.Role) error

+ UpdateRoleBinding func(namespace string, binding *rbacv1.RoleBinding) error

+ type RBACService struct

+ func NewRBACService(kubeClient kubernetes.Interface, logger log.Logger) *RBACService

+ func (r *RBACService) CreateOrUpdateRole(namespace string, role *rbacv1.Role) error

+ func (r *RBACService) CreateOrUpdateRoleBinding(namespace string, binding *rbacv1.RoleBinding) error

+ func (r *RBACService) CreateRole(namespace string, role *rbacv1.Role) error

+ func (r *RBACService) CreateRoleBinding(namespace string, binding *rbacv1.RoleBinding) error

+ func (r *RBACService) DeleteRole(namespace, name string) error

+ func (r *RBACService) DeleteRoleBinding(namespace, name string) error

+ func (r *RBACService) GetClusterRole(name string) (*rbacv1.ClusterRole, error)

+ func (r *RBACService) GetRole(namespace, name string) (*rbacv1.Role, error)

+ func (r *RBACService) GetRoleBinding(namespace, name string) (*rbacv1.RoleBinding, error)

+ func (r *RBACService) UpdateRoleBinding(namespace string, binding *rbacv1.RoleBinding) error

+ func (s *RBACService) UpdateRole(namespace string, role *rbacv1.Role) error

+ type RedisFailover interface

+ ListRedisFailovers func(namespace string, opts metav1.ListOptions) (*redisfailoverv1.RedisFailoverList, error)

+ WatchRedisFailovers func(namespace string, opts metav1.ListOptions) (watch.Interface, error)

+ type RedisFailoverService struct

+ func NewRedisFailoverService(crdcli redisfailoverclientset.Interface, logger log.Logger) *RedisFailoverService

+ func (r *RedisFailoverService) ListRedisFailovers(namespace string, opts metav1.ListOptions) (*redisfailoverv1.RedisFailoverList, error)

+ func (r *RedisFailoverService) WatchRedisFailovers(namespace string, opts metav1.ListOptions) (watch.Interface, error)

+ type Secret interface

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

+ type SecretService struct

+ func NewSecretService(kubeClient kubernetes.Interface, logger log.Logger) *SecretService

+ func (s *SecretService) GetSecret(namespace, name string) (*corev1.Secret, error)

+ type Service interface

+ CreateIfNotExistsService func(namespace string, service *corev1.Service) error

+ CreateOrUpdateService func(namespace string, service *corev1.Service) error

+ CreateService func(namespace string, service *corev1.Service) error

+ DeleteService func(namespace string, name string) error

+ GetService func(namespace string, name string) (*corev1.Service, error)

+ ListServices func(namespace string) (*corev1.ServiceList, error)

+ UpdateService func(namespace string, service *corev1.Service) error

+ type ServiceService struct

+ func NewServiceService(kubeClient kubernetes.Interface, logger log.Logger) *ServiceService

+ func (s *ServiceService) CreateIfNotExistsService(namespace string, service *corev1.Service) error

+ func (s *ServiceService) CreateOrUpdateService(namespace string, service *corev1.Service) error

+ func (s *ServiceService) CreateService(namespace string, service *corev1.Service) error

+ func (s *ServiceService) DeleteService(namespace string, name string) error

+ func (s *ServiceService) GetService(namespace string, name string) (*corev1.Service, error)

+ func (s *ServiceService) ListServices(namespace string) (*corev1.ServiceList, error)

+ func (s *ServiceService) UpdateService(namespace string, service *corev1.Service) error

+ type Services interface

+ func New(kubecli kubernetes.Interface, crdcli redisfailoverclientset.Interface, ...) Services

+ type StatefulSet interface

+ CreateOrUpdateStatefulSet func(namespace string, statefulSet *appsv1.StatefulSet) error

+ CreateStatefulSet func(namespace string, statefulSet *appsv1.StatefulSet) error

+ DeleteStatefulSet func(namespace string, name string) error

+ GetStatefulSet func(namespace, name string) (*appsv1.StatefulSet, error)

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

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

+ UpdateStatefulSet func(namespace string, statefulSet *appsv1.StatefulSet) error

+ type StatefulSetService struct

+ func NewStatefulSetService(kubeClient kubernetes.Interface, logger log.Logger) *StatefulSetService

+ func (s *StatefulSetService) CreateOrUpdateStatefulSet(namespace string, statefulSet *appsv1.StatefulSet) error

+ func (s *StatefulSetService) CreateStatefulSet(namespace string, statefulSet *appsv1.StatefulSet) error

+ func (s *StatefulSetService) DeleteStatefulSet(namespace, name string) error

+ func (s *StatefulSetService) GetStatefulSet(namespace, name string) (*appsv1.StatefulSet, error)

+ func (s *StatefulSetService) GetStatefulSetPods(namespace, name string) (*corev1.PodList, error)

+ func (s *StatefulSetService) ListStatefulSets(namespace string) (*appsv1.StatefulSetList, error)

+ func (s *StatefulSetService) UpdateStatefulSet(namespace string, statefulSet *appsv1.StatefulSet) error

v1.0.0-rc.5

Feb 7, 2020

v1.0.0-rc.4

Dec 17, 2019

v1.0.0-rc.3

Dec 11, 2019

v1.0.0-rc.2

Nov 15, 2019

v1.0.0-rc.1

May 10, 2019