registration

package
v0.3.23 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 17, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RunConfigLoop added in v0.3.11

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

func RunEventLoop added in v0.3.11

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

Types

type ConfigLoop added in v0.3.14

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

type ConfigLoopStarter added in v0.3.11

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

type EnabledConfigLoops added in v0.3.11

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

type PubSub added in v0.3.14

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

func NewPubsub added in v0.3.14

func NewPubsub() *PubSub

type Receiver added in v0.3.14

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

type Subscriber added in v0.3.14

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

func NewSubscriber added in v0.3.14

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

func (*Subscriber) Listen added in v0.3.14

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

Directories

Path Synopsis
Package appmesh is a generated GoMock package.
Package appmesh is a generated GoMock package.
mocks
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mock_registration is a generated GoMock package.
Package mock_registration is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL