Documentation ¶
Index ¶
Constants ¶
View Source
const ( // Syncing state means that the collector has just started and need to immediately do a fetch to catchup Syncing state = "sync" // Scheduled means that we have caught up with latest events and are scheduled to run again later in Schedule time Scheduled state = "waiting" // Collecting means the collector thinks it probably has more to collect but is rate limited by MinWaitTime Collecting state = "collecting" )
View Source
const (
DefaultSchedule = time.Duration(15 * time.Minute)
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventCollector ¶
type EventCollector struct {
// contains filtered or unexported fields
}
EventCollector periodically fetches events via the given EventFetcher and stores them to the given EventStore
func New ¶
func New(cfg Config) *EventCollector
Click to show internal directories.
Click to hide internal directories.