87
timeSource clock.TimeSource,
88
options *MonitorOptions,
90
>
return &monitorImpl{
91
>
readerStats: make(map[int64]readerStats),
92
>
sliceStats: make(map[Slice]sliceStats),
93
>
categoryType: categoryType,
94
>
timeSource: timeSource,
95
>
options: options,
96
>
pendingAlerts: make(map[AlertType]struct{}),
97
>
silencedAlerts: make(map[AlertType]time.Time),
98
>
alertCh: make(chan *Alert, alertChSize),
99
>
shutdownCh: make(chan struct{}),
100
>
}
101
>
}
102
103
func (m *monitorImpl) GetTotalPendingTaskCount() int {