subscriber

Documentation

Overview

Package subscriber implements a mechanism to represent K8s watcher subscribers and allows K8s events to objects / resources to notify their respective subscribers. The intent is to allow the K8s watchers to consolidate all the event handling from various subsystems into one place.

Index

• type CESHandler
• type CESList
  • func NewCES() *CESList
  • func (l *CESList) NotifyAdd(ces *cilium_v2a1.CiliumEndpointSlice)
  • func (l *CESList) NotifyDelete(ces *cilium_v2a1.CiliumEndpointSlice)
  • func (l *CESList) NotifyUpdate(oldCES, newCES *cilium_v2a1.CiliumEndpointSlice)
  • func (l *CESList) Register(c CESHandler)
• type CiliumNode
• type CiliumNodeChain
  • func NewCiliumNodeChain() *CiliumNodeChain
  • func (l *CiliumNodeChain) OnAddCiliumNode(node *ciliumv2.CiliumNode, swg *lock.StoppableWaitGroup) error
  • func (l *CiliumNodeChain) OnDeleteCiliumNode(node *ciliumv2.CiliumNode, swg *lock.StoppableWaitGroup) error
  • func (l *CiliumNodeChain) OnUpdateCiliumNode(oldNode, newNode *ciliumv2.CiliumNode, swg *lock.StoppableWaitGroup) error
  • func (l *CiliumNodeChain) Register(s CiliumNode)
• type Node
• type NodeChain
  • func NewNodeChain() *NodeChain
  • func (l *NodeChain) OnAddNode(node *v1.Node, swg *lock.StoppableWaitGroup) error
  • func (l *NodeChain) OnDeleteNode(node *v1.Node, swg *lock.StoppableWaitGroup) error
  • func (l *NodeChain) OnUpdateNode(oldNode, newNode *v1.Node, swg *lock.StoppableWaitGroup) error
  • func (l *NodeChain) Register(s Node)
• type RawChain
  • func NewRawChain() *RawChain
  • func (l *RawChain) OnAdd(obj interface{})
  • func (l *RawChain) OnDelete(obj interface{})
  • func (l *RawChain) OnUpdate(oldObj, newObj interface{})
  • func (l *RawChain) Register(cb cache.ResourceEventHandler)
• type Service
• type ServiceChain
  • func NewServiceChain() *ServiceChain
  • func (l *ServiceChain) OnAddService(svc *slim_corev1.Service) error
  • func (l *ServiceChain) OnDeleteService(svc *slim_corev1.Service) error
  • func (l *ServiceChain) OnUpdateService(oldSvc, newSvc *slim_corev1.Service) error
  • func (l *ServiceChain) Register(s Service)

Types

type CESHandler

type CESHandler interface {
	OnAdd(ces *cilium_v2a1.CiliumEndpointSlice)
	OnUpdate(oldCES, newCES *cilium_v2a1.CiliumEndpointSlice)
	OnDelete(ces *cilium_v2a1.CiliumEndpointSlice)
}

CESHandler is implemented by event handlers responding to CiliumEndpointSlice events.

type CESList

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

CESList holds the CES subscribers to any CiliumEndpointSlice resource / object changes in the K8s watchers.

func NewCES

func NewCES() *CESList

NewCES creates a new ces subscriber list.

func (*CESList) NotifyAdd

func (l *CESList) NotifyAdd(ces *cilium_v2a1.CiliumEndpointSlice)

NotifyAdd notifies all the subscribers of an add event to an object.

func (*CESList) NotifyDelete

func (l *CESList) NotifyDelete(ces *cilium_v2a1.CiliumEndpointSlice)

NotifyDelete notifies all the subscribers of a delete event to an object.

func (*CESList) NotifyUpdate

func (l *CESList) NotifyUpdate(oldCES, newCES *cilium_v2a1.CiliumEndpointSlice)

NotifyUpdate notifies all the subscribers of an update event to an object.

func (*CESList) Register

func (l *CESList) Register(c CESHandler)

Register registers the CES event handler as a subscriber.

type CiliumNode

type CiliumNode interface {
	OnAddCiliumNode(node *ciliumv2.CiliumNode, swg *lock.StoppableWaitGroup) error
	OnUpdateCiliumNode(oldObj, newObj *ciliumv2.CiliumNode, swg *lock.StoppableWaitGroup) error
	OnDeleteCiliumNode(node *ciliumv2.CiliumNode, swg *lock.StoppableWaitGroup) error
}

CiliumNode is implemented by event handlers responding to CiliumNode events.

type CiliumNodeChain

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

CiliumNodeChain holds the subsciber.CiliumNode implementations that are notified when reacting to CiliumNode resource / object changes in the K8s watchers.

CiliumNodeChain itself is an implementation of subscriber.CiliumNodeChain with an additional Register method for attaching children subscribers to the chain.

func NewCiliumNodeChain

func NewCiliumNodeChain() *CiliumNodeChain

NewCiliumNodeChain creates a CiliumNodeChain ready for its Register method to be called.

