syncer

Documentation

Index

• func BootstrapFactories(ctx context.Context, clientset *kubernetes.Interface, ...) (bootstrap.Opts, error)
• func NewControlPlane(ctx context.Context, grpcServer *grpc.Server, callbacks xdsserver.Callbacks, ...) 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 RunGloo(opts bootstrap.Opts) error
• func RunGlooWithExtensions(opts bootstrap.Opts, extensions Extensions) error
• type Extensions
• type RunFunc
• type TranslatorSyncerExtension
• type TranslatorSyncerExtensionFactory
• type TranslatorSyncerExtensionParams

Functions

func BootstrapFactories

func BootstrapFactories(ctx context.Context, clientset *kubernetes.Interface, kubeCache kube.SharedCache, memCache memory.InMemoryResourceCache, settings *v1.Settings) (bootstrap.Opts, error)

func NewControlPlane

func NewControlPlane(ctx context.Context, grpcServer *grpc.Server, 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

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, reporter reporter.Reporter, devMode bool, extensions []TranslatorSyncerExtension) v1.ApiSyncer

func RunGloo

func RunGloo(opts bootstrap.Opts) error

func RunGlooWithExtensions

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

Types

type Extensions

type Extensions struct {
	PluginExtensions []plugins.Plugin
	SyncerExtensions []TranslatorSyncerExtensionFactory
	XdsCallbacks     xdsserver.Callbacks
}

type RunFunc

type RunFunc func(opts bootstrap.Opts) error

type TranslatorSyncerExtension

type TranslatorSyncerExtension interface {
	Sync(ctx context.Context, snap *v1.ApiSnapshot, xdsCache envoycache.SnapshotCache) error
}

type TranslatorSyncerExtensionFactory

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

type TranslatorSyncerExtensionParams

type TranslatorSyncerExtensionParams struct {
	SettingExtensions *v1.Extensions
}