public class Utils
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CONNECT_GROUP_ID |
static java.lang.String |
CONNECT_KAFKA_CLUSTER_ID |
static java.lang.String |
KAFKA_BROKER_ID |
static java.lang.String |
KAFKA_CLUSTER_ID |
static java.lang.String |
LABEL_CLUSTER_ID |
static java.lang.String |
RESOURCE_LABEL_CLUSTER_ID |
Constructor and Description |
---|
Utils() |
Modifier and Type | Method and Description |
---|---|
static io.confluent.telemetry.ResourceBuilderFacade |
buildResourceFromAllLabelsWithId(org.apache.kafka.common.metrics.MetricsContext metricsContext,
java.lang.String id) |
static io.confluent.telemetry.ResourceBuilderFacade |
buildResourceFromLabels(org.apache.kafka.common.metrics.MetricsContext metricsContext)
Build a
Resource from tags in the MetricsContext metadata. |
static io.confluent.telemetry.ResourceBuilderFacade |
buildResourceFromLabelsWithId(org.apache.kafka.common.metrics.MetricsContext metricsContext,
java.lang.String id) |
static io.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,io.confluent.telemetry.events.v1.ConfigEvent> |
configEvent(java.util.Map<java.lang.String,?> cfg,
java.util.function.Predicate<java.lang.String> configPredicate,
io.opencensus.proto.resource.v1.Resource res,
java.lang.String type) |
static java.util.function.Predicate<java.lang.String> |
configPredicate(java.lang.String regexString) |
static java.util.Map<java.lang.String,java.lang.String> |
getNonResourceLabels(java.util.Map<java.lang.String,java.lang.String> metricsCtxMetadata) |
static java.util.Map<java.lang.String,java.lang.String> |
getResourceLabels(java.util.Map<java.lang.String,java.lang.String> metricsCtxMetadata)
Extract the resource labels from the metrics context metadata and remove metrics context
prefix.
|
static boolean |
notEmptyString(java.util.Map<java.lang.String,?> m,
java.lang.String key)
Validate that the map contains the key and the key is a non-empty string
|
static boolean |
validateRequiredLabels(java.util.Map<java.lang.String,java.lang.String> metadata)
Validate that the
MetricsContext metadata has tags for - _namespace - type - version -
cluster id |
static boolean |
validateRequiredResourceLabels(java.util.Map<java.lang.String,java.lang.String> metadata) |
public static final java.lang.String LABEL_CLUSTER_ID
public static final java.lang.String RESOURCE_LABEL_CLUSTER_ID
public static final java.lang.String KAFKA_BROKER_ID
public static final java.lang.String KAFKA_CLUSTER_ID
public static final java.lang.String CONNECT_KAFKA_CLUSTER_ID
public static final java.lang.String CONNECT_GROUP_ID
public static boolean notEmptyString(java.util.Map<java.lang.String,?> m, java.lang.String key)
public static java.util.Map<java.lang.String,java.lang.String> getResourceLabels(java.util.Map<java.lang.String,java.lang.String> metricsCtxMetadata)
public static java.util.Map<java.lang.String,java.lang.String> getNonResourceLabels(java.util.Map<java.lang.String,java.lang.String> metricsCtxMetadata)
public static io.confluent.telemetry.ResourceBuilderFacade buildResourceFromLabels(org.apache.kafka.common.metrics.MetricsContext metricsContext)
Resource
from tags in the MetricsContext
metadata.public static io.confluent.telemetry.ResourceBuilderFacade buildResourceFromLabelsWithId(org.apache.kafka.common.metrics.MetricsContext metricsContext, java.lang.String id)
public static io.confluent.telemetry.ResourceBuilderFacade buildResourceFromAllLabelsWithId(org.apache.kafka.common.metrics.MetricsContext metricsContext, java.lang.String id)
public static boolean validateRequiredLabels(java.util.Map<java.lang.String,java.lang.String> metadata)
MetricsContext
metadata has tags for - _namespace - type - version -
cluster idpublic static boolean validateRequiredResourceLabels(java.util.Map<java.lang.String,java.lang.String> metadata)
public static java.util.function.Predicate<java.lang.String> configPredicate(java.lang.String regexString)
public static io.cloudevents.CloudEvent<io.cloudevents.v1.AttributesImpl,io.confluent.telemetry.events.v1.ConfigEvent> configEvent(java.util.Map<java.lang.String,?> cfg, java.util.function.Predicate<java.lang.String> configPredicate, io.opencensus.proto.resource.v1.Resource res, java.lang.String type)