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 RawList
  • func NewRaw() *RawList
  • func (l *RawList) NotifyAdd(obj interface{})
  • func (l *RawList) NotifyDelete(obj interface{})
  • func (l *RawList) NotifyUpdate(oldObj, newObj interface{})
  • func (l *RawList) Register(cb cache.ResourceEventHandler)
• type ServiceHandler
• type ServiceList
  • func NewService() *ServiceList
  • func (l *ServiceList) NotifyAdd(svc *slim_corev1.Service)
  • func (l *ServiceList) NotifyDelete(svc *slim_corev1.Service)
  • func (l *ServiceList) NotifyUpdate(oldSvc, newSvc *slim_corev1.Service)
  • func (l *ServiceList) Register(s ServiceHandler)

Types

type RawList

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

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

func NewRaw

func NewRaw() *RawList

NewRaw creates a new raw subscriber list.

func (*RawList) NotifyAdd

func (l *RawList) NotifyAdd(obj interface{})

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

func (*RawList) NotifyDelete

func (l *RawList) NotifyDelete(obj interface{})

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

func (*RawList) NotifyUpdate

func (l *RawList) NotifyUpdate(oldObj, newObj interface{})

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

func (*RawList) Register

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

Register registers the raw event handler as a subscriber.

type ServiceHandler

type ServiceHandler interface {
	OnAdd(*slim_corev1.Service)
	OnUpdate(oldObj, newObj *slim_corev1.Service)
	OnDelete(*slim_corev1.Service)
}

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

type ServiceList

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

ServiceList holds the ServiceHandler subscribers that are notified when reacting to K8s Service resource / object changes in the K8s watchers.

func NewService

func NewService() *ServiceList

NewService creates a new subscriber list for ServiceHandlers.

func (*ServiceList) NotifyAdd

func (l *ServiceList) NotifyAdd(svc *slim_corev1.Service)

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

func (*ServiceList) NotifyDelete

func (l *ServiceList) NotifyDelete(svc *slim_corev1.Service)

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

func (*ServiceList) NotifyUpdate

func (l *ServiceList) NotifyUpdate(oldSvc, newSvc *slim_corev1.Service)

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

func (*ServiceList) Register

func (l *ServiceList) Register(s ServiceHandler)

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