v1alpha3

Documentation

Index

• func FromDestinationRuleHandlerToHandler(sync DestinationRuleHandler) generic.Handler
• func FromGatewayHandlerToHandler(sync GatewayHandler) generic.Handler
• func FromServiceEntryHandlerToHandler(sync ServiceEntryHandler) generic.Handler
• func FromVirtualServiceHandlerToHandler(sync VirtualServiceHandler) generic.Handler
• func UpdateDestinationRuleDeepCopyOnChange(client DestinationRuleClient, obj *v1alpha3.DestinationRule, ...) (*v1alpha3.DestinationRule, error)
• func UpdateGatewayDeepCopyOnChange(client GatewayClient, obj *v1alpha3.Gateway, ...) (*v1alpha3.Gateway, error)
• func UpdateServiceEntryDeepCopyOnChange(client ServiceEntryClient, obj *v1alpha3.ServiceEntry, ...) (*v1alpha3.ServiceEntry, error)
• func UpdateVirtualServiceDeepCopyOnChange(client VirtualServiceClient, obj *v1alpha3.VirtualService, ...) (*v1alpha3.VirtualService, error)
• type DestinationRuleCache
• type DestinationRuleClient
• type DestinationRuleController
  • func NewDestinationRuleController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) DestinationRuleController
• type DestinationRuleHandler
• type DestinationRuleIndexer
• type GatewayCache
• type GatewayClient
• type GatewayController
  • func NewGatewayController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) GatewayController
• type GatewayHandler
• type GatewayIndexer
• type Interface
  • func New(controllerManager *generic.ControllerManager, ...) Interface
• type ServiceEntryCache
• type ServiceEntryClient
• type ServiceEntryController
  • func NewServiceEntryController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) ServiceEntryController
• type ServiceEntryHandler
• type ServiceEntryIndexer
• type VirtualServiceCache
• type VirtualServiceClient
• type VirtualServiceController
  • func NewVirtualServiceController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) VirtualServiceController
• type VirtualServiceHandler
• type VirtualServiceIndexer

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)