Package com.linkedin.venice.pubsub.api

Class PubSubProducerAdapterConcurrentDelegator.ProducerQueueNode

java.lang.Object

com.linkedin.venice.pubsub.api.PubSubProducerAdapterConcurrentDelegator.ProducerQueueNode

All Implemented Interfaces:

Measurable

Enclosing class:

PubSubProducerAdapterConcurrentDelegator

public static class PubSubProducerAdapterConcurrentDelegator.ProducerQueueNode
extends Object
implements Measurable

Constructor Summary

Constructors

Constructor	Description
ProducerQueueNode(String topic, int partition, KafkaKey key, KafkaMessageEnvelope value, PubSubMessageHeaders headers, PubSubProducerCallback callback, CompletableFuture<PubSubProduceResult> produceFuture)

Method Summary

Modifier and Type	Method	Description
int	getHeapSize()

Methods inherited from class java.lang.Object

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

Constructor Details

ProducerQueueNode

public ProducerQueueNode(String topic,
 int partition,
 KafkaKey key,
 KafkaMessageEnvelope value,
 PubSubMessageHeaders headers,
 PubSubProducerCallback callback,
 CompletableFuture<PubSubProduceResult> produceFuture)

Method Details

getHeapSize

public int getHeapSize()

Specified by:

getHeapSize in interface Measurable