aggregator

Documentation

Index

• type ProviderAggregator
  • func NewProviderAggregator(conf static.Providers) *ProviderAggregator
  • func (p *ProviderAggregator) AddProvider(provider provider.Provider) error
  • func (p *ProviderAggregator) Init() error
  • func (p *ProviderAggregator) Provide(configurationChan chan<- dynamic.Message, pool *safe.Pool) error
• type RingChannel

Types

type ProviderAggregator

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

ProviderAggregator aggregates providers.

func NewProviderAggregator

func NewProviderAggregator(conf static.Providers) *ProviderAggregator

NewProviderAggregator returns an aggregate of all the providers configured in the static configuration.

func (*ProviderAggregator) AddProvider

func (p *ProviderAggregator) AddProvider(provider provider.Provider) error

AddProvider adds a provider in the providers map.

func (*ProviderAggregator) Init

func (p *ProviderAggregator) Init() error

Init the provider.

func (*ProviderAggregator) Provide

func (p *ProviderAggregator) Provide(configurationChan chan<- dynamic.Message, pool *safe.Pool) error

Provide calls the provide method of every providers.

type RingChannel

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

RingChannel implements a channel in a way that never blocks the writer. Specifically, if a value is written to a RingChannel when its buffer is full then the oldest value in the buffer is discarded to make room (just like a standard ring-buffer). Note that Go's scheduler can cause discarded values when they could be avoided, simply by scheduling the writer before the reader, so caveat emptor.