syncer

Documentation

Index

• Variables
• func GetPluginsWithExtensions(opts bootstrap.Opts, extensions Extensions) func() []plugins.Plugin
• func GetPluginsWithExtensionsAndRegistry(opts bootstrap.Opts, ...) func() []plugins.Plugin
• func NewControlPlane(ctx context.Context, grpcServer *grpc.Server, bindAddr net.Addr, ...) bootstrap.ControlPlane
• func NewSetupFunc() setuputils.SetupFunc
• func NewSetupFuncWithExtensions(extensions Extensions) setuputils.SetupFunc
• func NewSetupFuncWithRun(runFunc RunFunc) setuputils.SetupFunc
• func NewSetupFuncWithRunAndExtensions(runFunc RunFunc, extensions *Extensions) setuputils.SetupFunc
• func NewTranslatorSyncer(translator translator.Translator, xdsCache envoycache.SnapshotCache, ...) v1.ApiSyncer
• func NewValidationServer(ctx context.Context, grpcServer *grpc.Server, bindAddr net.Addr, start bool) bootstrap.ValidationServer
• func RunGloo(opts bootstrap.Opts) error
• func RunGlooWithExtensions(opts bootstrap.Opts, extensions Extensions) error
• type Extensions
• 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 RunFunc
• type TranslatorSyncerExtension
• type TranslatorSyncerExtensionFactory
• type TranslatorSyncerExtensionParams

Variables

var (
	DefaultXdsBindAddr        = fmt.Sprintf("0.0.0.0:%v", defaults.GlooXdsPort)
	DefaultValidationBindAddr = fmt.Sprintf("0.0.0.0:%v", defaults.GlooValidationPort)
	DefaultRestXdsBindAddr    = fmt.Sprintf("0.0.0.0:%v", defaults.GlooRestXdsPort)
)

Functions

func GetPluginsWithExtensions

func GetPluginsWithExtensions(opts bootstrap.Opts, extensions Extensions) func() []plugins.Plugin

func GetPluginsWithExtensionsAndRegistry

func GetPluginsWithExtensionsAndRegistry(opts bootstrap.Opts, registryPlugins func(opts bootstrap.Opts) []plugins.Plugin, extensions Extensions) func() []plugins.Plugin

func NewControlPlane

func NewControlPlane(ctx context.Context, grpcServer *grpc.Server, bindAddr net.Addr, callbacks xdsserver.Callbacks, start bool) bootstrap.ControlPlane

func NewSetupFunc

func NewSetupFunc() setuputils.SetupFunc

func NewSetupFuncWithExtensions

func NewSetupFuncWithExtensions(extensions Extensions) setuputils.SetupFunc

used outside of this repo noinspection GoUnusedExportedFunction

func NewSetupFuncWithRun

func NewSetupFuncWithRun(runFunc RunFunc) setuputils.SetupFunc

for use by UDS, FDS, other v1.SetupSyncers

func NewSetupFuncWithRunAndExtensions

func NewSetupFuncWithRunAndExtensions(runFunc RunFunc, extensions *Extensions) setuputils.SetupFunc

func NewTranslatorSyncer

func NewTranslatorSyncer(
	translator translator.Translator,
	xdsCache envoycache.SnapshotCache,
	xdsHasher *xds.ProxyKeyHasher,
	sanitizer sanitizer.XdsSanitizer,
	reporter reporter.Reporter,
	devMode bool,
	extensions []TranslatorSyncerExtension,
	settings *v1.Settings,
) v1.ApiSyncer

func NewValidationServer

func NewValidationServer(ctx context.Context, grpcServer *grpc.Server, bindAddr net.Addr, start bool) bootstrap.ValidationServer

func RunGloo

func RunGloo(opts bootstrap.Opts) error

func RunGlooWithExtensions

func RunGlooWithExtensions(opts bootstrap.Opts, extensions Extensions) error

Types

type Extensions

type Extensions struct {
	// Deprecated. Use PluginExtensionsFuncs instead.
	PluginExtensions      []plugins.Plugin
	PluginExtensionsFuncs []func() plugins.Plugin
	SyncerExtensions      []TranslatorSyncerExtensionFactory
	XdsCallbacks          xdsserver.Callbacks
}

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 RunFunc

type RunFunc func(opts bootstrap.Opts) error

type TranslatorSyncerExtension

type TranslatorSyncerExtension interface {
	Sync(
		ctx context.Context,
		snap *v1.ApiSnapshot,
		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
}