Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFakeProvider ¶
NewFakeProvider implements mesh.EndpointsProvider, which creates a test Kubernetes cluster/compute provider.
Types ¶
type CacheCollection ¶
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 NewProvider ¶
func NewProvider(kubeClient kubernetes.Interface, namespaceController namespace.Controller, stop chan struct{}, providerIdent string, cfg configurator.Configurator) (*Client, error)
NewProvider implements mesh.EndpointsProvider, which creates a new Kubernetes cluster/compute provider.
func (Client) GetAnnouncementsChannel ¶
func (c Client) GetAnnouncementsChannel() <-chan interface{}
GetAnnouncementsChannel returns the announcement channel for the Kubernetes endpoints provider.
func (*Client) GetID ¶
GetID returns a string descriptor / identifier of the compute provider. Required by interface: EndpointsProvider
func (Client) GetServiceForServiceAccount ¶
func (c Client) GetServiceForServiceAccount(svcAccount service.K8sServiceAccount) (service.MeshService, error)
GetServiceForServiceAccount retrieves the service 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 Deployments cache.SharedIndexInformer }
InformerCollection is a struct of the Kubernetes informers used in OSM