syncer

Documentation

Index

• 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) UpdateStatusForAllProxies(ctx context.Context)

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, identity leaderelector.Identity) *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) UpdateStatusForAllProxies

func (s *TranslatorSyncer) UpdateStatusForAllProxies(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. After this method runs, all Proxies (those retrieved from the proxy client) will have their status written, along with the translation reports that correspond to the Gateway resources.