k8s

Documentation

Index

• func HasNamespace(ingress *v1beta1.Ingress, namespaces Namespaces) bool
• func NewListWatchFromClient(c cache.Getter, resource string, namespace string, ...) *cache.ListWatch
• type Client
  • func NewInClusterClient() (Client, error)
  • func NewInClusterClientWithEndpoint(endpoint string) (Client, error)
• type Namespaces
  • func (ns *Namespaces) Get() interface{}
  • func (ns *Namespaces) Set(str string) error
  • func (ns *Namespaces) SetValue(val interface{})
  • func (ns *Namespaces) String() string

Functions

func HasNamespace

func HasNamespace(ingress *v1beta1.Ingress, namespaces Namespaces) bool

HasNamespace checks if the ingress is in one of the namespaces

func NewListWatchFromClient

func NewListWatchFromClient(c cache.Getter, resource string, namespace string, fieldSelector fields.Selector, labelSelector labels.Selector) *cache.ListWatch

NewListWatchFromClient creates a new ListWatch from the specified client, resource, namespace, field selector and label selector. Extends cache.NewListWatchFromClient to support labelSelector

Types

type Client

type Client interface {
	GetIngresses(namespaces Namespaces) []*v1beta1.Ingress
	GetService(namespace, name string) (*v1.Service, bool, error)
	GetEndpoints(namespace, name string) (*v1.Endpoints, bool, error)
	WatchAll(labelSelector string, stopCh <-chan struct{}) (<-chan interface{}, error)
}

Client is a client for the Kubernetes master. WatchAll starts the watch of the Kubernetes ressources and updates the stores. The stores can then be accessed via the Get* functions.

func NewInClusterClient

func NewInClusterClient() (Client, error)

NewInClusterClient returns a new Kubernetes client that expect to run inside the cluster

func NewInClusterClientWithEndpoint

func NewInClusterClientWithEndpoint(endpoint string) (Client, error)

NewInClusterClientWithEndpoint is the same as NewInClusterClient but uses the provided endpoint URL

type Namespaces

type Namespaces []string

Namespaces holds kubernetes namespaces

func (*Namespaces) Get

func (ns *Namespaces) Get() interface{}

Get []string

func (*Namespaces) Set

func (ns *Namespaces) Set(str string) error

Set adds strings elem into the the parser it splits str on , and ;

func (*Namespaces) SetValue

func (ns *Namespaces) SetValue(val interface{})

SetValue sets []string into the parser

func (*Namespaces) String

func (ns *Namespaces) String() string

String return slice in a string