context

Documentation

Index

• func CompositeResourceMapper(mappers ...reconcile.ResourceMapper) reconcile.ResourceMapper
• func GlobalProvidedFilter(rm manager.ResourceManager, configs map[string]bool) reconcile.ResourceFilter
• func MapInsightResourcesZeroGeneration(r model.Resource) (model.Resource, error)
• func MapZoneTokenSigningKeyGlobalToPublicKey(_ context.Context, _ manager.ResourceManager) reconcile.ResourceMapper
• func ZoneProvidedFilter(clusterName string) reconcile.ResourceFilter
• type Context
  • func DefaultContext(manager manager.ResourceManager, zone string) *Context

Functions

func CompositeResourceMapper

func CompositeResourceMapper(mappers ...reconcile.ResourceMapper) reconcile.ResourceMapper

CompositeResourceMapper combines the given ResourceMappers into a single ResourceMapper which calls each in order. If an error occurs, the first one is returned and no further mappers are executed.

func GlobalProvidedFilter

func GlobalProvidedFilter(rm manager.ResourceManager, configs map[string]bool) reconcile.ResourceFilter

GlobalProvidedFilter returns ResourceFilter which filters Resources provided by Global, specifically excludes Dataplanes, Ingresses and Egresses from 'clusterID' cluster

func MapInsightResourcesZeroGeneration

func MapInsightResourcesZeroGeneration(r model.Resource) (model.Resource, error)

MapInsightResourcesZeroGeneration zeros "generation" field in resources for which the field has only local relevance. This prevents reconciliation from unnecessarily deeming the object to have changed.

func MapZoneTokenSigningKeyGlobalToPublicKey

func MapZoneTokenSigningKeyGlobalToPublicKey(
	_ context.Context,
	_ manager.ResourceManager,
) reconcile.ResourceMapper

func ZoneProvidedFilter

func ZoneProvidedFilter(clusterName string) reconcile.ResourceFilter

ZoneProvidedFilter filter Resources provided by Zone, specifically Ingresses that belongs to another zones

Types

type Context

type Context struct {
	ZoneClientCtx        context.Context
	GlobalProvidedFilter reconcile.ResourceFilter
	ZoneProvidedFilter   reconcile.ResourceFilter
	GlobalServerFilters  []mux.Filter
	// Configs contains the names of system.ConfigResource that will be transferred from Global to Zone
	Configs map[string]bool

	GlobalResourceMapper reconcile.ResourceMapper
	ZoneResourceMapper   reconcile.ResourceMapper

	EnvoyAdminRPCs service.EnvoyAdminRPCs
}

func DefaultContext

func DefaultContext(manager manager.ResourceManager, zone string) *Context