poller

type HistoryUpdatedFunc func()

type Info struct {
	Identity       string
	RatePerSecond  float64
	IsolationGroup string
}

type Manager interface {
	StartPoll(pollerID string, cancelFunc context.CancelFunc, info *Info)
	EndPoll(pollerID string)
	CancelPoll(pollerID string) bool
	HasPollerFromIsolationGroupAfter(isolationGroup string, after time.Time) bool
	HasPollerAfter(after time.Time) bool
	GetCount() int
	GetCountByIsolationGroup(after time.Time) map[string]int
	ListInfo() []*types.PollerInfo
}