service

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 26, 2019 License: Apache-2.0 Imports: 26 Imported by: 64

Documentation

Index

Constants

View Source
const (

	// DefaultWait is the default wait time, in seconds
	DefaultWait = 20
	// DefaultInterval is the default interval, in seconds
	DefaultInterval = 6
)

Variables

This section is empty.

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) (*core.ServiceList, error)

GetServiceListByLabel returns a ServiceList by label

func OptionallyHTTPSFormattedURLString added in v0.31.0

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

OptionallyHTTPSFormattedURLString returns a formatted URL string, optionally HTTPS

func PrintServiceList added in v1.3.0

func PrintServiceList(writer io.Writer, data [][]string)

PrintServiceList prints a list of services as a table which has "Namespace", "Name" and "URL" columns to a writer

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() (typed_core.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 added in v0.22.2

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

GetClientset returns a clientset

func (*K8sClientGetter) GetCoreClient

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

GetCoreClient returns a core client

type SvcURL added in v1.4.0

type SvcURL struct {
	Namespace string
	Name      string
	URLs      []string
	PortNames []string
}

SvcURL represents a service URL. Each item in the URLs field combines the service URL with one of the configured node ports. The PortNames field contains the configured names of the ports in the URLs field (sorted correspondingly - first item in PortNames belongs to the first item in URLs).

func GetServiceURLsForService

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

GetServiceURLsForService returns a SvcUrl object for a service in a namespace. Supports optional formatting.

type URLs added in v0.31.0

type URLs []SvcURL

URLs represents a list of URL

func GetServiceURLs

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

GetServiceURLs returns a SvcURL object for every service in a particular namespace. Accepts a template for formatting

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL