registration

Documentation

Index

• func RunConfigLoop(ctx context.Context, enabledFeatures EnabledConfigLoops, ...) error
• func RunEventLoop(ctx context.Context, loop eventloop.EventLoop, opts clients.WatchOpts) error
• type ConfigLoopStarter
• type ConfigLoopStarters
• type EnabledConfigLoops
• type RegistrationSyncer
  • func NewRegistrationSyncer(configLoop ...ConfigLoopStarter) *RegistrationSyncer
  • func (s *RegistrationSyncer) Sync(ctx context.Context, snap *v1.RegistrationSnapshot) error

Functions

func RunConfigLoop

func RunConfigLoop(ctx context.Context, enabledFeatures EnabledConfigLoops, starter ConfigLoopStarter) error

func RunEventLoop

func RunEventLoop(ctx context.Context, loop eventloop.EventLoop, opts clients.WatchOpts) error

Types

type ConfigLoopStarter

type ConfigLoopStarter func(ctx context.Context, enabled EnabledConfigLoops) (eventloop.EventLoop, error)

type ConfigLoopStarters

type ConfigLoopStarters []ConfigLoopStarter

type EnabledConfigLoops

type EnabledConfigLoops struct {
	Istio   bool
	Gloo    bool
	AppMesh bool
}

type RegistrationSyncer

type RegistrationSyncer struct {
	// contains filtered or unexported fields
}

registration syncer, activates config syncers based on registered meshes enables istio config syncer as long as there's a registered istio mesh

func NewRegistrationSyncer

func NewRegistrationSyncer(configLoop ...ConfigLoopStarter) *RegistrationSyncer

func (*RegistrationSyncer) Sync

func (s *RegistrationSyncer) Sync(ctx context.Context, snap *v1.RegistrationSnapshot) error