poller

Documentation

Index

• type History
  • func NewPollerHistory(historyUpdatedFunc HistoryUpdatedFunc, timeSource clock.TimeSource) *History
  • func (pollers *History) GetPollerInfo(earliestAccessTime time.Time) []*types.PollerInfo
  • func (pollers *History) GetPollerIsolationGroups(earliestAccessTime time.Time) map[string]int
  • func (pollers *History) UpdatePollerInfo(id Identity, info Info)
• type HistoryUpdatedFunc
• type Identity
• type Info

Types

type History

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

func NewPollerHistory

func NewPollerHistory(historyUpdatedFunc HistoryUpdatedFunc, timeSource clock.TimeSource) *History

func (*History) GetPollerInfo

func (pollers *History) GetPollerInfo(earliestAccessTime time.Time) []*types.PollerInfo

func (*History) GetPollerIsolationGroups

func (pollers *History) GetPollerIsolationGroups(earliestAccessTime time.Time) map[string]int

func (*History) UpdatePollerInfo

func (pollers *History) UpdatePollerInfo(id Identity, info Info)

type HistoryUpdatedFunc

type HistoryUpdatedFunc func()

HistoryUpdatedFunc is a type for notifying applications when the poller history was updated

type Identity

type Identity string

type Info

type Info struct {
	RatePerSecond  float64
	IsolationGroup string
}