service

Documentation

Index

• func CheckService(namespace string, service string) error
• func CreateSecret(namespace, name string, dataValues map[string]string, labels map[string]string) error
• func DeleteSecret(namespace, name string) error
• func GetServiceListByLabel(namespace string, key string, value string) (*v1.ServiceList, error)
• func GetServiceURLsForService(api libmachine.API, namespace, service string, t *template.Template) ([]string, error)
• func WaitAndMaybeOpenService(api libmachine.API, namespace string, service string, ...) error
• type K8sClient
• type K8sClientGetter
  • func (*K8sClientGetter) GetClientset() (*kubernetes.Clientset, error)
  • func (k *K8sClientGetter) GetCoreClient() (corev1.CoreV1Interface, error)
• type ServiceURL
• type ServiceURLs
  • func GetServiceURLs(api libmachine.API, namespace string, t *template.Template) (ServiceURLs, error)

Functions

func CheckService

func CheckService(namespace string, service string) error

CheckService waits for the specified service to be ready by returning an error until the service is up The check is done by polling the endpoint associated with the service and when the endpoint exists, returning no error->service-online

func CreateSecret

func CreateSecret(namespace, name string, dataValues map[string]string, labels map[string]string) error

CreateSecret creates or modifies secrets

func DeleteSecret

func DeleteSecret(namespace, name string) error

DeleteSecret deletes a secret from a namespace

func GetServiceListByLabel

func GetServiceListByLabel(namespace string, key string, value string) (*v1.ServiceList, error)

func GetServiceURLsForService

func GetServiceURLsForService(api libmachine.API, namespace, service string, t *template.Template) ([]string, error)

Returns all the node ports for a service in a namespace with optional formatting

func WaitAndMaybeOpenService

func WaitAndMaybeOpenService(api libmachine.API, namespace string, service string, urlTemplate *template.Template, urlMode bool, https bool,
	wait int, interval int) error

Types

type K8sClient

type K8sClient interface {
	GetCoreClient() (corev1.CoreV1Interface, error)
	GetClientset() (*kubernetes.Clientset, error)
}

var K8s K8sClient

type K8sClientGetter

type K8sClientGetter struct{}

func (*K8sClientGetter) GetClientset

func (*K8sClientGetter) GetClientset() (*kubernetes.Clientset, error)

func (*K8sClientGetter) GetCoreClient

func (k *K8sClientGetter) GetCoreClient() (corev1.CoreV1Interface, error)

type ServiceURL

type ServiceURL struct {
	Namespace string
	Name      string
	URLs      []string
}

type ServiceURLs

type ServiceURLs []ServiceURL

func GetServiceURLs

func GetServiceURLs(api libmachine.API, namespace string, t *template.Template) (ServiceURLs, error)

Returns all the node port URLs for every service in a particular namespace Accepts a template for formating