io.confluent.kafka.schemaregistry.metrics

Class MetricsContainer

java.lang.Object

io.confluent.kafka.schemaregistry.metrics.MetricsContainer

public class MetricsContainer
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	JMX_PREFIX
static String	METRIC_CERTIFICATE_EXPIRATION
static String	METRIC_LEADER_INITIALIZATION_LATENCY
static String	METRIC_NAME_API_FAILURE_COUNT
static String	METRIC_NAME_API_SUCCESS_COUNT
static String	METRIC_NAME_AVRO_SCHEMAS_CREATED
static String	METRIC_NAME_AVRO_SCHEMAS_DELETED
static String	METRIC_NAME_CUSTOM_SCHEMA_PROVIDER
static String	METRIC_NAME_DELETED_COUNT
static String	METRIC_NAME_JSON_SCHEMAS_CREATED
static String	METRIC_NAME_JSON_SCHEMAS_DELETED
static String	METRIC_NAME_MASTER_SLAVE_ROLE
static String	METRIC_NAME_NODE_COUNT
static String	METRIC_NAME_PB_SCHEMAS_CREATED
static String	METRIC_NAME_PB_SCHEMAS_DELETED
static String	METRIC_NAME_REGISTERED_COUNT
static String	RESOURCE_LABEL_KAFKA_CLUSTER_ID
static String	RESOURCE_LABEL_PREFIX

Constructor Summary

Constructors

Constructor and Description
MetricsContainer(SchemaRegistryConfig config, String kafkaClusterId)

Method Summary

Modifier and Type	Method and Description
void	emitCertificateExpirationMetric(KeyStore keystore, SchemaRegistryMetric metric)
SchemaRegistryMetric	getApiCallsFailure()
SchemaRegistryMetric	getApiCallsSuccess()
SchemaRegistryMetric	getCertificateExpirationKeystore()
SchemaRegistryMetric	getCertificateExpirationTruststore()
SchemaRegistryMetric	getCustomSchemaProviderCount()
SchemaRegistryMetric	getLeaderInitializationLatencyMetric()
SchemaRegistryMetric	getLeaderNode()
org.apache.kafka.common.metrics.Metrics	getMetrics()
org.apache.kafka.common.metrics.MetricsContext	getMetricsContext()
Map<String,String>	getMetricsTags()
SchemaRegistryMetric	getNodeCountMetric()
SchemaRegistryMetric	getSchemasCreated()
SchemaRegistryMetric	getSchemasCreated(String type)
SchemaRegistryMetric	getSchemasDeleted()
SchemaRegistryMetric	getSchemasDeleted(String type)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

JMX_PREFIX

public static final String JMX_PREFIX

See Also:

Constant Field Values

RESOURCE_LABEL_PREFIX

public static final String RESOURCE_LABEL_PREFIX

See Also:

Constant Field Values

RESOURCE_LABEL_KAFKA_CLUSTER_ID

public static final String RESOURCE_LABEL_KAFKA_CLUSTER_ID

See Also:

Constant Field Values

METRIC_NAME_MASTER_SLAVE_ROLE

public static final String METRIC_NAME_MASTER_SLAVE_ROLE

See Also:

Constant Field Values

METRIC_NAME_NODE_COUNT

public static final String METRIC_NAME_NODE_COUNT

See Also:

Constant Field Values

METRIC_NAME_CUSTOM_SCHEMA_PROVIDER

public static final String METRIC_NAME_CUSTOM_SCHEMA_PROVIDER

See Also:

Constant Field Values

METRIC_NAME_API_SUCCESS_COUNT

public static final String METRIC_NAME_API_SUCCESS_COUNT

See Also:

Constant Field Values

METRIC_NAME_API_FAILURE_COUNT

public static final String METRIC_NAME_API_FAILURE_COUNT

See Also:

Constant Field Values

METRIC_NAME_REGISTERED_COUNT

public static final String METRIC_NAME_REGISTERED_COUNT

See Also:

Constant Field Values

METRIC_NAME_DELETED_COUNT

public static final String METRIC_NAME_DELETED_COUNT

See Also:

Constant Field Values

METRIC_NAME_AVRO_SCHEMAS_CREATED

public static final String METRIC_NAME_AVRO_SCHEMAS_CREATED

See Also:

Constant Field Values

METRIC_NAME_AVRO_SCHEMAS_DELETED

public static final String METRIC_NAME_AVRO_SCHEMAS_DELETED

See Also:

Constant Field Values

METRIC_NAME_JSON_SCHEMAS_CREATED

public static final String METRIC_NAME_JSON_SCHEMAS_CREATED

See Also:

Constant Field Values

METRIC_NAME_JSON_SCHEMAS_DELETED

public static final String METRIC_NAME_JSON_SCHEMAS_DELETED

See Also:

Constant Field Values

METRIC_NAME_PB_SCHEMAS_CREATED

public static final String METRIC_NAME_PB_SCHEMAS_CREATED

See Also:

Constant Field Values

METRIC_NAME_PB_SCHEMAS_DELETED

public static final String METRIC_NAME_PB_SCHEMAS_DELETED

See Also:

Constant Field Values

METRIC_LEADER_INITIALIZATION_LATENCY

public static final String METRIC_LEADER_INITIALIZATION_LATENCY

See Also:

Constant Field Values

METRIC_CERTIFICATE_EXPIRATION

public static final String METRIC_CERTIFICATE_EXPIRATION

See Also:

Constant Field Values

Constructor Detail

MetricsContainer

public MetricsContainer(SchemaRegistryConfig config,
                        String kafkaClusterId)

Method Detail

getMetrics

public org.apache.kafka.common.metrics.Metrics getMetrics()

getMetricsTags

public Map<String,String> getMetricsTags()

getMetricsContext

public org.apache.kafka.common.metrics.MetricsContext getMetricsContext()

getNodeCountMetric

public SchemaRegistryMetric getNodeCountMetric()

getLeaderNode

public SchemaRegistryMetric getLeaderNode()

getApiCallsSuccess

public SchemaRegistryMetric getApiCallsSuccess()

getApiCallsFailure

public SchemaRegistryMetric getApiCallsFailure()

getCustomSchemaProviderCount

public SchemaRegistryMetric getCustomSchemaProviderCount()

getSchemasCreated

public SchemaRegistryMetric getSchemasCreated()

getSchemasCreated

public SchemaRegistryMetric getSchemasCreated(String type)

getSchemasDeleted

public SchemaRegistryMetric getSchemasDeleted()

getSchemasDeleted

public SchemaRegistryMetric getSchemasDeleted(String type)

getLeaderInitializationLatencyMetric

public SchemaRegistryMetric getLeaderInitializationLatencyMetric()

getCertificateExpirationKeystore

public SchemaRegistryMetric getCertificateExpirationKeystore()

getCertificateExpirationTruststore

public SchemaRegistryMetric getCertificateExpirationTruststore()

emitCertificateExpirationMetric

public void emitCertificateExpirationMetric(KeyStore keystore,
                                            SchemaRegistryMetric metric)