reflectors

Documentation

Index

• Variables
• type GenericAPIReflector
  • func (r *GenericAPIReflector) GetCacheManager() reflectionCache.CacheManagerReader
  • func (r *GenericAPIReflector) GetForeignClient() kubernetes.Interface
  • func (r *GenericAPIReflector) GetHomeClient() kubernetes.Interface
  • func (r *GenericAPIReflector) Inform(obj apimgmt.ApiEvent)
  • func (r *GenericAPIReflector) Keyer(namespace, name string) string
  • func (r *GenericAPIReflector) NattingTable() namespacesmapping.NamespaceNatter
  • func (r *GenericAPIReflector) PreProcessAdd(obj interface{}) (interface{}, watch.EventType)
  • func (r *GenericAPIReflector) PreProcessDelete(obj interface{}) (interface{}, watch.EventType)
  • func (r *GenericAPIReflector) PreProcessIsAllowed(ctx context.Context, obj interface{}) bool
  • func (r *GenericAPIReflector) PreProcessUpdate(newObj, oldObj interface{}) (interface{}, watch.EventType)
  • func (r *GenericAPIReflector) PushToInforming(pod *corev1.Pod)
  • func (r *GenericAPIReflector) SetInforming(handler func(*corev1.Pod))
  • func (r *GenericAPIReflector) SetPreProcessingHandlers(handlers ri.PreProcessingHandlers)
  • func (r *GenericAPIReflector) SetupHandlers(api apimgmt.ApiType, reflectionType ri.ReflectionType, ...)

Variables

var Blacklist = map[apimgmt.ApiType]blackListType{
	apimgmt.EndpointSlices: {
		"default/kubernetes": struct{}{},
	},
	apimgmt.Pods: {},
	apimgmt.Services: {
		"default/kubernetes": struct{}{},
	},
}

the blacklist is a map containing the objects that should not be managed by the reflectors. the blacklist is generally checked in the `isAllowed` method of the reflectors TODO: in a future version we could/should move to a dynamic blaklisting package with contexts.

Types

type GenericAPIReflector

type GenericAPIReflector struct {
	Api                   apimgmt.ApiType
	PreProcessingHandlers ri.PreProcessingHandlers
	OutputChan            chan apimgmt.ApiEvent

	ForeignClient kubernetes.Interface
	HomeClient    kubernetes.Interface

	CacheManager reflectionCache.CacheManagerReaderAdder

	NamespaceNatting namespacesmapping.NamespaceNatter
	// contains filtered or unexported fields
}

func (*GenericAPIReflector) GetCacheManager

func (r *GenericAPIReflector) GetCacheManager() reflectionCache.CacheManagerReader

func (*GenericAPIReflector) GetForeignClient

func (r *GenericAPIReflector) GetForeignClient() kubernetes.Interface

func (*GenericAPIReflector) GetHomeClient

func (r *GenericAPIReflector) GetHomeClient() kubernetes.Interface

func (*GenericAPIReflector) Inform

func (r *GenericAPIReflector) Inform(obj apimgmt.ApiEvent)

func (*GenericAPIReflector) Keyer

func (r *GenericAPIReflector) Keyer(namespace, name string) string

func (*GenericAPIReflector) NattingTable

func (r *GenericAPIReflector) NattingTable() namespacesmapping.NamespaceNatter

NattingTable returns a namespaceNatter object to handle namespace translations.

func (*GenericAPIReflector) PreProcessAdd

func (r *GenericAPIReflector) PreProcessAdd(obj interface{}) (interface{}, watch.EventType)

func (*GenericAPIReflector) PreProcessDelete

func (r *GenericAPIReflector) PreProcessDelete(obj interface{}) (interface{}, watch.EventType)

func (*GenericAPIReflector) PreProcessIsAllowed

func (r *GenericAPIReflector) PreProcessIsAllowed(ctx context.Context, obj interface{}) bool

func (*GenericAPIReflector) PreProcessUpdate

func (r *GenericAPIReflector) PreProcessUpdate(newObj, oldObj interface{}) (interface{}, watch.EventType)

func (*GenericAPIReflector) PushToInforming

func (r *GenericAPIReflector) PushToInforming(pod *corev1.Pod)

PushToInforming pushes a pod to the informing function.

func (*GenericAPIReflector) SetInforming

func (r *GenericAPIReflector) SetInforming(handler func(*corev1.Pod))

SetInforming configures the handlers triggered for a certain API type by incoming reflection events.

func (*GenericAPIReflector) SetPreProcessingHandlers

func (r *GenericAPIReflector) SetPreProcessingHandlers(handlers ri.PreProcessingHandlers)

func (*GenericAPIReflector) SetupHandlers

func (r *GenericAPIReflector) SetupHandlers(api apimgmt.ApiType, reflectionType ri.ReflectionType, namespace, nattedNs string)