Package com.linkedin.venice.pubsub.api
-
Interface Summary Interface Description PubSubAdminAdapter An adapter for PubSubAdmin to create/delete/list/update topics.PubSubConsumerAdapter PubSubMessage<K,V,OFFSET> PubSubPosition Represents a position of a message in a partition of a topic.PubSubProducerAdapter The pub-sub producer interface with which venice writer's interact to send messages to pub-sub topic.PubSubProducerCallback A callback interface that users of PubSubProducerAdapter should implement if they want to execute some code once PubSubProducerAdapter#sendMessage request is completed.PubSubProduceResult An interface implemented by specific PubSubProducerAdapters to return the result of a produce action.PubSubTopic PubSubTopicPartition -
Class Summary Class Description PubSubInstrumentedAdminAdapter This class delegates anotherPubSubAdminAdapterinstance and keeps track of the invocation rate of methods on the delegated instancePubSubMessageDeserializer The class for deserializing messages from the pubsub specific message format toPubSubMessagePubSubMessageHeader A key-value pair that is associated with a messagePubSubMessageHeaders Set of key-value pairs to tagged with messages produced to a topic.PubSubPositionWireFormat -
Enum Summary Enum Description PubSubTopicType