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<- config.Message, pool *safe.Pool) error

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<- config.Message, pool *safe.Pool) error

Provide calls the provide method of every providers