func (*CiliumNodeChain) OnAddCiliumNode

func (l *CiliumNodeChain) OnAddCiliumNode(node *ciliumv2.CiliumNode, swg *lock.StoppableWaitGroup) error

OnAddCiliumNode notifies all the subscribers of an add event to a CiliumNode.

func (*CiliumNodeChain) OnDeleteCiliumNode

func (l *CiliumNodeChain) OnDeleteCiliumNode(node *ciliumv2.CiliumNode, swg *lock.StoppableWaitGroup) error

OnDeleteCiliumNode notifies all the subscribers of an update event to a CiliumNode.

func (*CiliumNodeChain) OnUpdateCiliumNode

func (l *CiliumNodeChain) OnUpdateCiliumNode(oldNode, newNode *ciliumv2.CiliumNode, swg *lock.StoppableWaitGroup) error

OnUpdateCiliumNode notifies all the subscribers of an update event to a CiliumNode.

func (*CiliumNodeChain) Register

func (l *CiliumNodeChain) Register(s CiliumNode)

Register registers s as a subscriber for reacting to CiliumNode objects into the list.

type Node

type Node interface {
	OnAddNode(*v1.Node, *lock.StoppableWaitGroup) error
	OnUpdateNode(oldObj, newObj *v1.Node, swg *lock.StoppableWaitGroup) error
	OnDeleteNode(*v1.Node, *lock.StoppableWaitGroup) error
}

Node is implemented by event handlers responding to K8s Node events.

type NodeChain

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

NodeChain holds the subsciber.Node implementations that are notified when reacting to K8s Node resource / object changes in the K8s watchers.

NodeChain itself is an implementation of subscriber.Node with an additional Register method for attaching children subscribers to the chain.

func NewNodeChain

func NewNodeChain() *NodeChain

NewNodeChain creates a NodeChain ready for it's Register method to be called.

func (*NodeChain) OnAddNode

func (l *NodeChain) OnAddNode(node *v1.Node, swg *lock.StoppableWaitGroup) error

NotifyAdd notifies all the subscribers of an add event to a service.

func (*NodeChain) OnDeleteNode

func (l *NodeChain) OnDeleteNode(node *v1.Node, swg *lock.StoppableWaitGroup) error

NotifyDelete notifies all the subscribers of an update event to a service.

func (*NodeChain) OnUpdateNode

func (l *NodeChain) OnUpdateNode(oldNode, newNode *v1.Node,
	swg *lock.StoppableWaitGroup) error

NotifyUpdate notifies all the subscribers of an update event to a service.

func (*NodeChain) Register

func (l *NodeChain) Register(s Node)

Register registers NodeHandler as a subscriber for reacting to Node objects into the list.

type RawChain

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

RawChain holds the raw subscribers to any K8s resource / object changes in the K8s watchers.

RawChain itself is an implementation of cache.ResourceEventHandler with an additional Register method for attaching children subscribers to the chain.

func NewRawChain

func NewRawChain() *RawChain

NewRaw creates a new raw subscriber list.

func (*RawChain) OnAdd

func (l *RawChain) OnAdd(obj interface{})

NotifyAdd notifies all the subscribers of an add event to an object.

func (*RawChain) OnDelete

func (l *RawChain) OnDelete(obj interface{})

NotifyDelete notifies all the subscribers of an update event to an object.

func (*RawChain) OnUpdate

func (l *RawChain) OnUpdate(oldObj, newObj interface{})

NotifyUpdate notifies all the subscribers of an update event to an object.

func (*RawChain) Register

func (l *RawChain) Register(cb cache.ResourceEventHandler)

Register registers the raw event handler as a subscriber.

type Service

type Service interface {
	OnAddService(*slim_corev1.Service) error
	OnUpdateService(oldObj, newObj *slim_corev1.Service) error
	OnDeleteService(*slim_corev1.Service) error
}

Service is implemented by event handlers responding to K8s Service events.

type ServiceChain

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

ServiceChain holds the subscriber.Service implementations that are notified when reacting to K8s Service resource / object changes in the K8s watchers.

ServiceChain itself is an implementation of subscriber.Service with an additional Register method for attaching children subscribers to the chain.

func NewServiceChain

func NewServiceChain() *ServiceChain

NewServiceChain

func (*ServiceChain) OnAddService

func (l *ServiceChain) OnAddService(svc *slim_corev1.Service) error

OnAddService notifies all the subscribers of an add event to a service.

func (*ServiceChain) OnDeleteService

func (l *ServiceChain) OnDeleteService(svc *slim_corev1.Service) error

OnDeleteService notifies all the subscribers of an update event to a service.

func (*ServiceChain) OnUpdateService

func (l *ServiceChain) OnUpdateService(oldSvc, newSvc *slim_corev1.Service) error

OnUpdateService notifies all the subscribers of an update event to a service.

func (*ServiceChain) Register

func (l *ServiceChain) Register(s Service)

Register registers ServiceHandler as a subscriber for reacting to Service objects into the list.