v1alpha3

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: May 26, 2019 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromDestinationRuleHandlerToHandler 

func FromDestinationRuleHandlerToHandler(sync DestinationRuleHandler) generic.Handler

func FromGatewayHandlerToHandler 

func FromGatewayHandlerToHandler(sync GatewayHandler) generic.Handler

func FromServiceEntryHandlerToHandler 

func FromServiceEntryHandlerToHandler(sync ServiceEntryHandler) generic.Handler

func FromVirtualServiceHandlerToHandler 

func FromVirtualServiceHandlerToHandler(sync VirtualServiceHandler) generic.Handler

Types

type DestinationRuleCache 

type DestinationRuleCache interface {
	Get(namespace, name string) (*v1alpha3.DestinationRule, error)
	List(namespace string, selector labels.Selector) ([]*v1alpha3.DestinationRule, error)

	AddIndexer(indexName string, indexer DestinationRuleIndexer)
	GetByIndex(indexName, key string) ([]*v1alpha3.DestinationRule, error)
}

type DestinationRuleClient 

type DestinationRuleClient interface {
	Create(*v1alpha3.DestinationRule) (*v1alpha3.DestinationRule, error)
	Update(*v1alpha3.DestinationRule) (*v1alpha3.DestinationRule, error)

	Delete(namespace, name string, options *metav1.DeleteOptions) error
	Get(namespace, name string, options metav1.GetOptions) (*v1alpha3.DestinationRule, error)
	List(namespace string, opts metav1.ListOptions) (*v1alpha3.DestinationRuleList, error)
	Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error)
	Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha3.DestinationRule, err error)
}

type DestinationRuleController 

type DestinationRuleController interface {
	DestinationRuleClient

	OnChange(ctx context.Context, name string, sync DestinationRuleHandler)
	OnRemove(ctx context.Context, name string, sync DestinationRuleHandler)
	Enqueue(namespace, name string)

	Cache() DestinationRuleCache

	Informer() cache.SharedIndexInformer
	GroupVersionKind() schema.GroupVersionKind

	AddGenericHandler(ctx context.Context, name string, handler generic.Handler)
	AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler)
	Updater() generic.Updater
}

func NewDestinationRuleController 

func NewDestinationRuleController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.DestinationRulesGetter, informer informers.DestinationRuleInformer) DestinationRuleController

type DestinationRuleHandler 

type DestinationRuleHandler func(string, *v1alpha3.DestinationRule) (*v1alpha3.DestinationRule, error)

func UpdateDestinationRuleOnChange 

func UpdateDestinationRuleOnChange(updater generic.Updater, handler DestinationRuleHandler) DestinationRuleHandler

type DestinationRuleIndexer 

type DestinationRuleIndexer func(obj *v1alpha3.DestinationRule) ([]string, error)

type GatewayCache 

type GatewayCache interface {
	Get(namespace, name string) (*v1alpha3.Gateway, error)
	List(namespace string, selector labels.Selector) ([]*v1alpha3.Gateway, error)

	AddIndexer(indexName string, indexer GatewayIndexer)
	GetByIndex(indexName, key string) ([]*v1alpha3.Gateway, error)
}

type GatewayClient 

type GatewayClient interface {
	Create(*v1alpha3.Gateway) (*v1alpha3.Gateway, error)
	Update(*v1alpha3.Gateway) (*v1alpha3.Gateway, error)

	Delete(namespace, name string, options *metav1.DeleteOptions) error
	Get(namespace, name string, options metav1.GetOptions) (*v1alpha3.Gateway, error)
	List(namespace string, opts metav1.ListOptions) (*v1alpha3.GatewayList, error)
	Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error)
	Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha3.Gateway, err error)
}

type GatewayController 

type GatewayController interface {
	GatewayClient

	OnChange(ctx context.Context, name string, sync GatewayHandler)
	OnRemove(ctx context.Context, name string, sync GatewayHandler)
	Enqueue(namespace, name string)

	Cache() GatewayCache

	Informer() cache.SharedIndexInformer
	GroupVersionKind() schema.GroupVersionKind

	AddGenericHandler(ctx context.Context, name string, handler generic.Handler)
	AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler)
	Updater() generic.Updater
}

func NewGatewayController 

func NewGatewayController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.GatewaysGetter, informer informers.GatewayInformer) GatewayController

type GatewayHandler 

type GatewayHandler func(string, *v1alpha3.Gateway) (*v1alpha3.Gateway, error)

func UpdateGatewayOnChange 

func UpdateGatewayOnChange(updater generic.Updater, handler GatewayHandler) GatewayHandler

type GatewayIndexer 

type GatewayIndexer func(obj *v1alpha3.Gateway) ([]string, error)

type Interface 

