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(obj interface{})
  • func (r *GenericAPIReflector) SetInforming(handler func(interface{}))
  • 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

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(obj interface{})

func (*GenericAPIReflector) SetInforming

func (r *GenericAPIReflector) SetInforming(handler func(interface{}))

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)