syncer

Documentation

Index

• func NewTranslatorSyncer(translator translator.Translator, xdsCache envoycache.SnapshotCache, ...) v1.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) error
• type MockXdsSanitizer
  • func (s *MockXdsSanitizer) SanitizeSnapshot(ctx context.Context, glooSnapshot *v1.ApiSnapshot, ...) (envoycache.Snapshot, error)
• 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,
) v1.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) error

type MockXdsSanitizer

type MockXdsSanitizer struct {
	Called bool
	Snap   envoycache.Snapshot
	Err    error
}

func (*MockXdsSanitizer) SanitizeSnapshot

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

type TranslatorSyncerExtension

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

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
}