runtime

Documentation

Index

• type Distributor
• type InMemoryDistributor
  • func NewInMemoryDistributor() *InMemoryDistributor
  • func (d *InMemoryDistributor) ClearSnapshot(name string)
  • func (d *InMemoryDistributor) SetSnapshot(name string, snapshot sn.Snapshot)
• type InMemorySource
  • func NewInMemorySource() *InMemorySource
  • func (s *InMemorySource) Delete(k resource.Key)
  • func (s *InMemorySource) Get(key resource.Key) (resource.Entry, error)
  • func (s *InMemorySource) Set(k resource.Key, item proto.Message)
  • func (s *InMemorySource) Start() (chan resource.Event, error)
  • func (s *InMemorySource) Stop()
• type Processor
  • func NewProcessor(src Source, distributor Distributor) *Processor
  • func (p *Processor) Start() error
  • func (p *Processor) Stop()
• type Source
• type State
  • func (s *State) String() string

Types

type Distributor

type Distributor interface {
	SetSnapshot(name string, snapshot sn.Snapshot)

	ClearSnapshot(name string)
}

Distributor interface allows processor to distribute snapshots of configuration.

type InMemoryDistributor

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

InMemoryDistributor is an in-memory distributor implementation.

func NewInMemoryDistributor

func NewInMemoryDistributor() *InMemoryDistributor

NewInMemoryDistributor returns a new instance of InMemoryDistributor

func (*InMemoryDistributor) ClearSnapshot

func (d *InMemoryDistributor) ClearSnapshot(name string)

ClearSnapshot is an implementation of Distributor.ClearSnapshot

func (*InMemoryDistributor) SetSnapshot

func (d *InMemoryDistributor) SetSnapshot(name string, snapshot sn.Snapshot)

SetSnapshot is an implementation of Distributor.SetSnapshot

type InMemorySource

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

InMemorySource is an implementation of source.Interface.

func NewInMemorySource

func NewInMemorySource() *InMemorySource

NewInMemorySource returns a new instance of InMemorySource.

func (*InMemorySource) Delete

func (s *InMemorySource) Delete(k resource.Key)

Delete a value in the in-memory store.

func (*InMemorySource) Get

func (s *InMemorySource) Get(key resource.Key) (resource.Entry, error)

Get a value in the in-memory store.

func (*InMemorySource) Set

func (s *InMemorySource) Set(k resource.Key, item proto.Message)

Set the value in the in-memory store.

func (*InMemorySource) Start

func (s *InMemorySource) Start() (chan resource.Event, error)

Start implements source.Interface.Start

func (*InMemorySource) Stop

func (s *InMemorySource) Stop()

Stop implements source.Interface.Stop

type Processor

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

Processor is the main control-loop for processing incoming config events and translating them into component configuration

func NewProcessor

func NewProcessor(src Source, distributor Distributor) *Processor

NewProcessor returns a new instance of a Processor

func (*Processor) Start

func (p *Processor) Start() error

Start the processor. This will cause processor to listen to incoming events from the provider and publish component configuration via the Distributor.

func (*Processor) Stop

func (p *Processor) Stop()

Stop the processor.

type Source

type Source interface {
	// Start the source interface. This returns a channel that the runtime will listen to for configuration
	// change events. The initial state of the underlying config store should be reflected as a series of
	// Added events, followed by a FullSync event.
	Start() (chan resource.Event, error)

	// Stop the source interface. Upon return from this method, the channel should not be accumulating any
	// more events.
	Stop()
}

Source to be implemented by a source configuration provider.

type State

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

State is the in-memory state of Galley.

func (*State) String

func (s *State) String() string

String implements fmt.Stringer