k8sutil

Documentation

Index

• Constants
• 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 CreateJob(schema batchv1.Job, namespace string, config *rest.Config) (bool, error)
• func CreateKubeconfigSecret(name string, namespace string, kubeconfig []byte) (err 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 CreateSSHSecret(name string, namespace string, privateKey []byte) (err error)
• func CreateServiceAccount(schema corev1.ServiceAccount, namespace string, config *rest.Config) (bool, error)
• func DeleteKubeconfigSecret(name string, namespace string) (err error)
• func DeleteSSHSecret(name string, namespace string) (err error)
• func DeleteSecret(name string, namespace string) (err error)
• 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 GetKubeconfigSecret(name string, namespace string) (secret []byte, err error)
• func GetKubeconfigSecretList(namespace string) (result []corev1.Secret, err error)
• func GetSSHSecret(name string, namespace string) (secret []byte, err error)
• func GetSSHSecretList(namespace string) (result []corev1.Secret, err error)
• func GetSecret(name string, namespace string) (secret corev1.Secret, err error)
• func GetSecretList(namespace string, options v1.ListOptions) (result []corev1.Secret, err error)
• func IsResourceAlreadyExistsError(err error) bool
• func IsResourceNotFoundError(err error) bool
• func SetLogger()
• func WaitCRDReady(clientset apiextensionsclient.Interface, crdName string) error

Constants

const (
	SDSServiceAccountName = "sds-sa"
)

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 CreateJob

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

func CreateKubeconfigSecret

func CreateKubeconfigSecret(name string, namespace string, kubeconfig []byte) (err 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 CreateSSHSecret

func CreateSSHSecret(name string, namespace string, privateKey []byte) (err error)

func CreateServiceAccount

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

func DeleteKubeconfigSecret

func DeleteKubeconfigSecret(name string, namespace string) (err error)

func DeleteSSHSecret

func DeleteSSHSecret(name string, namespace string) (err error)

func DeleteSecret

func DeleteSecret(name string, namespace string) (err error)

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 GetKubeconfigSecret

func GetKubeconfigSecret(name string, namespace string) (secret []byte, err error)

func GetKubeconfigSecretList

func GetKubeconfigSecretList(namespace string) (result []corev1.Secret, err error)

func GetSSHSecret

func GetSSHSecret(name string, namespace string) (secret []byte, err error)

func GetSSHSecretList

func GetSSHSecretList(namespace string) (result []corev1.Secret, err error)

func GetSecret

func GetSecret(name string, namespace string) (secret corev1.Secret, err error)

func GetSecretList

func GetSecretList(namespace string, options v1.ListOptions) (result []corev1.Secret, err 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.