sources

Documentation

Index

• type IntervalTimer
  • func NewIntervalTimer(interval time.Duration) *IntervalTimer
  • func (t *IntervalTimer) Reset() (intervalsMissed int64)
• type SourceManager
  • func Manager() SourceManager

Types

type IntervalTimer

type IntervalTimer struct {
	*time.Timer
	// contains filtered or unexported fields
}

func NewIntervalTimer

func NewIntervalTimer(interval time.Duration) *IntervalTimer

func (*IntervalTimer) Reset

func (t *IntervalTimer) Reset() (intervalsMissed int64)

type SourceManager

type SourceManager interface {
	metrics.ProviderHandler

	StopProviders()
	GetPendingMetrics() []*metrics.Batch
	SetDefaultCollectionInterval(time.Duration)
	BuildProviders(config configuration.SourceConfig) error
	SetClient(kubernetes.Interface)
}

SourceManager ProviderHandler with metrics gathering support

func Manager

func Manager() SourceManager

Manager return the SourceManager