syncer

Documentation

Index

• func Setup(ctx context.Context, kubeCache kube.SharedCache, ...) error
• type TranslatorSyncer
  • func NewTranslatorSyncer(ctx context.Context, writeNamespace string, proxyWatcher gloov1.ProxyClient, ...) *TranslatorSyncer
  • func (s *TranslatorSyncer) GeneratedDesiredProxies(ctx context.Context, snap *gloov1snap.ApiSnapshot) (reconciler.GeneratedProxies, reconciler.InvalidProxies)
  • func (s *TranslatorSyncer) Sync(ctx context.Context, snap *gloov1snap.ApiSnapshot) error
  • func (s *TranslatorSyncer) UpdateProxies(ctx context.Context)

Functions

func Setup

func Setup(ctx context.Context, kubeCache kube.SharedCache, inMemoryCache memory.InMemoryResourceCache, settings *gloov1.Settings) error

Types

type TranslatorSyncer

type TranslatorSyncer struct {
	// contains filtered or unexported fields
}

func NewTranslatorSyncer

func NewTranslatorSyncer(ctx context.Context, writeNamespace string, proxyWatcher gloov1.ProxyClient, proxyReconciler reconciler.ProxyReconciler, reporter reporter.StatusReporter, translator translator.Translator, statusClient resources.StatusClient, statusMetrics metrics.ConfigStatusMetrics) *TranslatorSyncer

func (*TranslatorSyncer) GeneratedDesiredProxies

func (s *TranslatorSyncer) GeneratedDesiredProxies(ctx context.Context, snap *gloov1snap.ApiSnapshot) (reconciler.GeneratedProxies, reconciler.InvalidProxies)

func (*TranslatorSyncer) Sync

func (s *TranslatorSyncer) Sync(ctx context.Context, snap *gloov1snap.ApiSnapshot) error

TODO (ilackarms): make sure that sync happens if proxies get updated as well; may need to resync

func (*TranslatorSyncer) UpdateProxies

func (s *TranslatorSyncer) UpdateProxies(ctx context.Context)

This replaced a watch on the proxy CR from when the gloo and gateway pods were separate Now it is called at the end of the gloo translation loop after statuses have been set for proxies This is where we update statuses on gateway types based on the proxy statuses