v1alpha3

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Oct 8, 2020 License: Apache-2.0 Imports: 16 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

func UpdateDestinationRuleDeepCopyOnChange 

func UpdateDestinationRuleDeepCopyOnChange(client DestinationRuleClient, obj *v1alpha3.DestinationRule, handler func(obj *v1alpha3.DestinationRule) (*v1alpha3.DestinationRule, error)) (*v1alpha3.DestinationRule, error)

func UpdateGatewayDeepCopyOnChange 

func UpdateGatewayDeepCopyOnChange(client GatewayClient, obj *v1alpha3.Gateway, handler func(obj *v1alpha3.Gateway) (*v1alpha3.Gateway, error)) (*v1alpha3.Gateway, error)

func UpdateServiceEntryDeepCopyOnChange 

func UpdateServiceEntryDeepCopyOnChange(client ServiceEntryClient, obj *v1alpha3.ServiceEntry, handler func(obj *v1alpha3.ServiceEntry) (*v1alpha3.ServiceEntry, error)) (*v1alpha3.ServiceEntry, error)

func UpdateVirtualServiceDeepCopyOnChange 

func UpdateVirtualServiceDeepCopyOnChange(client VirtualServiceClient, obj *v1alpha3.VirtualService, handler func(obj *v1alpha3.VirtualService) (*v1alpha3.VirtualService, error)) (*v1alpha3.VirtualService, error)

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 {
	generic.ControllerMeta
	DestinationRuleClient

	OnChange(ctx context.Context, name string, sync DestinationRuleHandler)
	OnRemove(ctx context.Context, name string, sync DestinationRuleHandler)
	Enqueue(namespace, name string)
	EnqueueAfter(namespace, name string, duration time.Duration)

	Cache() DestinationRuleCache
}

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)

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 {
	generic.ControllerMeta
	GatewayClient

	OnChange(ctx context.Context, name string, sync GatewayHandler)
	OnRemove(ctx context.Context, name string, sync GatewayHandler)
	Enqueue(namespace, name string)
	EnqueueAfter(namespace, name string, duration time.Duration)

	Cache() GatewayCache
}

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)

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 {
	generic.ControllerMeta
	ServiceEntryClient

	OnChange(ctx context.Context, name string, sync ServiceEntryHandler)
	OnRemove(ctx context.Context, name string, sync ServiceEntryHandler)
	Enqueue(namespace, name string)
	EnqueueAfter(namespace, name string, duration time.Duration)

	Cache() ServiceEntryCache
}

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)

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 {
	generic.ControllerMeta
	VirtualServiceClient

	OnChange(ctx context.Context, name string, sync VirtualServiceHandler)
	OnRemove(ctx context.Context, name string, sync VirtualServiceHandler)
	Enqueue(namespace, name string)
	EnqueueAfter(namespace, name string, duration time.Duration)

	Cache() VirtualServiceCache
}

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)

type VirtualServiceIndexer 

type VirtualServiceIndexer func(obj *v1alpha3.VirtualService) ([]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.