outgoing

Documentation

Overview

Package outgoing contains the logic to configure the reflection of target objects from the home cluster to a foreign cluster

Index

• Variables
• type ConfigmapsReflector
  • func (r *ConfigmapsReflector) CleanupNamespace(localNamespace string)
  • func (r *ConfigmapsReflector) HandleEvent(e interface{})
  • func (r *ConfigmapsReflector) PreAdd(obj interface{}) (interface{}, watch.EventType)
  • func (r *ConfigmapsReflector) PreDelete(obj interface{}) (interface{}, watch.EventType)
  • func (r *ConfigmapsReflector) PreUpdate(newObj, _ interface{}) (interface{}, watch.EventType)
  • func (r *ConfigmapsReflector) SetSpecializedPreProcessingHandlers()
• type EndpointSlicesReflector
  • func (r *EndpointSlicesReflector) CleanupNamespace(localNamespace string)
  • func (r *EndpointSlicesReflector) HandleEvent(e interface{})
  • func (r *EndpointSlicesReflector) PreAdd(obj interface{}) (interface{}, watch.EventType)
  • func (r *EndpointSlicesReflector) PreDelete(obj interface{}) (interface{}, watch.EventType)
  • func (r *EndpointSlicesReflector) PreUpdate(newObj, _ interface{}) (interface{}, watch.EventType)
  • func (r *EndpointSlicesReflector) SetSpecializedPreProcessingHandlers()
• type SecretsReflector
  • func (r *SecretsReflector) CleanupNamespace(localNamespace string)
  • func (r *SecretsReflector) HandleEvent(e interface{})
  • func (r *SecretsReflector) PreAdd(obj interface{}) (interface{}, watch.EventType)
  • func (r *SecretsReflector) PreDelete(obj interface{}) (interface{}, watch.EventType)
  • func (r *SecretsReflector) PreUpdate(newObj interface{}, _ interface{}) (interface{}, watch.EventType)
  • func (r *SecretsReflector) SetSpecializedPreProcessingHandlers()
• type ServicesReflector
  • func (r *ServicesReflector) CleanupNamespace(localNamespace string)
  • func (r *ServicesReflector) HandleEvent(e interface{})
  • func (r *ServicesReflector) PreAdd(obj interface{}) (interface{}, watch.EventType)
  • func (r *ServicesReflector) PreDelete(obj interface{}) (interface{}, watch.EventType)
  • func (r *ServicesReflector) PreUpdate(newObj interface{}, _ interface{}) (interface{}, watch.EventType)
  • func (r *ServicesReflector) SetSpecializedPreProcessingHandlers()

Variables

var ReflectorBuilders = map[apimgmt.ApiType]func(reflector ri.APIReflector, opts map[options.OptionKey]options.Option) ri.OutgoingAPIReflector{
	apimgmt.Configmaps:     configmapsReflectorBuilder,
	apimgmt.EndpointSlices: endpointslicesReflectorBuilder,
	apimgmt.Secrets:        secretsReflectorBuilder,
	apimgmt.Services:       servicesReflectorBuilder,
}

Types

type ConfigmapsReflector

type ConfigmapsReflector struct {
	ri.APIReflector
}

func (*ConfigmapsReflector) CleanupNamespace

func (r *ConfigmapsReflector) CleanupNamespace(localNamespace string)

func (*ConfigmapsReflector) HandleEvent

func (r *ConfigmapsReflector) HandleEvent(e interface{})

func (*ConfigmapsReflector) PreAdd

func (r *ConfigmapsReflector) PreAdd(obj interface{}) (interface{}, watch.EventType)

func (*ConfigmapsReflector) PreDelete

func (r *ConfigmapsReflector) PreDelete(obj interface{}) (interface{}, watch.EventType)

func (*ConfigmapsReflector) PreUpdate

func (r *ConfigmapsReflector) PreUpdate(newObj, _ interface{}) (interface{}, watch.EventType)

func (*ConfigmapsReflector) SetSpecializedPreProcessingHandlers

func (r *ConfigmapsReflector) SetSpecializedPreProcessingHandlers()

type EndpointSlicesReflector

type EndpointSlicesReflector struct {
	ri.APIReflector

	VirtualNodeName options.ReadOnlyOption
	IpamClient      liqonetIpam.IpamClient
}

func (*EndpointSlicesReflector) CleanupNamespace

func (r *EndpointSlicesReflector) CleanupNamespace(localNamespace string)

func (*EndpointSlicesReflector) HandleEvent

func (r *EndpointSlicesReflector) HandleEvent(e interface{})

func (*EndpointSlicesReflector) PreAdd

func (r *EndpointSlicesReflector) PreAdd(obj interface{}) (interface{}, watch.EventType)

func (*EndpointSlicesReflector) PreDelete

func (r *EndpointSlicesReflector) PreDelete(obj interface{}) (interface{}, watch.EventType)

func (*EndpointSlicesReflector) PreUpdate

func (r *EndpointSlicesReflector) PreUpdate(newObj, _ interface{}) (interface{}, watch.EventType)

func (*EndpointSlicesReflector) SetSpecializedPreProcessingHandlers

func (r *EndpointSlicesReflector) SetSpecializedPreProcessingHandlers()

type SecretsReflector

type SecretsReflector struct {
	ri.APIReflector
}

func (*SecretsReflector) CleanupNamespace

func (r *SecretsReflector) CleanupNamespace(localNamespace string)

func (*SecretsReflector) HandleEvent

func (r *SecretsReflector) HandleEvent(e interface{})

func (*SecretsReflector) PreAdd

func (r *SecretsReflector) PreAdd(obj interface{}) (interface{}, watch.EventType)

func (*SecretsReflector) PreDelete

func (r *SecretsReflector) PreDelete(obj interface{}) (interface{}, watch.EventType)

func (*SecretsReflector) PreUpdate

func (r *SecretsReflector) PreUpdate(newObj interface{}, _ interface{}) (interface{}, watch.EventType)

func (*SecretsReflector) SetSpecializedPreProcessingHandlers

func (r *SecretsReflector) SetSpecializedPreProcessingHandlers()

type ServicesReflector

type ServicesReflector struct {
	ri.APIReflector
}

func (*ServicesReflector) CleanupNamespace

func (r *ServicesReflector) CleanupNamespace(localNamespace string)

func (*ServicesReflector) HandleEvent

func (r *ServicesReflector) HandleEvent(e interface{})

func (*ServicesReflector) PreAdd

func (r *ServicesReflector) PreAdd(obj interface{}) (interface{}, watch.EventType)

func (*ServicesReflector) PreDelete

func (r *ServicesReflector) PreDelete(obj interface{}) (interface{}, watch.EventType)

func (*ServicesReflector) PreUpdate

func (r *ServicesReflector) PreUpdate(newObj interface{}, _ interface{}) (interface{}, watch.EventType)

func (*ServicesReflector) SetSpecializedPreProcessingHandlers

func (r *ServicesReflector) SetSpecializedPreProcessingHandlers()