Documentation
¶
Index ¶
- type ConfigMapLister
- type Dummy
- func (d Dummy) GetConfig() *config.Configuration
- func (d Dummy) GetConfigMap(key string) (*corev1.ConfigMap, error)
- func (d Dummy) GetIngress(key string) (*extensions.Ingress, error)
- func (d Dummy) GetIngressAnnotations(key string) (*annotations.Ingress, error)
- func (d *Dummy) GetInstanceIDFromPodIP(s string) (string, error)
- func (d *Dummy) GetNodeInstanceID(node *corev1.Node) (string, error)
- func (d Dummy) GetPod(key string) (*corev1.Pod, error)
- func (d Dummy) GetService(key string) (*corev1.Service, error)
- func (d Dummy) GetServiceAnnotations(key string, ingress *annotations.Ingress) (*annotations.Service, error)
- func (d Dummy) GetServiceEndpoints(key string) (*corev1.Endpoints, error)
- func (d Dummy) ListIngresses() []*extensions.Ingress
- func (d Dummy) ListNodes() []*corev1.Node
- func (d Dummy) Run(stopCh chan struct{})
- func (d *Dummy) SetConfig(c *config.Configuration)
- type EndpointLister
- type Informer
- type IngressAnnotationsLister
- type IngressLister
- type Lister
- type MockStorer
- func (_m *MockStorer) GetConfig() *config.Configuration
- func (_m *MockStorer) GetIngressAnnotations(key string) (*annotations.Ingress, error)
- func (_m *MockStorer) GetInstanceIDFromPodIP(_a0 string) (string, error)
- func (_m *MockStorer) GetNodeInstanceID(node *v1.Node) (string, error)
- func (_m *MockStorer) GetPod(key string) (*v1.Pod, error)
- func (_m *MockStorer) GetService(key string) (*v1.Service, error)
- func (_m *MockStorer) GetServiceAnnotations(key string, ingress *annotations.Ingress) (*annotations.Service, error)
- func (_m *MockStorer) GetServiceEndpoints(key string) (*v1.Endpoints, error)
- func (_m *MockStorer) ListNodes() []*v1.Node
- type NodeLister
- type NotExistsError
- type PodLister
- type ServiceAnnotationsLister
- type ServiceLister
- type Storer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConfigMapLister ¶
ConfigMapLister makes a Store that lists Configmaps.
type Dummy ¶
type Dummy struct {
GetIngressAnnotationsResponse *annotations.Ingress
GetServiceAnnotationsResponse *annotations.Service
GetServiceFunc func(string) (*corev1.Service, error)
ListNodesFunc func() []*corev1.Node
GetNodeInstanceIDFunc func(*corev1.Node) (string, error)
GetServiceEndpointsFunc func(string) (*corev1.Endpoints, error)
GetPodFunc func(string) (*corev1.Pod, error)
// contains filtered or unexported fields
}
func (Dummy) GetConfigMap ¶
GetConfigMap ...
func (Dummy) GetIngress ¶
func (d Dummy) GetIngress(key string) (*extensions.Ingress, error)
GetIngress ...
func (Dummy) GetIngressAnnotations ¶
func (d Dummy) GetIngressAnnotations(key string) (*annotations.Ingress, error)
GetIngressAnnotations ...
func (*Dummy) GetInstanceIDFromPodIP ¶
GetInstanceIDFromPodIP ...
func (*Dummy) GetNodeInstanceID ¶
GetInstanceIDFromPodIP ...
func (Dummy) GetService ¶
GetService ...
func (Dummy) GetServiceAnnotations ¶
func (d Dummy) GetServiceAnnotations(key string, ingress *annotations.Ingress) (*annotations.Service, error)
GetServiceAnnotations ...
func (Dummy) GetServiceEndpoints ¶
GetServiceEndpoints ...
type EndpointLister ¶
EndpointLister makes a Store that lists Endpoints.
type Informer ¶
type Informer struct {
Ingress cache.SharedIndexInformer
Service cache.SharedIndexInformer
Endpoint cache.SharedIndexInformer
Node cache.SharedIndexInformer
Pod cache.SharedIndexInformer
}
Informer defines the required SharedIndexInformers that interact with the API server.
type IngressAnnotationsLister ¶
IngressAnnotationsLister makes a Store that lists annotations in Ingress rules.
func (IngressAnnotationsLister) ByKey ¶
func (il IngressAnnotationsLister) ByKey(key string) (*annotations.Ingress, error)
ByKey returns the Ingress annotations matching key in the local Ingress annotations Store.
type IngressLister ¶
IngressLister makes a Store that lists Ingress.
func (IngressLister) ByKey ¶
func (il IngressLister) ByKey(key string) (*extensions.Ingress, error)
ByKey returns the Ingress matching key in the local Ingress Store.
type Lister ¶
type Lister struct {
Ingress IngressLister
Service ServiceLister
Endpoint EndpointLister
Node NodeLister
Pod PodLister
IngressAnnotation IngressAnnotationsLister
ServiceAnnotation ServiceAnnotationsLister
}
Lister contains object listers (stores).
type MockStorer ¶
MockStorer is an autogenerated mock type for the Storer type
func (*MockStorer) GetConfig ¶
func (_m *MockStorer) GetConfig() *config.Configuration
GetConfig provides a mock function with given fields:
func (*MockStorer) GetIngressAnnotations ¶
func (_m *MockStorer) GetIngressAnnotations(key string) (*annotations.Ingress, error)
GetIngressAnnotations provides a mock function with given fields: key
func (*MockStorer) GetInstanceIDFromPodIP ¶
func (_m *MockStorer) GetInstanceIDFromPodIP(_a0 string) (string, error)
GetInstanceIDFromPodIP provides a mock function with given fields: _a0
func (*MockStorer) GetNodeInstanceID ¶
func (_m *MockStorer) GetNodeInstanceID(node *v1.Node) (string, error)
GetNodeInstanceID provides a mock function with given fields: node
func (*MockStorer) GetPod ¶ added in v1.1.6
func (_m *MockStorer) GetPod(key string) (*v1.Pod, error)
GetPod provides a mock function with given fields: key
func (*MockStorer) GetService ¶
func (_m *MockStorer) GetService(key string) (*v1.Service, error)
GetService provides a mock function with given fields: key
func (*MockStorer) GetServiceAnnotations ¶
func (_m *MockStorer) GetServiceAnnotations(key string, ingress *annotations.Ingress) (*annotations.Service, error)
GetServiceAnnotations provides a mock function with given fields: key, ingress
func (*MockStorer) GetServiceEndpoints ¶
func (_m *MockStorer) GetServiceEndpoints(key string) (*v1.Endpoints, error)
GetServiceEndpoints provides a mock function with given fields: key
func (*MockStorer) ListNodes ¶
func (_m *MockStorer) ListNodes() []*v1.Node
ListNodes provides a mock function with given fields:
type NodeLister ¶
NodeLister makes a Store that lists Nodes.
type NotExistsError ¶
type NotExistsError string
NotExistsError is returned when an object does not exist in a local store.
func (NotExistsError) Error ¶
func (e NotExistsError) Error() string
Error implements the error interface.
type ServiceAnnotationsLister ¶
ServiceAnnotationsLister makes a Store that lists annotations in Service rules.
func (ServiceAnnotationsLister) ByKey ¶
func (il ServiceAnnotationsLister) ByKey(key string) (*annotations.Service, error)
ByKey returns the Service annotations matching key in the local Service annotations Store.
type ServiceLister ¶
ServiceLister makes a Store that lists Services.
type Storer ¶
type Storer interface {
// GetService returns the Service matching key.
GetService(key string) (*corev1.Service, error)
// GetServiceEndpoints returns the Endpoints of a Service matching key.
GetServiceEndpoints(key string) (*corev1.Endpoints, error)
// GetServiceAnnotations returns the parsed annotations of an Service matching key. if ingress is non-nil, merges ingress annotations into the service.
GetServiceAnnotations(key string, ingress *annotations.Ingress) (*annotations.Service, error)
// ListNodes returns a list of all Nodes in the store.
ListNodes() []*corev1.Node
// GetIngressAnnotations returns the parsed annotations of an Ingress matching key.
GetIngressAnnotations(key string) (*annotations.Ingress, error)
// GetConfig returns the controller configuration
GetConfig() *config.Configuration
// GetInstanceIDFromPodIP gets the instance id of the node running a pod
GetInstanceIDFromPodIP(string) (string, error)
// GetNodeInstanceID gets the instance id of node
GetNodeInstanceID(node *corev1.Node) (string, error)
// GetServicePods gets all pods that match the selector of a service
GetPod(key string) (*corev1.Pod, error)
}
Storer is the interface that wraps the required methods to gather information about ingresses, services, secrets and ingress annotations.