appmanager

Documentation

Index

• Constants
• func NewBroadcasterWrapper() record.EventBroadcaster
• type EventNotifier
  • func NewEventNotifier(bfunc NewBroadcasterFunc) *EventNotifier
  • func (en *EventNotifier) CreateNotifierForNamespace(namespace string, coreIntf corev1.CoreV1Interface) *NamespaceEventNotifier
  • func (en *EventNotifier) DeleteNotifierForNamespace(namespace string)
  • func (en *EventNotifier) GetNotifierForNamespace(namespace string) *NamespaceEventNotifier
• type Manager
  • func NewManager(params *Params) *Manager
  • func (appMgr *Manager) AddNamespace(namespace string, cfgMapSelector labels.Selector, resyncPeriod time.Duration) error
  • func (appMgr *Manager) AddNamespaceLabelInformer(labelSelector labels.Selector, resyncPeriod time.Duration) error
  • func (appMgr *Manager) GetAllWatchedNamespaces() []string
  • func (appMgr *Manager) GetWatchedNamespacesLockless() []string
  • func (appMgr *Manager) IsNodePort() bool
  • func (appMgr *Manager) ProcessNodeUpdate(obj interface{}, err error)
  • func (appMgr *Manager) Run(stopCh <-chan struct{})
  • func (appMgr *Manager) UseNodeInternal() bool
• type NPLAnnoations
• type NPLAnnotation
• type NamespaceEventNotifier
  • func (nen *NamespaceEventNotifier) RecordEvent(obj runtime.Object, eventType, reason, message string)
• type NamespaceEventNotifierMap
• type NewBroadcasterFunc
• type Node
• type Params
• type ProcessedHostPath
• type ResourceMap
• type WatchedNamespaces

Constants

const (
	Namespaces     = "namespaces"
	Services       = "services"
	Endpoints      = "endpoints"
	Secrets        = "secrets"
	Configmaps     = "configmaps"
	Ingresses      = "ingresses"
	IngressClasses = "ingressclasses"
)

Functions

func NewBroadcasterWrapper

func NewBroadcasterWrapper() record.EventBroadcaster

Types

type EventNotifier

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

func NewEventNotifier

func NewEventNotifier(bfunc NewBroadcasterFunc) *EventNotifier

func (*EventNotifier) CreateNotifierForNamespace

func (en *EventNotifier) CreateNotifierForNamespace(
	namespace string,
	coreIntf corev1.CoreV1Interface,
) *NamespaceEventNotifier

Create a notifier for a namespace, or return the existing one

func (*EventNotifier) DeleteNotifierForNamespace

func (en *EventNotifier) DeleteNotifierForNamespace(namespace string)

func (*EventNotifier) GetNotifierForNamespace

func (en *EventNotifier) GetNotifierForNamespace(
	namespace string,
) *NamespaceEventNotifier

Get the notifier for a namespace

type Manager

type Manager struct {
	DynamicNS bool

	AgentCIS cisAgent.CISAgentInterface

	WatchedNS WatchedNamespaces

	K8sVersion string
	// contains filtered or unexported fields
}

func NewManager

func NewManager(params *Params) *Manager

func (*Manager) AddNamespace

func (appMgr *Manager) AddNamespace(namespace string, cfgMapSelector labels.Selector, resyncPeriod time.Duration) error

func (*Manager) AddNamespaceLabelInformer

func (appMgr *Manager) AddNamespaceLabelInformer(labelSelector labels.Selector, resyncPeriod time.Duration) error

func (*Manager) GetAllWatchedNamespaces

func (appMgr *Manager) GetAllWatchedNamespaces() []string

func (*Manager) GetWatchedNamespacesLockless

func (appMgr *Manager) GetWatchedNamespacesLockless() []string

func (*Manager) IsNodePort

func (appMgr *Manager) IsNodePort() bool

func (*Manager) ProcessNodeUpdate

func (appMgr *Manager) ProcessNodeUpdate(obj interface{}, err error)

func (*Manager) Run

func (appMgr *Manager) Run(stopCh <-chan struct{})

func (*Manager) UseNodeInternal

func (appMgr *Manager) UseNodeInternal() bool

type NPLAnnoations

type NPLAnnoations []NPLAnnotation

type NPLAnnotation

type NPLAnnotation struct {
	PodPort  int32  `json:"podPort"`
	NodeIP   string `json:"nodeIP"`
	NodePort int32  `json:"nodePort"`
}

type NamespaceEventNotifier

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

func (*NamespaceEventNotifier) RecordEvent

func (nen *NamespaceEventNotifier) RecordEvent(
	obj runtime.Object,
	eventType,
	reason,
	message string,
)

type NamespaceEventNotifierMap

type NamespaceEventNotifierMap map[string]*NamespaceEventNotifier

type NewBroadcasterFunc

type NewBroadcasterFunc func() record.EventBroadcaster

type Node

type Node struct {
	Name string
	Addr string
}

type Params

type Params struct {
	KubeClient kubernetes.Interface

	UseNodeInternal bool
	IsNodePort      bool

	ManageConfigMaps bool
	ManageIngress    bool
	HubMode          bool
	AgRspChan        chan interface{}
	// contains filtered or unexported fields
}

type ProcessedHostPath

type ProcessedHostPath struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type ResourceMap

type ResourceMap map[int32][]*ResourceConfig

type WatchedNamespaces

type WatchedNamespaces struct {
	Namespaces     []string
	NamespaceLabel string
}