Versions in this module Expand all Collapse all v1 v1.5.3 Dec 16, 2021 v1.5.2 Dec 16, 2021 Changes in this version + type MonitoringService interface + IncrBytesProcessed func(string, int64) + IncrRecordsProcessed func(string, int) + Init func(appName, streamName, workerID string) error + LeaseGained func(string) + LeaseLost func(string) + LeaseRenewed func(string) + MillisBehindLatest func(string, float64) + RecordGetRecordsTime func(string, float64) + RecordProcessRecordsTime func(string, float64) + Shutdown func() + Start func() error + type NoopMonitoringService struct + func (NoopMonitoringService) IncrBytesProcessed(shard string, count int64) + func (NoopMonitoringService) IncrRecordsProcessed(shard string, count int) + func (NoopMonitoringService) Init(appName, streamName, workerID string) error + func (NoopMonitoringService) LeaseGained(shard string) + func (NoopMonitoringService) LeaseLost(shard string) + func (NoopMonitoringService) LeaseRenewed(shard string) + func (NoopMonitoringService) MillisBehindLatest(shard string, millSeconds float64) + func (NoopMonitoringService) RecordGetRecordsTime(shard string, time float64) + func (NoopMonitoringService) RecordProcessRecordsTime(shard string, time float64) + func (NoopMonitoringService) Shutdown() + func (NoopMonitoringService) Start() error
Go to main page