monitor

Documentation

Index

• Constants
• func CaptureFileCacheMetrics(ctx context.Context, readType string, readDataSize int, cacheHit bool, ...)
• func CaptureGCSReadMetrics(ctx context.Context, readType string, requestedDataSize int64)
• func CloseOpenTelemetryCollectorExporter()
• func CloseStackdriverExporter()
• func EnableOpenTelemetryCollectorExporter(address string) error
• func EnableStackdriverExporter(interval time.Duration) error
• func NewMonitoringBucket(b gcs.Bucket) gcs.Bucket

Constants

const NanosecondsInOneMillisecond = 1000000

Functions

func CaptureFileCacheMetrics

func CaptureFileCacheMetrics(ctx context.Context, readType string, readDataSize int, cacheHit bool, readLatencyNs int64)

func CaptureGCSReadMetrics

func CaptureGCSReadMetrics(ctx context.Context, readType string, requestedDataSize int64)

func CloseOpenTelemetryCollectorExporter

func CloseOpenTelemetryCollectorExporter()

CloseOpenTelemetryCollectorExporter ensures all collected metrics are sent to the OpenTelemetry Collect and closes the exporter.

func CloseStackdriverExporter

func CloseStackdriverExporter()

CloseStackdriverExporter ensures all collected metrics are sent to Stackdriver and closes the stackdriverExporter.

func EnableOpenTelemetryCollectorExporter

func EnableOpenTelemetryCollectorExporter(address string) error

EnableOpenTelemetryCollectorExporter starts exporting monitoring metrics to the OpenTelemetry Collector at the given address. Details: https://opentelemetry.io/docs/collector/

func EnableStackdriverExporter

func EnableStackdriverExporter(interval time.Duration) error

EnableStackdriverExporter starts to collect monitoring metrics and exports them to Stackdriver iff the given interval is positive.

func NewMonitoringBucket

func NewMonitoringBucket(b gcs.Bucket) gcs.Bucket

NewMonitoringBucket returns a gcs.Bucket that exports metrics for monitoring