Index

A B C D G H I K L M N O P R S T U
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

attr(String, String) - Method in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

attr(String, String, String, String) - Method in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

ATTR_RESULT - Static variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

ATTR_SUBTYPE - Static variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

ATTR_TYPE - Static variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

attributesCache - Variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

B

BlockingQueue<E> - Class in org.apache.solr.crossdc.manager.consumer

BlockingQueue(int) - Constructor for class org.apache.solr.crossdc.manager.consumer.BlockingQueue

C

checkOffsetsAndUpdate() - Method in class org.apache.solr.crossdc.manager.consumer.PartitionManager

close() - Method in interface org.apache.solr.crossdc.manager.consumer.ConsumerMetrics.ConsumerTimer

Close this timer.

close() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer.SolrClientSupplier

collapsed - Variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

Consumer - Class in org.apache.solr.crossdc.manager.consumer

Consumer() - Constructor for class org.apache.solr.crossdc.manager.consumer.Consumer

Consumer.CrossDcConsumer - Class in org.apache.solr.crossdc.manager.consumer

Abstract class for defining cross-dc consumer

ConsumerMetrics - Interface in org.apache.solr.crossdc.manager.consumer

Interface for tracking and recording metrics related to the processing of messages and requests in the Consumer.

ConsumerMetrics.ConsumerTimer - Interface in org.apache.solr.crossdc.manager.consumer

Represents a timer interface used for measuring and observing the duration of tasks.

createKafkaAdminClient(Properties) - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

createKafkaConsumer(Properties) - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

createKafkaMirroringSink(KafkaCrossDcConf) - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

createSolrClient() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer.SolrClientSupplier

createSolrClientSupplier(KafkaCrossDcConf) - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

createSolrMessageProcessor() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

CrossDcConsumer() - Constructor for class org.apache.solr.crossdc.manager.consumer.Consumer.CrossDcConsumer

D

doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.solr.crossdc.manager.consumer.HealthCheckServlet

doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.solr.crossdc.manager.consumer.MetricsServlet

doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.solr.crossdc.manager.consumer.ThreadDumpServlet

dump(boolean, boolean, OutputStream) - Method in class org.apache.solr.crossdc.manager.consumer.ThreadDump

Dumps all the threads' current information, optionally including synchronization, to an output stream.

dump(OutputStream) - Method in class org.apache.solr.crossdc.manager.consumer.ThreadDump

Dumps all the threads' current information, including synchronization, to an output stream.

G

get() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer.SolrClientSupplier

getCrossDcConsumer(KafkaCrossDcConf, ConsumerMetrics, CountDownLatch) - Method in class org.apache.solr.crossdc.manager.consumer.Consumer

getMetricManager() - Method in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

getPartitionWork(TopicPartition) - Method in class org.apache.solr.crossdc.manager.consumer.PartitionManager

getResubmitBackoffPolicy() - Method in class org.apache.solr.crossdc.manager.messageprocessor.MessageProcessor

H

handleItem(MirroredSolrRequest<?>) - Method in class org.apache.solr.crossdc.manager.messageprocessor.SolrMessageProcessor

HealthCheckServlet - Class in org.apache.solr.crossdc.manager.consumer

HealthCheckServlet() - Constructor for class org.apache.solr.crossdc.manager.consumer.HealthCheckServlet

I

incrementCollapsedCounter() - Method in interface org.apache.solr.crossdc.manager.consumer.ConsumerMetrics

Increments the counter for collapsed "add" requests.

incrementCollapsedCounter() - Method in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

incrementInputMsgCounter() - Method in interface org.apache.solr.crossdc.manager.consumer.ConsumerMetrics

Increments the counter for input messages.

incrementInputMsgCounter(long) - Method in interface org.apache.solr.crossdc.manager.consumer.ConsumerMetrics

Increments the counter for input messages.

incrementInputMsgCounter(long) - Method in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

