snapshot

package

v0.4.2 Latest Latest Go to latest Published: Jul 29, 2018 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/znly/gloo

Documentation ¶

Index ¶

type Cache
- func (c *Cache) Hash() uint64
- func (c *Cache) Ready() bool
type Emitter
- func NewEmitter(configWatcher configwatcher.Interface, secretWatcher secretwatcher.Interface, ...) *Emitter

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Cache ¶

type Cache struct {
	Cfg       *v1.Config
	Secrets   secretwatcher.SecretMap
	Files     filewatcher.Files
	Endpoints endpointdiscovery.EndpointGroups
}

Cache contains the latest Gloo snapshot

func (*Cache) Hash ¶

func (c *Cache) Hash() uint64

func (*Cache) Ready ¶

func (c *Cache) Ready() bool

no need to configure anything until some routes (virtual services) exist endpoints don't matter as far as envoy is concerned

type Emitter ¶

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

the snapshot emitter wraps various config sources and emits a new snapshot when any element in the config updates

func NewEmitter ¶

func NewEmitter(configWatcher configwatcher.Interface,
	secretWatcher secretwatcher.Interface,
	fileWatcher filewatcher.Interface,
	endpointsWatcher endpointdiscovery.Interface,
	getDependencies func(cfg *v1.Config) []*plugins.Dependencies) *Emitter

func (*Emitter) Error ¶

func (e *Emitter) Error() <-chan error

fan out to cover all channels that return errors

func (*Emitter) Run ¶

func (e *Emitter) Run(stop <-chan struct{})

func (*Emitter) Snapshot ¶

func (e *Emitter) Snapshot() <-chan *Cache

Source Files ¶

View all Source files

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