snapshot

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
  • func (e *Emitter) Error() <-chan error
  • func (e *Emitter) Run(stop <-chan struct{})
  • func (e *Emitter) Snapshot() <-chan *Cache

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