gatherers

Documentation

Index

• type CustomPeriodGatherer
• type GatheringClosure
• type Interface

Types

type CustomPeriodGatherer

type CustomPeriodGatherer interface {
	Interface

	// ShouldBeProcessedNow returns true when it's time to process the gatherer
	// is responsible for tracking the time itself
	ShouldBeProcessedNow() bool
	// UpdateLastProcessingTime is called when the gatherer is about to be processed,
	// so that it can update its last processed time for example.
	UpdateLastProcessingTime()
}

CustomPeriodGatherer gatherers implementing this interface may not get to each archive and their period can be different from interval in the config(equal or higher, but never lower)

type GatheringClosure

type GatheringClosure struct {
	Run func(context.Context) ([]record.Record, []error)
}

GatheringClosure is a struct containing a closure each gatherer returns

type Interface

type Interface interface {
	// GetName returns the name of the gatherer
	GetName() string

	// GetGatheringFunctions returns all the gathering function implemented by current gatherer
	GetGatheringFunctions(context.Context) (map[string]GatheringClosure, error)
}

Interface is an interface for gathering types