type Interface interface {
	DestinationRule() DestinationRuleController
	Gateway() GatewayController
	ServiceEntry() ServiceEntryController
	VirtualService() VirtualServiceController
}

func New 

func New(controllerManager *generic.ControllerManager, client clientset.NetworkingV1alpha3Interface,
	informers informers.Interface) Interface

type ServiceEntryCache 

type ServiceEntryCache interface {
	Get(namespace, name string) (*v1alpha3.ServiceEntry, error)
	List(namespace string, selector labels.Selector) ([]*v1alpha3.ServiceEntry, error)

	AddIndexer(indexName string, indexer ServiceEntryIndexer)
	GetByIndex(indexName, key string) ([]*v1alpha3.ServiceEntry, error)
}

type ServiceEntryClient 

type ServiceEntryClient interface {
	Create(*v1alpha3.ServiceEntry) (*v1alpha3.ServiceEntry, error)
	Update(*v1alpha3.ServiceEntry) (*v1alpha3.ServiceEntry, error)

	Delete(namespace, name string, options *metav1.DeleteOptions) error
	Get(namespace, name string, options metav1.GetOptions) (*v1alpha3.ServiceEntry, error)
	List(namespace string, opts metav1.ListOptions) (*v1alpha3.ServiceEntryList, error)
	Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error)
	Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha3.ServiceEntry, err error)
}

type ServiceEntryController 

type ServiceEntryController interface {
	ServiceEntryClient

	OnChange(ctx context.Context, name string, sync ServiceEntryHandler)
	OnRemove(ctx context.Context, name string, sync ServiceEntryHandler)
	Enqueue(namespace, name string)

	Cache() ServiceEntryCache

	Informer() cache.SharedIndexInformer
	GroupVersionKind() schema.GroupVersionKind

	AddGenericHandler(ctx context.Context, name string, handler generic.Handler)
	AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler)
	Updater() generic.Updater
}

func NewServiceEntryController 

func NewServiceEntryController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.ServiceEntriesGetter, informer informers.ServiceEntryInformer) ServiceEntryController

type ServiceEntryHandler 

type ServiceEntryHandler func(string, *v1alpha3.ServiceEntry) (*v1alpha3.ServiceEntry, error)

func UpdateServiceEntryOnChange 

func UpdateServiceEntryOnChange(updater generic.Updater, handler ServiceEntryHandler) ServiceEntryHandler

type ServiceEntryIndexer 

type ServiceEntryIndexer func(obj *v1alpha3.ServiceEntry) ([]string, error)

type VirtualServiceCache 

type VirtualServiceCache interface {
	Get(namespace, name string) (*v1alpha3.VirtualService, error)
	List(namespace string, selector labels.Selector) ([]*v1alpha3.VirtualService, error)

	AddIndexer(indexName string, indexer VirtualServiceIndexer)
	GetByIndex(indexName, key string) ([]*v1alpha3.VirtualService, error)
}

type VirtualServiceClient 

type VirtualServiceClient interface {
	Create(*v1alpha3.VirtualService) (*v1alpha3.VirtualService, error)
	Update(*v1alpha3.VirtualService) (*v1alpha3.VirtualService, error)

	Delete(namespace, name string, options *metav1.DeleteOptions) error
	Get(namespace, name string, options metav1.GetOptions) (*v1alpha3.VirtualService, error)
	List(namespace string, opts metav1.ListOptions) (*v1alpha3.VirtualServiceList, error)
	Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error)
	Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1alpha3.VirtualService, err error)
}

type VirtualServiceController 

type VirtualServiceController interface {
	VirtualServiceClient

	OnChange(ctx context.Context, name string, sync VirtualServiceHandler)
	OnRemove(ctx context.Context, name string, sync VirtualServiceHandler)
	Enqueue(namespace, name string)

	Cache() VirtualServiceCache

	Informer() cache.SharedIndexInformer
	GroupVersionKind() schema.GroupVersionKind

	AddGenericHandler(ctx context.Context, name string, handler generic.Handler)
	AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler)
	Updater() generic.Updater
}

func NewVirtualServiceController 

func NewVirtualServiceController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.VirtualServicesGetter, informer informers.VirtualServiceInformer) VirtualServiceController

type VirtualServiceHandler 

type VirtualServiceHandler func(string, *v1alpha3.VirtualService) (*v1alpha3.VirtualService, error)

func UpdateVirtualServiceOnChange 

func UpdateVirtualServiceOnChange(updater generic.Updater, handler VirtualServiceHandler) VirtualServiceHandler

type VirtualServiceIndexer 

type VirtualServiceIndexer func(obj *v1alpha3.VirtualService) ([]string, error)

Source Files

View all Source files

Directories

Path Synopsis

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.