kube

Documentation

Index

• func AppendConfigVolume(volumes *[]corev1.Volume, mounts *[]corev1.VolumeMount, name string, ...)
• func AppendSecretVolume(volumes *[]corev1.Volume, mounts *[]corev1.VolumeMount, name string, ...)
• func ContainerForController(ds types.DeploymentSpec) corev1.Container
• func ContainerForTransport(ds types.DeploymentSpec) corev1.Container
• func DeleteDeployment(name string, namespace string, cli *kubernetes.Clientset) error
• func DeleteSecret(name string, namespace string, cli *kubernetes.Clientset) error
• func DeleteService(name string, namespace string, kubeclient *kubernetes.Clientset) error
• func FindEnvVar(env []corev1.EnvVar, name string) *corev1.EnvVar
• func FirstReadyPod(list []corev1.Pod) *corev1.Pod
• func GetComponentVersion(namespace string, clientset *kubernetes.Clientset, component string) string
• func GetConfigMap(name string, namespace string, cli *kubernetes.Clientset) (*corev1.ConfigMap, error)
• func GetDeployment(name string, namespace string, cli *kubernetes.Clientset) (*appsv1.Deployment, error)
• func GetImageVersion(pod *corev1.Pod, container string) string
• func GetLoadBalancerHostOrIP(service *corev1.Service) string
• func GetOwnerReference(dep *appsv1.Deployment) metav1.OwnerReference
• func GetReadyPod(namespace string, clientset *kubernetes.Clientset, component string) (*corev1.Pod, error)
• func GetRoute(name string, namespace string, rc *routev1client.RouteV1Client) (*routev1.Route, error)
• func GetService(name string, namespace string, kubeclient *kubernetes.Clientset) (*corev1.Service, error)
• func IsPodReady(pod *corev1.Pod) bool
• func IsPodRunning(pod *corev1.Pod) bool
• func NewCertAuthorityWithOwner(ca types.CertAuthority, owner metav1.OwnerReference, namespace string, ...) (*corev1.Secret, error)
• func NewConfigMapWithOwner(name string, owner metav1.OwnerReference, namespace string, ...) (*corev1.ConfigMap, error)
• func NewControllerDeployment(van *types.VanRouterSpec, ownerRef metav1.OwnerReference, ...) (*appsv1.Deployment, error)
• func NewProxyDeployment(serviceInterface types.ServiceInterface, namespace string, ...) (*appsv1.Deployment, error)
• func NewProxyStatefulSet(serviceInterface types.ServiceInterface, namespace string, ...) (*appsv1.StatefulSet, error)
• func NewRoleBindingWithOwner(rb types.RoleBinding, owner metav1.OwnerReference, namespace string, ...) (*rbacv1.RoleBinding, error)
• func NewRoleWithOwner(newrole types.Role, owner metav1.OwnerReference, namespace string, ...) (*rbacv1.Role, error)
• func NewRouteWithOwner(rte types.Route, owner metav1.OwnerReference, namespace string, ...) (*routev1.Route, error)
• func NewSecretWithOwner(cred types.Credential, owner metav1.OwnerReference, namespace string, ...) (*corev1.Secret, error)
• func NewServiceAccountWithOwner(sa types.ServiceAccount, owner metav1.OwnerReference, namespace string, ...) (*corev1.ServiceAccount, error)
• func NewServiceForProxy(desiredService types.ServiceInterface, namespace string, ...) (*corev1.Service, error)
• func NewServiceWithOwner(svc types.Service, owner metav1.OwnerReference, namespace string, ...) (*corev1.Service, error)
• func NewTransportDeployment(van *types.VanRouterSpec, cli *kubernetes.Clientset) (*appsv1.Deployment, error)
• func RemoveSecretVolumeForDeployment(name string, dep *appsv1.Deployment, index int)
• func SetEnvVarForDeployment(dep *appsv1.Deployment, name string, value string)
• func UpdateConfigMapForHeadlessServiceInterface(serviceName string, headless types.Headless, port int, ...) error
• func UpdateConfigMapForServiceInterface(serviceName string, targetName string, selector string, port int, ...) error
• func UpdateSkupperServices(changed []types.ServiceInterface, deleted []string, origin string, ...) error

Functions

func AppendConfigVolume

func AppendConfigVolume(volumes *[]corev1.Volume, mounts *[]corev1.VolumeMount, name string, path string)

func AppendSecretVolume

func AppendSecretVolume(volumes *[]corev1.Volume, mounts *[]corev1.VolumeMount, name string, path string)

func ContainerForController

func ContainerForController(ds types.DeploymentSpec) corev1.Container

TODO - remove constants, get from spec

func ContainerForTransport

func ContainerForTransport(ds types.DeploymentSpec) corev1.Container

func DeleteDeployment

func DeleteDeployment(name string, namespace string, cli *kubernetes.Clientset) error

func DeleteSecret

func DeleteSecret(name string, namespace string, cli *kubernetes.Clientset) error

func DeleteService

func DeleteService(name string, namespace string, kubeclient *kubernetes.Clientset) error

