Uses of Class
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream

Packages that use ByteBufCodedInputStream

Package	Description
org.apache.pulsar.common.api.proto
org.apache.pulsar.common.util.protobuf

Uses of ByteBufCodedInputStream in org.apache.pulsar.common.api.proto

Methods in org.apache.pulsar.common.api.proto with parameters of type ByteBufCodedInputStream

Modifier and Type	Method and Description
PulsarApi.Schema.Builder	PulsarApi.Schema.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.MessageIdData.Builder	PulsarApi.MessageIdData.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.KeyValue.Builder	PulsarApi.KeyValue.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.KeyLongValue.Builder	PulsarApi.KeyLongValue.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.EncryptionKeys.Builder	PulsarApi.EncryptionKeys.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.MessageMetadata.Builder	PulsarApi.MessageMetadata.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.SingleMessageMetadata.Builder	PulsarApi.SingleMessageMetadata.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandConnect.Builder	PulsarApi.CommandConnect.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandConnected.Builder	PulsarApi.CommandConnected.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandSubscribe.Builder	PulsarApi.CommandSubscribe.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandPartitionedTopicMetadata.Builder	PulsarApi.CommandPartitionedTopicMetadata.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandPartitionedTopicMetadataResponse.Builder	PulsarApi.CommandPartitionedTopicMetadataResponse.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandLookupTopic.Builder	PulsarApi.CommandLookupTopic.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandLookupTopicResponse.Builder	PulsarApi.CommandLookupTopicResponse.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandProducer.Builder	PulsarApi.CommandProducer.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandSend.Builder	PulsarApi.CommandSend.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandSendReceipt.Builder	PulsarApi.CommandSendReceipt.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandSendError.Builder	PulsarApi.CommandSendError.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandMessage.Builder	PulsarApi.CommandMessage.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandAck.Builder	PulsarApi.CommandAck.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandActiveConsumerChange.Builder	PulsarApi.CommandActiveConsumerChange.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandFlow.Builder	PulsarApi.CommandFlow.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandUnsubscribe.Builder	PulsarApi.CommandUnsubscribe.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandSeek.Builder	PulsarApi.CommandSeek.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandReachedEndOfTopic.Builder	PulsarApi.CommandReachedEndOfTopic.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandCloseProducer.Builder	PulsarApi.CommandCloseProducer.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandCloseConsumer.Builder	PulsarApi.CommandCloseConsumer.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder	PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandSuccess.Builder	PulsarApi.CommandSuccess.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandProducerSuccess.Builder	PulsarApi.CommandProducerSuccess.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandError.Builder	PulsarApi.CommandError.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandPing.Builder	PulsarApi.CommandPing.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandPong.Builder	PulsarApi.CommandPong.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandConsumerStats.Builder	PulsarApi.CommandConsumerStats.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandConsumerStatsResponse.Builder	PulsarApi.CommandConsumerStatsResponse.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandGetLastMessageId.Builder	PulsarApi.CommandGetLastMessageId.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandGetLastMessageIdResponse.Builder	PulsarApi.CommandGetLastMessageIdResponse.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandGetTopicsOfNamespace.Builder	PulsarApi.CommandGetTopicsOfNamespace.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandGetTopicsOfNamespaceResponse.Builder	PulsarApi.CommandGetTopicsOfNamespaceResponse.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandGetSchema.Builder	PulsarApi.CommandGetSchema.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.CommandGetSchemaResponse.Builder	PulsarApi.CommandGetSchemaResponse.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
PulsarApi.BaseCommand.Builder	PulsarApi.BaseCommand.Builder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)

Uses of ByteBufCodedInputStream in org.apache.pulsar.common.util.protobuf

Methods in org.apache.pulsar.common.util.protobuf that return ByteBufCodedInputStream

Modifier and Type	Method and Description
static ByteBufCodedInputStream	ByteBufCodedInputStream.get(io.netty.buffer.ByteBuf buf)

Methods in org.apache.pulsar.common.util.protobuf with parameters of type ByteBufCodedInputStream

Modifier and Type	Method and Description
ByteBufCodedInputStream.ByteBufMessageBuilder	ByteBufCodedInputStream.ByteBufMessageBuilder.mergeFrom(ByteBufCodedInputStream input, org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite ext)