Package rater provides the functionality to calculate the processing rate of each vertex partition.

BuildUXEdgeWatermarkFetchers returns a map of the watermark fetchers, where key is the buffer name, value is a list of fetchers to the buffers.

BuildWatermarkStores returns a map of watermark stores per edge.

NewHealthChecker creates a new object HealthChecker struct type.

NewPipelineMetadataQuery returns a new instance of pipelineMetadataQuery.

HealthChecker is the struct type for health checker.

PipelineMetadataQuery has the metadata required for the pipeline queries.