FastFingerprint runs the same algorithm as Prometheus labelSetToFastFingerprint().

FromExemplarQueryRequest unpacks a ExemplarQueryRequest proto.

FromLabelNamesRequest unpacks a LabelNamesRequest proto.

FromLabelValuesRequest unpacks a LabelValuesRequest proto.

FromMetricsForLabelMatchersRequest unpacks a MetricsForLabelMatchersRequest proto.

FromQueryRequest unpacks a QueryRequest proto.

HashAdd32 adds a string to a fnv32 hash value, returning the updated hash.

HashAddByte32 adds a byte to a fnv32 hash value, returning the updated hash.

HashNew32 initializies a new fnv32 hash value.

LabelsToKeyString is used to form a string to be used as the hashKey.

MakeIngesterClient makes a new IngesterClient.

MatrixFromSeriesSet unpacks a SeriesSet to a model.Matrix.

SendQueryStream wraps the stream's Send() checking if the context is done before calling Send().

SeriesSetToQueryResponse builds a QueryResponse proto.

ToExemplarQueryRequest builds an ExemplarQueryRequest proto.

ToLabelNamesRequest builds a LabelNamesRequest proto.

ToLabelValuesRequest builds a LabelValuesRequest proto.

ToMetricsForLabelMatchersRequest builds a MetricsForLabelMatchersRequest proto.

ToQueryRequest builds a QueryRequest proto.

Config is the configuration struct for the ingester client.

QueryStreamResponse contains a batch of timeseries chunks or timeseries.

UnimplementedIngesterServer can be embedded to have forward compatible implementations.

ClosableClientConn is grpc.ClientConnInterface with Close function.

HealthAndIngesterClient is the union of IngesterClient and grpc_health_v1.HealthClient.

IngesterClient is the client API for Ingester service.

IngesterServer is the server API for Ingester service.