syncer

Documentation

Index

• func NewTranslatorSyncer(translator translator.Translator, xdsCache envoycache.SnapshotCache, ...) v1snap.ApiSyncer
• type MockXdsCache
  • func (*MockXdsCache) ClearSnapshot(node string)
  • func (*MockXdsCache) CreateWatch(envoycache.Request) (value chan envoycache.Response, cancel func())
  • func (*MockXdsCache) Fetch(context.Context, envoycache.Request) (*envoycache.Response, error)
  • func (c *MockXdsCache) GetSnapshot(node string) (envoycache.Snapshot, error)
  • func (*MockXdsCache) GetStatusInfo(string) envoycache.StatusInfo
  • func (c *MockXdsCache) GetStatusKeys() []string
  • func (c *MockXdsCache) SetSnapshot(node string, snapshot envoycache.Snapshot)
• type MockXdsSanitizer
  • func (s *MockXdsSanitizer) SanitizeSnapshot(ctx context.Context, glooSnapshot *v1snap.ApiSnapshot, ...) envoycache.Snapshot
• type TranslatorSyncerExtension
• type TranslatorSyncerExtensionFactory
• type TranslatorSyncerExtensionParams
• type UpgradeableTranslatorSyncerExtension

Functions

func NewTranslatorSyncer

func NewTranslatorSyncer(
	translator translator.Translator,
	xdsCache envoycache.SnapshotCache,
	xdsHasher *xds.ProxyKeyHasher,
	sanitizer sanitizer.XdsSanitizer,
	reporter reporter.StatusReporter,
	devMode bool,
	extensions []TranslatorSyncerExtension,
	settings *v1.Settings,
	statusMetrics metrics.ConfigStatusMetrics,
	gatewaySyncer *gwsyncer.TranslatorSyncer,
	proxyClient v1.ProxyClient,
	writeNamespace string,
) v1snap.ApiSyncer

Types

type MockXdsCache

type MockXdsCache struct {
	Called bool
	// Snap that is set
	SetSnap envoycache.Snapshot
	// Snap that is returned
	GetSnap envoycache.Snapshot
}

func (*MockXdsCache) ClearSnapshot

func (*MockXdsCache) ClearSnapshot(node string)

func (*MockXdsCache) CreateWatch

func (*MockXdsCache) CreateWatch(envoycache.Request) (value chan envoycache.Response, cancel func())

func (*MockXdsCache) Fetch

func (*MockXdsCache) Fetch(context.Context, envoycache.Request) (*envoycache.Response, error)

func (*MockXdsCache) GetSnapshot

func (c *MockXdsCache) GetSnapshot(node string) (envoycache.Snapshot, error)

func (*MockXdsCache) GetStatusInfo

func (*MockXdsCache) GetStatusInfo(string) envoycache.StatusInfo

func (*MockXdsCache) GetStatusKeys

func (c *MockXdsCache) GetStatusKeys() []string

func (*MockXdsCache) SetSnapshot

func (c *MockXdsCache) SetSnapshot(node string, snapshot envoycache.Snapshot)

type MockXdsSanitizer

type MockXdsSanitizer struct {
	Called bool
	Snap   envoycache.Snapshot
}

func (*MockXdsSanitizer) SanitizeSnapshot

func (s *MockXdsSanitizer) SanitizeSnapshot(ctx context.Context, glooSnapshot *v1snap.ApiSnapshot, xdsSnapshot envoycache.Snapshot, reports reporter.ResourceReports) envoycache.Snapshot

type TranslatorSyncerExtension

type TranslatorSyncerExtension interface {
	Sync(
		ctx context.Context,
		snap *v1snap.ApiSnapshot,
		settings *v1.Settings,
		xdsCache envoycache.SnapshotCache,
		reports reporter.ResourceReports,
	) (string, error)
}

TODO(kdorosh) in follow up PR, update this interface so it can never error It is logically invalid for us to return an error here (translation of resources always needs to result in a xds snapshot, so we are resilient to pod restarts)

type TranslatorSyncerExtensionFactory

type TranslatorSyncerExtensionFactory func(context.Context, TranslatorSyncerExtensionParams) (TranslatorSyncerExtension, error)

type TranslatorSyncerExtensionParams

type TranslatorSyncerExtensionParams struct {
	RateLimitServiceSettings ratelimit.ServiceSettings
}

type UpgradeableTranslatorSyncerExtension

type UpgradeableTranslatorSyncerExtension interface {
	ExtensionName() string
	IsUpgrade() bool
}