ConvertFromStringMap convert a string map to a KeyValue []byte.

ConvertToStringMap convert a KeyValue []byte to string map.

Crc32cCheckSum handles computing the checksum.

GetAndAdd perform atomic read and update.

JavaStringHash and Java String.hashCode() equivalent.

Murmur3_32Hash use Murmur3 hashing function.

NewBatchBuilder init batch builder and return BatchBuilder pointer.

NewBlockingQueue init block queue and returns a BlockingQueue.

NewBuffer creates and initializes a new Buffer using buf as its initial contents.

NewConnectionPool init connection pool.

NewHTTPLookupService init a http based lookup service struct and return an object of LookupService.

NewKeyBasedBatchBuilder init batch builder and return BatchBuilder pointer.

NewLookupService init a lookup service struct and return an object of LookupService.

NewMemoryLimitController threshold valid range is (0, 1.0).

NewMetricsProvider returns metrics registered to registerer.

ParseTopicName parse the given topic name and return TopicName.

TimestampMillis return a time unix nano.

MaxFrameSize limit the maximum size that pulsar allows for messages to be sent.

MaxMessageSize limit message size for transfer.

MessageFramePadding is for metadata and other frame headers.

ErrCorruptedMessage is the error returned by ReadMessageData when it has detected corrupted data.

ErrEOM is the error returned by ReadMessage when no more input is available.

ErrRequestTimeOut happens when request not finished in given requestTimeout.

ClientHandlerMap is a simple concurrent-safe map for the client type.

LookupResult encapsulates a struct for lookup a request, containing two parts: LogicalAddr, PhysicalAddr.

MessageReader provides helper methods to parse the metadata and messages from the binary format Wire format for a messages Old format (single message) [MAGIC_NUMBER][CHECKSUM] [METADATA_SIZE][METADATA] [PAYLOAD] Batch format [MAGIC_NUMBER][CHECKSUM] [METADATA_SIZE][METADATA] [METADATA_SIZE][METADATA][PAYLOAD] [METADATA_SIZE][METADATA][PAYLOAD].

PartitionedTopicMetadata encapsulates a struct for metadata of a partitioned topic.

TopicName abstract a struct contained in a Topic.

BatchBuilder is a interface of batch builders.

BlockingQueue is a interface of block queue.

Buffer is a variable-sized buffer of bytes with Read and Write methods.

Connection is a interface of client cnx.

ConnectionListener is a user of a connection (eg.

ConnectionPool is a interface of connection pool.

LookupService is a interface of lookup service.

BatcherBuilderProvider defines func which returns the BatchBuilder.

GetTopicsOfNamespaceMode for CommandGetTopicsOfNamespace_Mode.