event

Documentation

Index

• type AttributeHandler
• type Handler
  • func (h *Handler) HandleAdd(obj interface{}) error
  • func (h *Handler) HandleDelete(obj interface{}) error
  • func (h *Handler) HandleUpdate(oldObj, newObj interface{}) error
• type NetworkPolicyHandler
• type ObjectHandler

Types

type AttributeHandler

type AttributeHandler interface {
	ConvertLabels(targetPodLabels map[string]string) map[string][]string
	GetLocalEnvVars(obj metav1.Object) (map[string]string, error)
	GetLabelsFromEnvVars(envVars map[string]string) (map[string][]string, error)
	MergeLabels(targetLabels ...map[string][]string) (map[string][]string, error)
}

type Handler

type Handler struct {
	Client               kubernetes.Interface
	DyanmicClient        dynamic.Interface
	NetworkPolicyHandler NetworkPolicyHandler
	ObjectHandler        ObjectHandler
	AttributeHandler     AttributeHandler
}

func (*Handler) HandleAdd

func (h *Handler) HandleAdd(obj interface{}) error

HandleAdd handles the case when a K8s object of interest is added to the cluster, and creates a NetworkPolicy for it

func (*Handler) HandleDelete

func (h *Handler) HandleDelete(obj interface{}) error

HandleDelete handles the case when an object of interest is deleted from the cluster. If the object had a NetworkPolicy belonging to it, the policy gets deleted

func (*Handler) HandleUpdate

func (h *Handler) HandleUpdate(oldObj, newObj interface{}) error

HandleUpdate handles the case when a K8s object of interest is updated in the cluster, provided the object's environment variables or labels have changed

type NetworkPolicyHandler

type NetworkPolicyHandler interface {
	NewPolicy(name string, namespace string, podSelectorLabels map[string]string, targetPodLabels map[string][]string) (*networkingv1.NetworkPolicy, error)
	GetPolicyByPodLabels(namespace string, podLabels map[string]string) (*networkingv1.NetworkPolicy, error)
	AppendLabelsToPeers(targetPodLabels map[string][]string) (ingressPeers []networkingv1.NetworkPolicyPeer, egressPeers []networkingv1.NetworkPolicyPeer, err error)
}

type ObjectHandler

type ObjectHandler interface {
	AddLabel() error
	Mutate(action object.Action) error
}