incrementInputReqCounter(String, String) - Method in interface org.apache.solr.crossdc.manager.consumer.ConsumerMetrics

Increments the counter for input requests by type and subtype.

incrementInputReqCounter(String, String, int) - Method in interface org.apache.solr.crossdc.manager.consumer.ConsumerMetrics

Increments the counter for input requests by type, subtype, and delta.

incrementInputReqCounter(String, String, int) - Method in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

incrementOutputCounter(String, String) - Method in interface org.apache.solr.crossdc.manager.consumer.ConsumerMetrics

Increments the counter for output requests by type and result.

incrementOutputCounter(String, String, int) - Method in interface org.apache.solr.crossdc.manager.consumer.ConsumerMetrics

Increments the counter for output requests by type, result, and delta.

incrementOutputCounter(String, String, int) - Method in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

init() - Method in class org.apache.solr.crossdc.manager.consumer.HealthCheckServlet

init() - Method in class org.apache.solr.crossdc.manager.consumer.MetricsServlet

init() - Method in class org.apache.solr.crossdc.manager.consumer.ThreadDumpServlet

inputMsg - Variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

inputReq - Variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

isKafkaConnected() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

isRunning() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

isSolrConnected() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

K

KAFKA_CROSSDC_CONSUMER - Static variable in class org.apache.solr.crossdc.manager.consumer.HealthCheckServlet

KafkaCrossDcConsumer - Class in org.apache.solr.crossdc.manager.consumer

This is a Java class called KafkaCrossDcConsumer, which is part of the Apache Solr framework.

KafkaCrossDcConsumer(KafkaCrossDcConf, ConsumerMetrics, CountDownLatch) - Constructor for class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

KafkaCrossDcConsumer.SolrClientSupplier - Class in org.apache.solr.crossdc.manager.consumer

Supplier for creating and managing a working CloudSolrClient instance.

KEY_SEPARATOR - Static variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

L

logMetrics(SolrMetricManager) - Static method in class org.apache.solr.crossdc.manager.consumer.Util

M

main(String[]) - Static method in class org.apache.solr.crossdc.manager.consumer.Consumer

MessageProcessor - Class in org.apache.solr.crossdc.manager.messageprocessor

MessageProcessor(ResubmitBackoffPolicy) - Constructor for class org.apache.solr.crossdc.manager.messageprocessor.MessageProcessor

metricManager - Variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

metrics - Variable in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

MetricsServlet - Class in org.apache.solr.crossdc.manager.consumer

Helper servlet that exports collected metrics in Prometheus format using MetricsHandler.

MetricsServlet() - Constructor for class org.apache.solr.crossdc.manager.consumer.MetricsServlet

N

NAME_PREFIX - Static variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

NOOP - Static variable in interface org.apache.solr.crossdc.manager.consumer.ConsumerMetrics

No-op implementation of ConsumerMetrics.

O

observeDuration() - Method in interface org.apache.solr.crossdc.manager.consumer.ConsumerMetrics.ConsumerTimer

Return the elapsed time in milliseconds.

offer(E) - Method in class org.apache.solr.crossdc.manager.consumer.BlockingQueue

org.apache.solr.crossdc.manager.consumer - package org.apache.solr.crossdc.manager.consumer

Logic for consuming information from Queues.

org.apache.solr.crossdc.manager.messageprocessor - package org.apache.solr.crossdc.manager.messageprocessor

Processing CrossDC replication messages.

OtelMetrics - Class in org.apache.solr.crossdc.manager.consumer

OtelMetrics() - Constructor for class org.apache.solr.crossdc.manager.consumer.OtelMetrics

output - Variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

outputBackoffHistogram - Variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

outputBatchSizeHistogram - Variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

outputFirstAttemptHistogram - Variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

outputTimeHistogram - Variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

P

PartitionManager - Class in org.apache.solr.crossdc.manager.consumer

