v1

Documentation

Index

• func FromNetworkPolicyHandlerToHandler(sync NetworkPolicyHandler) generic.Handler
• func RegisterNetworkPolicyGeneratingHandler(ctx context.Context, controller NetworkPolicyController, apply apply.Apply, ...)
• func RegisterNetworkPolicyStatusHandler(ctx context.Context, controller NetworkPolicyController, ...)
• func UpdateNetworkPolicyDeepCopyOnChange(client NetworkPolicyClient, obj *v1.NetworkPolicy, ...) (*v1.NetworkPolicy, error)
• type Interface
  • func New(controllerFactory controller.SharedControllerFactory) Interface
• type NetworkPolicyCache
• type NetworkPolicyClient
• type NetworkPolicyController
  • func NewNetworkPolicyController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) NetworkPolicyController
• type NetworkPolicyGeneratingHandler
• type NetworkPolicyHandler
• type NetworkPolicyIndexer
• type NetworkPolicyStatusHandler

Functions

func FromNetworkPolicyHandlerToHandler

func FromNetworkPolicyHandlerToHandler(sync NetworkPolicyHandler) generic.Handler

func RegisterNetworkPolicyGeneratingHandler

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

RegisterNetworkPolicyGeneratingHandler configures a NetworkPolicyController to execute a NetworkPolicyGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterNetworkPolicyStatusHandler

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

RegisterNetworkPolicyStatusHandler configures a NetworkPolicyController to execute a NetworkPolicyStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

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

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

NetworkPolicyGeneratingHandler is the top-level handler that is executed for every NetworkPolicy event. It extends NetworkPolicyStatusHandler by a returning a slice of child objects to be passed to apply.Apply

type NetworkPolicyHandler

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

type NetworkPolicyIndexer

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

type NetworkPolicyStatusHandler

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

NetworkPolicyStatusHandler is executed for every added or modified NetworkPolicy. Should return the new status to be updated