kube

Documentation

Index

• func NewFakeProvider() endpoint.Provider
• func NewProvider(kubeClient kubernetes.Interface, kubeController k8s.Controller, ...) (endpoint.Provider, error)
• type CacheCollection
• type Client
  • func (c Client) GetAnnouncementsChannel() <-chan interface{}
  • func (c *Client) GetID() string
  • func (c *Client) GetResolvableEndpointsForService(svc service.MeshService) ([]endpoint.Endpoint, error)
  • func (c Client) GetServicesForServiceAccount(svcAccount service.K8sServiceAccount) ([]service.MeshService, error)
  • func (c Client) ListEndpointsForService(svc service.MeshService) []endpoint.Endpoint
• type InformerCollection

Functions

func NewFakeProvider

func NewFakeProvider() endpoint.Provider

NewFakeProvider implements mesh.EndpointsProvider, which creates a test Kubernetes cluster/compute provider.

func NewProvider

func NewProvider(kubeClient kubernetes.Interface, kubeController k8s.Controller, stop chan struct{}, providerIdent string, cfg configurator.Configurator) (endpoint.Provider, error)

NewProvider implements mesh.EndpointsProvider, which creates a new Kubernetes cluster/compute provider.

Types

type CacheCollection

type CacheCollection struct {
	Endpoints cache.Store
	Pods      cache.Store
}

CacheCollection is a struct of the Kubernetes caches used in OSM

type Client

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

Client is a struct for all components necessary to connect to and maintain state of a Kubernetes cluster.

func (Client) GetAnnouncementsChannel

func (c Client) GetAnnouncementsChannel() <-chan interface{}

GetAnnouncementsChannel returns the announcement channel for the Kubernetes endpoints provider.

func (*Client) GetID

func (c *Client) GetID() string

GetID returns a string descriptor / identifier of the compute provider. Required by interface: EndpointsProvider

func (*Client) GetResolvableEndpointsForService

func (c *Client) GetResolvableEndpointsForService(svc service.MeshService) ([]endpoint.Endpoint, error)

GetResolvableEndpointsForService returns the expected endpoints that are to be reached when the service FQDN is resolved

func (Client) GetServicesForServiceAccount

func (c Client) GetServicesForServiceAccount(svcAccount service.K8sServiceAccount) ([]service.MeshService, error)

GetServicesForServiceAccount retrieves a list of services for the given service account.

func (Client) ListEndpointsForService

func (c Client) ListEndpointsForService(svc service.MeshService) []endpoint.Endpoint

ListEndpointsForService retrieves the list of IP addresses for the given service

type InformerCollection

type InformerCollection struct {
	Endpoints cache.SharedIndexInformer
	Pods      cache.SharedIndexInformer
}

InformerCollection is a struct of the Kubernetes informers used in OSM