Documentation ¶
Index ¶
- type ConfigMapLister
- type Dummy
- func (d *Dummy) GetClusterInstanceIDs() ([]string, error)
- 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) 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) GetClusterInstanceIDs() ([]string, error)
- 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) 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) GetClusterInstanceIDsFunc func() ([]string, error) GetServiceEndpointsFunc func(string) (*corev1.Endpoints, error) // contains filtered or unexported fields }
func (*Dummy) GetClusterInstanceIDs ¶
GetClusterInstanceIDs is the mock for dummy store
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) GetClusterInstanceIDs ¶
func (_m *MockStorer) GetClusterInstanceIDs() ([]string, error)
GetClusterInstanceIDs provides a mock function with given fields:
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) 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) // GetClusterInstanceIDs gets id of all instances inside cluster GetClusterInstanceIDs() ([]string, error) }
Storer is the interface that wraps the required methods to gather information about ingresses, services, secrets and ingress annotations.