kinesisconfigs

Documentation

Index

• type DynamicLoader
  • func NewDynamicLoader(fetcher fetcher.ConfigFetcher, reloadTime, retryDelay time.Duration, ...) (*DynamicLoader, error)
  • func (d *DynamicLoader) Close()
  • func (d *DynamicLoader) Crank()

Types

type DynamicLoader

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

DynamicLoader fetches configs on an interval, with stats on the fetching process.

func NewDynamicLoader

func NewDynamicLoader(
	fetcher fetcher.ConfigFetcher,
	reloadTime,
	retryDelay time.Duration,
	stats reporter.StatsLogger,
	multee writer.SpadeWriterManager,
	kinesisWriterGenerator func(scoop_protocol.KinesisWriterConfig) (writer.SpadeWriter, error),
	staticConfigs []scoop_protocol.KinesisWriterConfig,
	commonFilters map[string]scoop_protocol.EventFilterFunc,
) (*DynamicLoader, error)

NewDynamicLoader returns a new DynamicLoader, performing the first fetch.

func (*DynamicLoader) Close

func (d *DynamicLoader) Close()

Close stops the DynamicLoader's fetching process.

func (*DynamicLoader) Crank

func (d *DynamicLoader) Crank()

Crank is a blocking function that refreshes the config on an interval.