func FindEnvVar

func FindEnvVar(env []corev1.EnvVar, name string) *corev1.EnvVar

func FirstReadyPod

func FirstReadyPod(list []corev1.Pod) *corev1.Pod

func GetComponentVersion

func GetComponentVersion(namespace string, clientset *kubernetes.Clientset, component string) string

func GetConfigMap

func GetConfigMap(name string, namespace string, cli *kubernetes.Clientset) (*corev1.ConfigMap, error)

func GetDeployment

func GetDeployment(name string, namespace string, cli *kubernetes.Clientset) (*appsv1.Deployment, error)

TODO, pass full client object with namespace and clientset

func GetImageVersion

func GetImageVersion(pod *corev1.Pod, container string) string

func GetLoadBalancerHostOrIP

func GetLoadBalancerHostOrIP(service *corev1.Service) string

func GetOwnerReference

func GetOwnerReference(dep *appsv1.Deployment) metav1.OwnerReference

func GetReadyPod

func GetReadyPod(namespace string, clientset *kubernetes.Clientset, component string) (*corev1.Pod, error)

func GetRoute

func GetRoute(name string, namespace string, rc *routev1client.RouteV1Client) (*routev1.Route, error)

func GetService

func GetService(name string, namespace string, kubeclient *kubernetes.Clientset) (*corev1.Service, error)

func IsPodReady

func IsPodReady(pod *corev1.Pod) bool

func IsPodRunning

func IsPodRunning(pod *corev1.Pod) bool

func NewCertAuthorityWithOwner

func NewCertAuthorityWithOwner(ca types.CertAuthority, owner metav1.OwnerReference, namespace string, cli *kubernetes.Clientset) (*corev1.Secret, error)

func NewConfigMapWithOwner

func NewConfigMapWithOwner(name string, owner metav1.OwnerReference, namespace string, kubeclient *kubernetes.Clientset) (*corev1.ConfigMap, error)

func NewControllerDeployment

func NewControllerDeployment(van *types.VanRouterSpec, ownerRef metav1.OwnerReference, cli *kubernetes.Clientset) (*appsv1.Deployment, error)

func NewProxyDeployment

func NewProxyDeployment(serviceInterface types.ServiceInterface, namespace string, cli *kubernetes.Clientset) (*appsv1.Deployment, error)

func NewProxyStatefulSet

func NewProxyStatefulSet(serviceInterface types.ServiceInterface, namespace string, cli *kubernetes.Clientset) (*appsv1.StatefulSet, error)

func NewRoleBindingWithOwner

func NewRoleBindingWithOwner(rb types.RoleBinding, owner metav1.OwnerReference, namespace string, kubeclient *kubernetes.Clientset) (*rbacv1.RoleBinding, error)

func NewRoleWithOwner

func NewRoleWithOwner(newrole types.Role, owner metav1.OwnerReference, namespace string, kubeclient *kubernetes.Clientset) (*rbacv1.Role, error)

func NewRouteWithOwner

func NewRouteWithOwner(rte types.Route, owner metav1.OwnerReference, namespace string, rc *routev1client.RouteV1Client) (*routev1.Route, error)

func NewSecretWithOwner

func NewSecretWithOwner(cred types.Credential, owner metav1.OwnerReference, namespace string, cli *kubernetes.Clientset) (*corev1.Secret, error)

func NewServiceAccountWithOwner

func NewServiceAccountWithOwner(sa types.ServiceAccount, owner metav1.OwnerReference, namespace string, cli *kubernetes.Clientset) (*corev1.ServiceAccount, error)

func NewServiceForProxy

func NewServiceForProxy(desiredService types.ServiceInterface, namespace string, kubeclient *kubernetes.Clientset) (*corev1.Service, error)

func NewServiceWithOwner

func NewServiceWithOwner(svc types.Service, owner metav1.OwnerReference, namespace string, kubeclient *kubernetes.Clientset) (*corev1.Service, error)

func NewTransportDeployment

func NewTransportDeployment(van *types.VanRouterSpec, cli *kubernetes.Clientset) (*appsv1.Deployment, error)

func RemoveSecretVolumeForDeployment

func RemoveSecretVolumeForDeployment(name string, dep *appsv1.Deployment, index int)

func SetEnvVarForDeployment

func SetEnvVarForDeployment(dep *appsv1.Deployment, name string, value string)

func UpdateConfigMapForHeadlessServiceInterface

func UpdateConfigMapForHeadlessServiceInterface(serviceName string, headless types.Headless, port int, options types.VanServiceInterfaceCreateOptions, owner *metav1.OwnerReference, namespace string, cli *kubernetes.Clientset) error

func UpdateConfigMapForServiceInterface

func UpdateConfigMapForServiceInterface(serviceName string, targetName string, selector string, port int, options types.VanServiceInterfaceCreateOptions, owner *metav1.OwnerReference, namespace string, cli *kubernetes.Clientset) error

func UpdateSkupperServices

func UpdateSkupperServices(changed []types.ServiceInterface, deleted []string, origin string, namespace string, cli *kubernetes.Clientset) error