sync

Apr 23, 2024

Changes in this version

+ func CascadeDeletion(ctx context.Context, k8sClient client.Client, cache LiveStateCache, ...) error

+ func GetLiveManagedObjects(cache LiveStateCache, gitSync *v1alpha1.GitSync) (map[kube.ResourceKey]*unstructured.Unstructured, error)

+ func KeyOfGitSync(gitSync *v1alpha1.GitSync) string

+ func NewIgnoreNormalizer(overrides map[string]ResourceOverride) (diff.Normalizer, error)

+ func NewNoopNormalizer() diff.Normalizer

+ func ProcessGitSyncDeletion(ctx context.Context, gitSync *v1alpha1.GitSync, s *Syncer) error

+ func StateDiffs(configs, lives []*unstructured.Unstructured, ...) (*diff.DiffResultList, error)

+ type LiveStateCache interface

+ GetClusterCache func() (clustercache.ClusterCache, error)

+ GetManagedLiveObjs func(gitsync *v1alpha1.GitSync, targetObjs []*unstructured.Unstructured) (map[kube.ResourceKey]*unstructured.Unstructured, error)

+ Init func(numaLogger *logger.NumaLogger) error

+ PopulateResourceInfo func(un *unstructured.Unstructured, isRoot bool) (interface{}, bool)

+ func NewLiveStateCache(clusterCacheConfig *rest.Config) LiveStateCache

+ type NoopNormalizer struct

+ func (n *NoopNormalizer) Normalize(un *unstructured.Unstructured) error

+ type ObjectUpdatedHandler = func(managedByGitSync map[string]bool, ref v1.ObjectReference)

+ type Option func(*options)

+ func WithTaskInterval(n int) Option

+ func WithWorkers(n int) Option

+ type OverrideIgnoreDiff struct

+ JSONPointers []string

+ type ResourceFilter struct

+ func (n *ResourceFilter) IsExcludedResource(group, kind, _ string) bool

+ type ResourceIgnoreDifferences struct

+ Group string

+ JSONPointers []string

+ Kind string

+ Name string

+ Namespace string

+ type ResourceInfo struct

+ GitSyncName string

+ Health *health.HealthStatus

+ type ResourceOverride struct

+ IgnoreDifferences OverrideIgnoreDiff

+ type ResourceType struct

+ Group string

+ Kind string

+ type Syncer struct

+ func NewSyncer(client client.Client, config *rest.Config, rawConfig *rest.Config, ...) *Syncer

+ func (s *Syncer) Contains(key string) bool

+ func (s *Syncer) Length() int

+ func (s *Syncer) Start(ctx context.Context) error

+ func (s *Syncer) StartWatching(key string)

+ func (s *Syncer) StopWatching(key string)