monitoring

Documentation

Index

• Variables
• func RecordOnTimer(maxTimeReached, quiesceTimeReached, timerReset bool)
• func RecordProcessorEventProcessed(eventSpan time.Duration)
• func RecordProcessorSnapshotPublished(events int64, snapshotSpan time.Duration)
• func RecordStateTypeCount(collection string, count int)
• func RecordStateTypeCountWithContext(ctx context.Context, count int)
• func RecordStrategyOnChange()

Variables

var CollectionTag tag.Key

CollectionTag holds the type URL for the context.

Functions

func RecordOnTimer

func RecordOnTimer(maxTimeReached, quiesceTimeReached, timerReset bool)

RecordOnTimer

func RecordProcessorEventProcessed

func RecordProcessorEventProcessed(eventSpan time.Duration)

RecordProcessorEventProcessed

func RecordProcessorSnapshotPublished

func RecordProcessorSnapshotPublished(events int64, snapshotSpan time.Duration)

RecordProcessorSnapshotPublished

func RecordStateTypeCount

func RecordStateTypeCount(collection string, count int)

RecordStateTypeCount

func RecordStateTypeCountWithContext

func RecordStateTypeCountWithContext(ctx context.Context, count int)

RecordStateTypeCountWithContext

func RecordStrategyOnChange

func RecordStrategyOnChange()

RecordStrategyOnChange