v1

package
v1.1.1 Latest Latest
Warning

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

Go to latest
Published: Feb 23, 2023 License: Apache-2.0 Imports: 20 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromNetworkPolicyHandlerToHandler

func FromNetworkPolicyHandlerToHandler(sync NetworkPolicyHandler) generic.Handler

func RegisterNetworkPolicyGeneratingHandler added in v1.1.0

func RegisterNetworkPolicyGeneratingHandler(ctx context.Context, controller NetworkPolicyController, apply apply.Apply,
	condition condition.Cond, name string, handler NetworkPolicyGeneratingHandler, opts *generic.GeneratingHandlerOptions)

func RegisterNetworkPolicyStatusHandler added in v1.1.0

func RegisterNetworkPolicyStatusHandler(ctx context.Context, controller NetworkPolicyController, condition condition.Cond, name string, handler NetworkPolicyStatusHandler)

func UpdateNetworkPolicyDeepCopyOnChange

func UpdateNetworkPolicyDeepCopyOnChange(client NetworkPolicyClient, obj *v1.NetworkPolicy, handler func(obj *v1.NetworkPolicy) (*v1.NetworkPolicy, error)) (*v1.NetworkPolicy, error)

Types

type Interface

type Interface interface {
	NetworkPolicy() NetworkPolicyController
}

func New

func New(controllerFactory controller.SharedControllerFactory) Interface

type NetworkPolicyCache

type NetworkPolicyCache interface {
	Get(namespace, name string) (*v1.NetworkPolicy, error)
	List(namespace string, selector labels.Selector) ([]*v1.NetworkPolicy, error)

	AddIndexer(indexName string, indexer NetworkPolicyIndexer)
	GetByIndex(indexName, key string) ([]*v1.NetworkPolicy, error)
}

type NetworkPolicyClient

type NetworkPolicyClient interface {
	Create(*v1.NetworkPolicy) (*v1.NetworkPolicy, error)
	Update(*v1.NetworkPolicy) (*v1.NetworkPolicy, error)
	UpdateStatus(*v1.NetworkPolicy) (*v1.NetworkPolicy, error)
	Delete(namespace, name string, options *metav1.DeleteOptions) error
	Get(namespace, name string, options metav1.GetOptions) (*v1.NetworkPolicy, error)
	List(namespace string, opts metav1.ListOptions) (*v1.NetworkPolicyList, error)
	Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error)
	Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.NetworkPolicy, err error)
}

type NetworkPolicyController

type NetworkPolicyController interface {
	generic.ControllerMeta
	NetworkPolicyClient

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

	Cache() NetworkPolicyCache
}

func NewNetworkPolicyController

func NewNetworkPolicyController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) NetworkPolicyController

type NetworkPolicyGeneratingHandler added in v1.1.0

type NetworkPolicyGeneratingHandler func(obj *v1.NetworkPolicy, status v1.NetworkPolicyStatus) ([]runtime.Object, v1.NetworkPolicyStatus, error)

type NetworkPolicyHandler

type NetworkPolicyHandler func(string, *v1.NetworkPolicy) (*v1.NetworkPolicy, error)

type NetworkPolicyIndexer

type NetworkPolicyIndexer func(obj *v1.NetworkPolicy) ([]string, error)

type NetworkPolicyStatusHandler added in v1.1.0

type NetworkPolicyStatusHandler func(obj *v1.NetworkPolicy, status v1.NetworkPolicyStatus) (v1.NetworkPolicyStatus, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL