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 OptionallyHTTPSFormattedURLString(bareURLString string, https bool) (string, bool)
• func WaitAndMaybeOpenService(api libmachine.API, namespace string, service string, ...) error
• type K8sClient
• type K8sClientGetter
  • func (*K8sClientGetter) GetClientset(timeout time.Duration) (*kubernetes.Clientset, error)
  • func (k *K8sClientGetter) GetCoreClient() (corev1.CoreV1Interface, error)
• type URL
• type URLs
  • func GetServiceURLs(api libmachine.API, namespace string, t *template.Template) (URLs, error)

Functions

func CheckService

func CheckService(namespace string, service string) error

CheckService checks if a service is listening on a port.

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)

GetServiceListByLabel returns a ServiceList by label

func GetServiceURLsForService

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

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

func OptionallyHTTPSFormattedURLString

func OptionallyHTTPSFormattedURLString(bareURLString string, https bool) (string, bool)

OptionallyHTTPSFormattedURLString returns a formatted URL string, optionally HTTPS

func WaitAndMaybeOpenService

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

WaitAndMaybeOpenService waits for a service, and opens it when running

Types

type K8sClient

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

K8sClient represents a kubernetes client

var K8s K8sClient

K8s is the current K8sClient

type K8sClientGetter

type K8sClientGetter struct{}

K8sClientGetter can get a K8sClient

func (*K8sClientGetter) GetClientset

func (*K8sClientGetter) GetClientset(timeout time.Duration) (*kubernetes.Clientset, error)

GetClientset returns a clientset

func (*K8sClientGetter) GetCoreClient

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

GetCoreClient returns a core client

type URL

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

URL represents service URL

type URLs

type URLs []URL

URLs represents a list of URL

func GetServiceURLs

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

GetServiceURLs returns all the node port URLs for every service in a particular namespace Accepts a template for formatting