handler

package
v0.1.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 12, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EndpointDiscovery added in v0.1.11 

type EndpointDiscovery struct {
	kubehandler.DefaultHandler
	CoreClient corev1types.CoreV1Interface
	Trigger    func()
}

SvcDiscovery handles addition, updation and deletion of headless services

func (*EndpointDiscovery) UpdateFunc added in v0.1.11 

func (d *EndpointDiscovery) UpdateFunc(namespace, name string) error

type MockCoreClient added in v0.1.11 

type MockCoreClient struct {
	mock.Mock
}

func (MockCoreClient) ComponentStatuses added in v0.1.11 

func (m MockCoreClient) ComponentStatuses() v1.ComponentStatusInterface

func (MockCoreClient) ConfigMaps added in v0.1.11 

func (m MockCoreClient) ConfigMaps(namespace string) v1.ConfigMapInterface

func (MockCoreClient) Endpoints added in v0.1.11 

func (m MockCoreClient) Endpoints(namespace string) v1.EndpointsInterface

func (MockCoreClient) Events added in v0.1.11 

func (m MockCoreClient) Events(namespace string) v1.EventInterface

func (MockCoreClient) LimitRanges added in v0.1.11 

func (m MockCoreClient) LimitRanges(namespace string) v1.LimitRangeInterface

func (MockCoreClient) Namespaces added in v0.1.11 

func (m MockCoreClient) Namespaces() v1.NamespaceInterface

func (MockCoreClient) Nodes added in v0.1.11 

func (m MockCoreClient) Nodes() v1.NodeInterface

func (MockCoreClient) PersistentVolumeClaims added in v0.1.11 

func (m MockCoreClient) PersistentVolumeClaims(namespace string) v1.PersistentVolumeClaimInterface

func (MockCoreClient) PersistentVolumes added in v0.1.11 

func (m MockCoreClient) PersistentVolumes() v1.PersistentVolumeInterface

func (MockCoreClient) PodTemplates added in v0.1.11 

func (m MockCoreClient) PodTemplates(namespace string) v1.PodTemplateInterface

func (MockCoreClient) Pods added in v0.1.11 

func (m MockCoreClient) Pods(namespace string) v1.PodInterface

func (MockCoreClient) RESTClient added in v0.1.11 

func (m MockCoreClient) RESTClient() rest.Interface

func (MockCoreClient) ReplicationControllers added in v0.1.11 

func (m MockCoreClient) ReplicationControllers(namespace string) v1.ReplicationControllerInterface

func (MockCoreClient) ResourceQuotas added in v0.1.11 

func (m MockCoreClient) ResourceQuotas(namespace string) v1.ResourceQuotaInterface

func (MockCoreClient) Secrets added in v0.1.11 

func (m MockCoreClient) Secrets(namespace string) v1.SecretInterface

func (MockCoreClient) ServiceAccounts added in v0.1.11 

func (m MockCoreClient) ServiceAccounts(namespace string) v1.ServiceAccountInterface

func (MockCoreClient) Services added in v0.1.11 

func (m MockCoreClient) Services(namespace string) v1.ServiceInterface

type MockEndpointsInterface added in v0.1.11 

type MockEndpointsInterface struct {
	mock.Mock
}

func (MockEndpointsInterface) Create added in v0.1.11 

func (m MockEndpointsInterface) Create(*v1.Endpoints) (*v1.Endpoints, error)

func (MockEndpointsInterface) Delete added in v0.1.11 

func (m MockEndpointsInterface) Delete(name string, options *metav1.DeleteOptions) error

func (MockEndpointsInterface) DeleteCollection added in v0.1.11 

func (m MockEndpointsInterface) DeleteCollection(options *metav1.DeleteOptions, listOptions metav1.ListOptions) error

func (MockEndpointsInterface) Get added in v0.1.11 

func (m MockEndpointsInterface) Get(name string, options metav1.GetOptions) (*v1.Endpoints, error)

func (MockEndpointsInterface) List added in v0.1.11 

func (m MockEndpointsInterface) List(opts metav1.ListOptions) (*v1.EndpointsList, error)

func (MockEndpointsInterface) Patch added in v0.1.11 

func (m MockEndpointsInterface) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Endpoints, err error)

func (MockEndpointsInterface) Update added in v0.1.11 

func (m MockEndpointsInterface) Update(*v1.Endpoints) (*v1.Endpoints, error)

func (MockEndpointsInterface) Watch added in v0.1.11 

func (m MockEndpointsInterface) Watch(opts metav1.ListOptions) (watch.Interface, error)

type MockSvcInterface added in v0.1.11 

type MockSvcInterface struct {
	mock.Mock
}

func (MockSvcInterface) Create added in v0.1.11 

func (m MockSvcInterface) Create(*v1.Service) (*v1.Service, error)

func (MockSvcInterface) Delete added in v0.1.11 

func (m MockSvcInterface) Delete(name string, options *metav1.DeleteOptions) error

func (MockSvcInterface) Get added in v0.1.11 

func (m MockSvcInterface) Get(name string, options metav1.GetOptions) (*v1.Service, error)

func (MockSvcInterface) List added in v0.1.11 

func (m MockSvcInterface) List(opts metav1.ListOptions) (*v1.ServiceList, error)

func (MockSvcInterface) Patch added in v0.1.11 

func (m MockSvcInterface) Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.Service, err error)

func (MockSvcInterface) ProxyGet added in v0.1.11 

func (m MockSvcInterface) ProxyGet(scheme, name, port, path string, params map[string]string) rest.ResponseWrapper

func (MockSvcInterface) Update added in v0.1.11 

func (m MockSvcInterface) Update(*v1.Service) (*v1.Service, error)

func (MockSvcInterface) UpdateStatus added in v0.1.11 

func (m MockSvcInterface) UpdateStatus(*v1.Service) (*v1.Service, error)

func (MockSvcInterface) Watch added in v0.1.11 

func (m MockSvcInterface) Watch(opts metav1.ListOptions) (watch.Interface, error)

type SvcDiscovery added in v0.1.11 

type SvcDiscovery struct {
	kubehandler.DefaultHandler
	CoreClient corev1types.CoreV1Interface
	SVCTrigger func(eventType envoy.LBEventType, svc *corev1.Service)
}

SvcDiscovery handles addition, updation and deletion of headless services

func (*SvcDiscovery) AddFunc added in v0.1.11 

func (d *SvcDiscovery) AddFunc(namespace, name string) error

func (*SvcDiscovery) DeleteFunc added in v0.1.11 

func (d *SvcDiscovery) DeleteFunc(namespace, name string) error

func (*SvcDiscovery) UpdateFunc added in v0.1.11 

func (d *SvcDiscovery) UpdateFunc(namespace, name string) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.