Versions in this module Expand all Collapse all v1 v1.0.0 Mar 5, 2024 Changes in this version + type MonitoringService interface + DeleteMetricMillisBehindLatest func(shard string) + IncrBytesProcessed func(shard string, count int64) + IncrRecordsProcessed func(shard string, count int) + Init func(appName, streamName, workerID string) error + LeaseGained func(shard string) + LeaseLost func(shard string) + LeaseRenewed func(shard string) + MillisBehindLatest func(shard string, milliSeconds float64) + RecordGetRecordsTime func(shard string, time float64) + RecordProcessRecordsTime func(shard string, time float64) + Shutdown func() + Start func() error + type NoopMonitoringService struct + func (NoopMonitoringService) DeleteMetricMillisBehindLatest(_ string) + func (NoopMonitoringService) IncrBytesProcessed(_ string, _ int64) + func (NoopMonitoringService) IncrRecordsProcessed(_ string, _ int) + func (NoopMonitoringService) Init(_, _, _ string) error + func (NoopMonitoringService) LeaseGained(_ string) + func (NoopMonitoringService) LeaseLost(_ string) + func (NoopMonitoringService) LeaseRenewed(_ string) + func (NoopMonitoringService) MillisBehindLatest(_ string, _ float64) + func (NoopMonitoringService) RecordGetRecordsTime(_ string, _ float64) + func (NoopMonitoringService) RecordProcessRecordsTime(_ string, _ float64) + func (NoopMonitoringService) Shutdown() + func (NoopMonitoringService) Start() error