PartitionManager.PartitionWork - Class in org.apache.solr.crossdc.manager.consumer

PartitionManager.WorkUnit - Class in org.apache.solr.crossdc.manager.consumer

printKafkaInfo(String, String) - Static method in class org.apache.solr.crossdc.manager.consumer.Util

processResult(MirroredSolrRequest.Type, IQueueHandler.Result<MirroredSolrRequest<?>>) - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

PROP_TOPIC_DEBUG - Static variable in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

R

recordOutputBackoffTime(MirroredSolrRequest.Type, long) - Method in interface org.apache.solr.crossdc.manager.consumer.ConsumerMetrics

Records the backoff time for output requests.

recordOutputBackoffTime(MirroredSolrRequest.Type, long) - Method in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

recordOutputBatchSize(MirroredSolrRequest.Type, SolrRequest<?>) - Method in interface org.apache.solr.crossdc.manager.consumer.ConsumerMetrics

Records the batch size of the output request.

recordOutputBatchSize(MirroredSolrRequest.Type, SolrRequest<?>) - Method in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

recordOutputFirstAttemptTime(MirroredSolrRequest.Type, long) - Method in interface org.apache.solr.crossdc.manager.consumer.ConsumerMetrics

Records the latency between the time when the message was sent at source and the time of the first attempt at processing.

recordOutputFirstAttemptTime(MirroredSolrRequest.Type, long) - Method in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

register(String) - Method in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

REGISTRY - Static variable in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

run() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

This is where the magic happens.

S

sendBatch(SolrRequest<? extends SolrResponse>, MirroredSolrRequest.Type, ConsumerRecord<String, MirroredSolrRequest<?>>, PartitionManager.WorkUnit) - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

shutdown() - Method in class org.apache.solr.crossdc.manager.consumer.Consumer

shutdown() - Method in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

Shutdown the Kafka consumer by calling wakeup.

SOLR_METRICS_MANAGER_ATTRIBUTE - Static variable in class org.apache.solr.crossdc.manager.consumer.MetricsServlet

solrClientSupplier - Variable in class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer

SolrClientSupplier(String) - Constructor for class org.apache.solr.crossdc.manager.consumer.KafkaCrossDcConsumer.SolrClientSupplier

SolrMessageProcessor - Class in org.apache.solr.crossdc.manager.messageprocessor

Message processor implements all the logic to process a MirroredSolrRequest.

SolrMessageProcessor(ConsumerMetrics, Supplier<CloudSolrClient>, ResubmitBackoffPolicy) - Constructor for class org.apache.solr.crossdc.manager.messageprocessor.SolrMessageProcessor

start() - Method in class org.apache.solr.crossdc.manager.consumer.Consumer

start(Map<String, Object>) - Method in class org.apache.solr.crossdc.manager.consumer.Consumer

startOutputTimeTimer(String) - Method in interface org.apache.solr.crossdc.manager.consumer.ConsumerMetrics

Starts a timer to measure the duration of an output request processing by the given request type.

startOutputTimeTimer(String) - Method in class org.apache.solr.crossdc.manager.consumer.OtelMetrics

T

ThreadDump - Class in org.apache.solr.crossdc.manager.consumer

A convenience class for getting a thread dump.

ThreadDump(ThreadMXBean) - Constructor for class org.apache.solr.crossdc.manager.consumer.ThreadDump

ThreadDumpServlet - Class in org.apache.solr.crossdc.manager.consumer

An HTTP servlets which outputs a text/plain dump of all threads in the VM.

ThreadDumpServlet() - Constructor for class org.apache.solr.crossdc.manager.consumer.ThreadDumpServlet

U

uncheckedSleep(long) - Method in class org.apache.solr.crossdc.manager.messageprocessor.SolrMessageProcessor

Util - Class in org.apache.solr.crossdc.manager.consumer

Util() - Constructor for class org.apache.solr.crossdc.manager.consumer.Util

A B C D G H I K L M N O P R S T U
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form