controller

Documentation

Index

• Constants
• type DynamicAttachmentRequest
  • func (dar *DynamicAttachmentRequest) String() string
• type DynamicAttachmentRequestType
• type PodNetworksController
  • func NewPodNetworksController(k8sCoreInformerFactory v1coreinformerfactory.SharedInformerFactory, ...) (*PodNetworksController, error)
  • func (pnc *PodNetworksController) Eventf(object runtime.Object, eventtype, reason, messageFmt string, ...)
  • func (pnc *PodNetworksController) Start(stopChan <-chan struct{})

Constants

const (
	AdvertisedName = "pod-networks-updates"
)

Types

type DynamicAttachmentRequest

type DynamicAttachmentRequest struct {
	Pod         *corev1.Pod
	Attachments []nadv1.NetworkSelectionElement
	Type        DynamicAttachmentRequestType
	PodNetNS    string
}

func (*DynamicAttachmentRequest) String

func (dar *DynamicAttachmentRequest) String() string

type DynamicAttachmentRequestType

type DynamicAttachmentRequestType string

type PodNetworksController

type PodNetworksController struct {
	// contains filtered or unexported fields
}

PodNetworksController handles the cncf networks annotations update, and triggers adding / removing networks from a running pod.

func NewPodNetworksController

func NewPodNetworksController(
	k8sCoreInformerFactory v1coreinformerfactory.SharedInformerFactory,
	nadInformers nadinformers.SharedInformerFactory,
	broadcaster record.EventBroadcaster,
	recorder record.EventRecorder,
	k8sClientSet kubernetes.Interface,
	nadClientSet nadclient.Interface,
	containerRuntime cri.ContainerRuntime,
	multusClient multuscni.Client,
) (*PodNetworksController, error)

NewPodNetworksController returns new PodNetworksController instance

func (*PodNetworksController) Eventf

func (pnc *PodNetworksController) Eventf(object runtime.Object, eventtype, reason, messageFmt string, args ...interface{})

Eventf puts event into kubernetes events

func (*PodNetworksController) Start

func (pnc *PodNetworksController) Start(stopChan <-chan struct{})

Start runs worker thread after performing cache synchronization