k8sutil

Documentation

Index

• Variables
• func CreateCRD(clientset apiextensionsclient.Interface, ...) error
• func CreateClusterRole(schema rbac.ClusterRole, config *rest.Config) (bool, error)
• func CreateClusterRoleBinding(schema rbac.ClusterRoleBinding, config *rest.Config) (bool, error)
• func CreateExternalService(schema corev1.Service, sdsCluster *v1alpha1.SDSCluster, config *rest.Config) (bool, error)
• func CreateIngress(schema v1beta1.Ingress, sdsCluster *v1alpha1.SDSCluster, config *rest.Config) (bool, error)
• func CreateJob(schema batchv1.Job, namespace string, config *rest.Config) (bool, error)
• func CreateNamespace(schema corev1.Namespace, config *rest.Config) (bool, error)
• func CreateRole(schema rbac.Role, namespace string, config *rest.Config) (bool, error)
• func CreateRoleBinding(schema rbac.RoleBinding, namespace string, config *rest.Config) (bool, error)
• func CreateSecret(name string, namespace string, sdsCluster *v1alpha1.SDSCluster, ...) error
• func CreateServiceAccount(schema corev1.ServiceAccount, namespace string, config *rest.Config) (bool, error)
• func DeleteSecret(name string, namespace string, config *rest.Config) error
• func GenerateExternalService(name string, externalName string) corev1.Service
• func GenerateIngress(name string, cluster string, service string) v1beta1.Ingress
• func GenerateJob(name string, jobSpec batchv1.JobSpec) batchv1.Job
• func GenerateKubernetesConfig() (*rest.Config, error)
• func GenerateNamespace(name string) corev1.Namespace
• func GenerateServiceAccount(name string) corev1.ServiceAccount
• func GenerateSingleClusterRolebinding(name string, subject string, subjectNamespace string, roleName string) rbac.ClusterRoleBinding
• func GenerateSingleRolebinding(name string, subject string, subjectNamespace string, roleName string) rbac.RoleBinding
• func GetClusterEndpoint(kubeconfig string) (string, error)
• func GetSecret(name string, namespace string, config *rest.Config) (corev1.Secret, error)
• func GetTokenNameFromServiceAccount(name string, namespace string, config *rest.Config) (string, error)
• func IsResourceAlreadyExistsError(err error) bool
• func IsResourceNotFoundError(err error) bool
• func SetLogger()
• func WaitCRDReady(clientset apiextensionsclient.Interface, crdName string) error

Variables

var (
	KubeConfigLocation string
	DefaultConfig      *rest.Config
)

Functions

func CreateCRD

func CreateCRD(clientset apiextensionsclient.Interface, crd apiextensionsv1beta1.CustomResourceDefinition) error

CreateCRD creates the objects in kubernetes

func CreateClusterRole

func CreateClusterRole(schema rbac.ClusterRole, config *rest.Config) (bool, error)

func CreateClusterRoleBinding

func CreateClusterRoleBinding(schema rbac.ClusterRoleBinding, config *rest.Config) (bool, error)

func CreateExternalService

func CreateExternalService(schema corev1.Service, sdsCluster *v1alpha1.SDSCluster, config *rest.Config) (bool, error)

func CreateIngress

func CreateIngress(schema v1beta1.Ingress, sdsCluster *v1alpha1.SDSCluster, config *rest.Config) (bool, error)

func CreateJob

func CreateJob(schema batchv1.Job, namespace string, config *rest.Config) (bool, error)

func CreateNamespace

func CreateNamespace(schema corev1.Namespace, config *rest.Config) (bool, error)

func CreateRole

func CreateRole(schema rbac.Role, namespace string, config *rest.Config) (bool, error)

func CreateRoleBinding

func CreateRoleBinding(schema rbac.RoleBinding, namespace string, config *rest.Config) (bool, error)

func CreateSecret

func CreateSecret(name string, namespace string, sdsCluster *v1alpha1.SDSCluster, dataKeyName string, secretData []byte, config *rest.Config) error

func CreateServiceAccount

func CreateServiceAccount(schema corev1.ServiceAccount, namespace string, config *rest.Config) (bool, error)

func DeleteSecret

func DeleteSecret(name string, namespace string, config *rest.Config) error

func GenerateExternalService

func GenerateExternalService(name string, externalName string) corev1.Service

func GenerateIngress

func GenerateIngress(name string, cluster string, service string) v1beta1.Ingress

func GenerateJob

func GenerateJob(name string, jobSpec batchv1.JobSpec) batchv1.Job

func GenerateKubernetesConfig

func GenerateKubernetesConfig() (*rest.Config, error)

func GenerateNamespace

func GenerateNamespace(name string) corev1.Namespace

func GenerateServiceAccount

func GenerateServiceAccount(name string) corev1.ServiceAccount

func GenerateSingleClusterRolebinding

func GenerateSingleClusterRolebinding(name string, subject string, subjectNamespace string, roleName string) rbac.ClusterRoleBinding

func GenerateSingleRolebinding

func GenerateSingleRolebinding(name string, subject string, subjectNamespace string, roleName string) rbac.RoleBinding

func GetClusterEndpoint

func GetClusterEndpoint(kubeconfig string) (string, error)

func GetSecret

func GetSecret(name string, namespace string, config *rest.Config) (corev1.Secret, error)

func GetTokenNameFromServiceAccount

func GetTokenNameFromServiceAccount(name string, namespace string, config *rest.Config) (string, error)

func IsResourceAlreadyExistsError

func IsResourceAlreadyExistsError(err error) bool

IsResourceAlreadyExistsError determines if error is an already exist type

func IsResourceNotFoundError

func IsResourceNotFoundError(err error) bool

IsResourceNotFoundError determines if error is of type not found

func SetLogger

func SetLogger()

func WaitCRDReady

func WaitCRDReady(clientset apiextensionsclient.Interface, crdName string) error

WaitCRDReady waits until proper condition is obtained.