connector

Documentation

Index

• type Client
  • func NewClient() (*Client, error)
  • func (c *Client) GetIngresses() ([]extensions_v1beta1.Ingress, error)
  • func (c *Client) GetServiceMap() (map[string]core_v1.Service, error)
  • func (c *Client) WatchIngressForChanges() (chan bool, error)
  • func (c *Client) WatchServicesForChanges() (chan bool, error)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient() (*Client, error)

NewClient generates a client with the right configuration

func (*Client) GetIngresses

func (c *Client) GetIngresses() ([]extensions_v1beta1.Ingress, error)

GetIngresses gets all ingresses from all namespaces

func (*Client) GetServiceMap

func (c *Client) GetServiceMap() (map[string]core_v1.Service, error)

GetServiceMap gives all services in a map to look them up in (namespace)-(service) format

func (*Client) WatchIngressForChanges

func (c *Client) WatchIngressForChanges() (chan bool, error)

WatchIngressForChanges watches changes on ingrress inside Kubernetes

func (*Client) WatchServicesForChanges

func (c *Client) WatchServicesForChanges() (chan bool, error)

WatchServicesForChanges watches changes on services inside Kubernetes