context

Documentation

Index

• func CompositeResourceMapper(mappers ...reconcile.ResourceMapper) reconcile.ResourceMapper
• func GlobalProvidedFilter(rm manager.ResourceManager, configs map[string]bool) reconcile.ResourceFilter
• func HashSuffixMapper(checkDDSFeature bool, labelsToUse ...string) reconcile.ResourceMapper
• func MapInsightResourcesZeroGeneration(_ dds.Features, r core_model.Resource) (core_model.Resource, error)
• func RemoveK8sSystemNamespaceSuffixMapper(k8sSystemNamespace string) reconcile.ResourceMapper
• func UpdateResourceMeta(fs ...util.CloneResourceMetaOpt) reconcile.ResourceMapper
• func ZoneProvidedFilter(_ context.Context, _ string, _ dds.Features, r core_model.Resource) bool
• type Context
  • func DefaultContext(ctx context.Context, manager manager.ResourceManager, cfg dubbo_cp.Config) *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

func HashSuffixMapper

func HashSuffixMapper(checkDDSFeature bool, labelsToUse ...string) reconcile.ResourceMapper

HashSuffixMapper returns mapper that adds a hash suffix to the name during DDS sync

func MapInsightResourcesZeroGeneration

func MapInsightResourcesZeroGeneration(_ dds.Features, r core_model.Resource) (core_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 RemoveK8sSystemNamespaceSuffixMapper

func RemoveK8sSystemNamespaceSuffixMapper(k8sSystemNamespace string) reconcile.ResourceMapper

RemoveK8sSystemNamespaceSuffixMapper is a mapper responsible for removing control plane system namespace suffixes from names of resources if resources are stored in kubernetes.

func UpdateResourceMeta

func UpdateResourceMeta(fs ...util.CloneResourceMetaOpt) reconcile.ResourceMapper

func ZoneProvidedFilter

func ZoneProvidedFilter(_ context.Context, _ string, _ dds.Features, r core_model.Resource) bool

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

	ServerStreamInterceptors []grpc.StreamServerInterceptor
	ServerUnaryInterceptor   []grpc.UnaryServerInterceptor
}

func DefaultContext

func DefaultContext(
	ctx context.Context,
	manager manager.ResourceManager,
	cfg dubbo_cp.Config,
) *Context