NewMetricsOptions returns a metrics option list.

NewMetricsServer returns a Prometheus metrics server instance, which can be used to start an HTTPS service to expose Prometheus metrics.

WithHealthCheckExecutor appends a health check executor.

WithLagReaders sets the lag readers.

WithLookbackSeconds sets lookback seconds for pending calculation.

WithRefreshInterval sets how often to refresh the pending information.

AckMessageError is used to indicate the errors in the number of messages acknowledged.

AckMessagesCount is used to indicate the number of messages acknowledged.

ActiveWindowsCount is used to indicate the number of active windows.

ClosedWindowsCount is used to indicate the number of closed windows.

ConcurrentUDFProcessingTime is a histogram to Observe UDF Processing times as a whole.

CtrlMessagesCount is used to indicate the number of total ctrl messages sent.

DropBytesCount is to indicate the number of bytes dropped.

DropMessagesCount is used to indicate the number of messages dropped.

FbSinkWriteBytesCount is to indicate the number of bytes written to a fallback sink.

FbSinkWriteMessagesCount is used to indicate the number of messages written to a fallback sink.

FbSinkWriteMessagesError is used to indicate the number of errors while writing to a fallback sink.

ForwardAChunkProcessingTime is a histogram to Observe forwardAChunk Processing times as a whole.

PBQWriteErrorCount is used to indicate the number of errors while writing to pbq.

PBQWriteMessagesCount is used to indicate the number of messages written to pbq.

PBQWriteTime pbq write latency.

PlatformError is used to indicate the number of Internal/Platform errors.

ReadBytesCount is to indicate the number of bytes read.

Generic forwarder metrics.

ReadDataMessagesCount is used to indicate the number of data messages read.

ReadMessagesCount is used to indicate the number of total messages read.

ReadMessagesError is used to indicate the number of errors messages read.

ReduceDroppedMessagesCount is used to indicate the number of messages dropped.

ReduceForwardTime is used to indicate the time it took to forward the writeMessages.

ReducePartitionsInFlight is used to indicate the partitions in flight.

ReduceProcessTime reduce ForwardTask processing latency.

SourceTransformerConcurrentProcessingTime is a histogram to Observe Source Transformer Processing times as a whole.

SourceTransformerError is used to indicate the number of source transformer errors.

SourceTransformerProcessingTime is a histogram to Observe Source Transformer Processing times as a whole.

SourceTransformerReadMessagesCount is used to indicate the number of messages read by source transformer.

SourceTransformerWriteMessagesCount is used to indicate the number of messages written by source transformer.

UDFError is used to indicate the number of UDF errors.

UDFProcessingTime is a histogram to Observe UDF Processing times as a whole.

UDFReadMessagesCount is used to indicate the number of messages read by UDF.

UDFWriteMessagesCount is used to indicate the number of messages written by UDF.

Generic forwarder metrics.

WriteBytesCount is to indicate the number of bytes written.

WriteMessagesCount is used to indicate the number of messages written.

WriteMessagesError is used to indicate the number of errors encountered while writing messages.

HealthChecker is the interface to check if the user-defined container is connected and ready to use.