Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) GetAnnouncementsChannel ¶
func (c Client) GetAnnouncementsChannel() <-chan interface{}
GetAnnouncementsChannel returns the announcement channel for the Ingress client
func (Client) GetIngressResources ¶
func (c Client) GetIngressResources(meshService service.MeshService) ([]*extensionsV1beta.Ingress, error)
GetIngressResources returns the ingress resources whose backends correspond to the service
type FakeIngressMonitor ¶
type FakeIngressMonitor struct {
FakeIngresses []*extensionsV1beta.Ingress
Monitor
}
FakeIngressMonitor returns a fake ingress monitor object
func NewFakeIngressMonitor ¶
func NewFakeIngressMonitor() FakeIngressMonitor
NewFakeIngressMonitor returns a fake ingress.Monitor used for testing
func (FakeIngressMonitor) GetAnnouncementsChannel ¶
func (f FakeIngressMonitor) GetAnnouncementsChannel() <-chan interface{}
GetAnnouncementsChannel returns the channel on which Ingress Monitor makes annoucements
func (FakeIngressMonitor) GetIngressResources ¶
func (f FakeIngressMonitor) GetIngressResources(service.MeshService) ([]*extensionsV1beta.Ingress, error)
GetIngressResources returns the ingress resources whose backends correspond to the service
type Monitor ¶
type Monitor interface {
// GetIngressResources returns the ingress resources whose backends correspond to the service
GetIngressResources(service.MeshService) ([]*extensionsV1beta.Ingress, error)
// GetAnnouncementsChannel returns the channel on which Ingress Monitor makes annoucements
GetAnnouncementsChannel() <-chan interface{}
}
Monitor is the client interface for K8s Ingress resource
func NewIngressClient ¶
func NewIngressClient(kubeClient kubernetes.Interface, namespaceController namespace.Controller, stop chan struct{}, cfg configurator.Configurator) (Monitor, error)
NewIngressClient implements ingress.Monitor and creates the Kubernetes client to monitor Ingress resources.
Source Files