kube

Documentation

Index

• func NewFakeProvider() endpoint.Provider
• func NewProvider(kubeClient kubernetes.Interface, kubeController k8s.Controller, ...) (endpoint.Provider, error)
• type Client
  • 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) GetTargetPortToProtocolMappingForService(svc service.MeshService) (map[uint32]string, error)
  • func (c Client) ListEndpointsForIdentity(sa service.K8sServiceAccount) []endpoint.Endpoint
  • func (c Client) ListEndpointsForService(svc service.MeshService) []endpoint.Endpoint

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, providerIdent string, cfg configurator.Configurator) (endpoint.Provider, error)

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

Types

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) 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) GetTargetPortToProtocolMappingForService

func (c Client) GetTargetPortToProtocolMappingForService(svc service.MeshService) (map[uint32]string, error)

GetTargetPortToProtocolMappingForService returns a mapping of the service's ports to their corresponding application protocol

func (Client) ListEndpointsForIdentity

func (c Client) ListEndpointsForIdentity(sa service.K8sServiceAccount) []endpoint.Endpoint

ListEndpointsForIdentity retrieves the list of IP addresses 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