registration

Documentation

Index

• func RunConfigLoop(ctx context.Context, enabledFeatures EnabledConfigLoops, ...) error
• func RunEventLoop(ctx context.Context, loop eventloop.EventLoop, opts clients.WatchOpts) error
• type ConfigLoop
• type ConfigLoopStarter
• type EnabledConfigLoops
• type PubSub
  • func NewPubsub() *PubSub
• type Receiver
• type RegistrationSyncer
  • func NewRegistrationSyncer(pubSub *PubSub) *RegistrationSyncer
  • func (s *RegistrationSyncer) Sync(ctx context.Context, snap *v1.RegistrationSnapshot) error
• type Subscriber
  • func NewSubscriber(ctx context.Context, pubsub *PubSub, cl ConfigLoop) *Subscriber
  • func (l *Subscriber) Listen(parentCtx context.Context)

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 ConfigLoop

type ConfigLoop interface {
	Enabled(enabled EnabledConfigLoops) bool
	Start(ctx context.Context, enabled EnabledConfigLoops) (eventloop.EventLoop, error)
}

type ConfigLoopStarter

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

type EnabledConfigLoops

type EnabledConfigLoops struct {
	Istio   bool
	Gloo    bool
	AppMesh bool
	Linkerd bool
}

type PubSub

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

func NewPubsub

func NewPubsub() *PubSub

type Receiver

type Receiver <-chan EnabledConfigLoops

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(pubSub *PubSub) *RegistrationSyncer

func (*RegistrationSyncer) Sync

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

type Subscriber

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

func NewSubscriber

func NewSubscriber(ctx context.Context, pubsub *PubSub, cl ConfigLoop) *Subscriber

func (*Subscriber) Listen

func (l *Subscriber) Listen(parentCtx context.Context)