kubeclient

Documentation

Index

• Constants
• Variables
• func BootstrapVampService(configPath string) (string, string, string, error)
• func CheckAndWaitForService(url string, cert []byte) error
• func CreateOrUpdateDeployment(clientset *kubernetes.Clientset, ns string, deployment *appsv1.Deployment) error
• func CreateOrUpdateOpaqueSecret(clientset *kubernetes.Clientset, ns string, name string, ...) error
• func CreateOrUpdateSecret(clientset *kubernetes.Clientset, ns string, secret *apiv1.Secret) error
• func CreateOrUpdateService(clientset *kubernetes.Clientset, ns string, service *apiv1.Service) error
• func CreateOrUpdateStatefulSet(clientset *kubernetes.Clientset, ns string, statefulSet *appsv1.StatefulSet) error
• func GetKubeConfigPath(configPath string) *string
• func GetOpaqueSecret(clientset *kubernetes.Clientset, ns string, name string) (map[string][]byte, error)
• func GetServiceExternalIP(clientset *kubernetes.Clientset, ns string, name string) (string, error)
• func InstallMongoDB(clientset *kubernetes.Clientset, ns string) error
• func InstallVamp(clientset *kubernetes.Clientset, ns string, config *models.VampConfig) (*string, []byte, []byte, error)
• func InstallVampService(config *models.VampConfig, configPath string) (string, []byte, []byte, error)
• func SetupVampCredentials(clientset *kubernetes.Clientset, ns string) error
• func VampConfigValidateAndSetupDefaults(config *models.VampConfig) (*models.VampConfig, error)

Constants

const InstallationNamespace = "vamp-system"

This is shared between installation and credentials, it is currently not configurable TODO: add it to VampConfig when it is configurable

Variables

var DefaultVampConfig = models.VampConfig{
	DatabaseName:          "vamp",
	ImageName:             "magneticio/vampkubist",
	ImageTag:              "0.7.8",
	Mode:                  "IN_CLUSTER",
	AccessTokenExpiration: "10m",
}

Golang does't support struct constants Default values for an installation config

Functions

func BootstrapVampService

func BootstrapVampService(configPath string) (string, string, string, error)

func CheckAndWaitForService

func CheckAndWaitForService(url string, cert []byte) error

func CreateOrUpdateDeployment

func CreateOrUpdateDeployment(clientset *kubernetes.Clientset, ns string, deployment *appsv1.Deployment) error

func CreateOrUpdateOpaqueSecret

func CreateOrUpdateOpaqueSecret(clientset *kubernetes.Clientset, ns string, name string, data map[string][]byte) error

func CreateOrUpdateSecret

func CreateOrUpdateSecret(clientset *kubernetes.Clientset, ns string, secret *apiv1.Secret) error

func CreateOrUpdateService

func CreateOrUpdateService(clientset *kubernetes.Clientset, ns string, service *apiv1.Service) error

func CreateOrUpdateStatefulSet

func CreateOrUpdateStatefulSet(clientset *kubernetes.Clientset, ns string, statefulSet *appsv1.StatefulSet) error

func GetKubeConfigPath

func GetKubeConfigPath(configPath string) *string

Tries to detect kubeconfig path if it is not explicitly set

func GetOpaqueSecret

func GetOpaqueSecret(clientset *kubernetes.Clientset, ns string, name string) (map[string][]byte, error)

func GetServiceExternalIP

func GetServiceExternalIP(clientset *kubernetes.Clientset, ns string, name string) (string, error)

func InstallMongoDB

func InstallMongoDB(clientset *kubernetes.Clientset, ns string) error

func InstallVamp

func InstallVamp(clientset *kubernetes.Clientset, ns string, config *models.VampConfig) (*string, []byte, []byte, error)

func InstallVampService

func InstallVampService(config *models.VampConfig, configPath string) (string, []byte, []byte, error)

func SetupVampCredentials

func SetupVampCredentials(clientset *kubernetes.Clientset, ns string) error

This method installs namespace, cluster role binding and image pull secret TODO: differenciate between already exists and other error types

func VampConfigValidateAndSetupDefaults

func VampConfigValidateAndSetupDefaults(config *models.VampConfig) (*models.VampConfig, error)