A B C D E F G H I J L M N O P Q R S T U V W Z

A

AbstractConfiguration - Class in org.apache.bookkeeper.conf

Abstract configuration

AbstractConfiguration() - Constructor for class org.apache.bookkeeper.conf.AbstractConfiguration

addAllRanges(Iterable<? extends PubSubProtocol.LedgerRange>) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

addAllRemoteComponents(Iterable<? extends PubSubProtocol.RegionSpecificSeqId>) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

addAllTriedServers(Iterable<? extends ByteString>) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

addComplete(int, LedgerHandle, long, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.AddCallback

Callback declaration

addEntry(byte[]) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry synchronously to an open ledger.

addEntry(byte[], int, int) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry synchronously to an open ledger.

addRanges(PubSubProtocol.LedgerRange) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

addRanges(PubSubProtocol.LedgerRange.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

addRemoteComponents(PubSubProtocol.RegionSpecificSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

addRemoteComponents(PubSubProtocol.RegionSpecificSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

addTriedServers(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

asyncAddEntry(byte[], AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry asynchronously to an open ledger.

asyncAddEntry(byte[], int, int, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry asynchronously to an open ledger, using an offset and range.

AsyncCallback - Interface in org.apache.bookkeeper.client

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

AsyncCallback.AddCallback - Interface in org.apache.bookkeeper.client

AsyncCallback.CloseCallback - Interface in org.apache.bookkeeper.client

AsyncCallback.CreateCallback - Interface in org.apache.bookkeeper.client

AsyncCallback.DeleteCallback - Interface in org.apache.bookkeeper.client

AsyncCallback.OpenCallback - Interface in org.apache.bookkeeper.client

AsyncCallback.ReadCallback - Interface in org.apache.bookkeeper.client

AsyncCallback.ReadLastConfirmedCallback - Interface in org.apache.bookkeeper.client

AsyncCallback.RecoverCallback - Interface in org.apache.bookkeeper.client

asyncClose(AsyncCallback.CloseCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Asynchronous close, any adds in flight will return errors.

asyncCloseSubscription(ByteString, ByteString, Callback<Void>, Object) - Method in interface org.apache.hedwig.client.api.Subscriber

Closes all of the client side cached data for this subscription without actually sending an unsubscribe request to the server.

asyncCreateLedger(int, int, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper

Creates a new ledger asynchronously.

asyncDeleteLedger(long, AsyncCallback.DeleteCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper

Deletes a ledger asynchronously.

asyncOpenLedger(long, BookKeeper.DigestType, byte[], AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper

Open existing ledger asynchronously for reading.

asyncOpenLedgerNoRecovery(long, BookKeeper.DigestType, byte[], AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper

Open existing ledger asynchronously for reading, but it does not try to recover the ledger if it is not yet closed.

asyncPublish(ByteString, PubSubProtocol.Message, Callback<Void>, Object) - Method in interface org.apache.hedwig.client.api.Publisher

Publishes a message asynchronously on the given topic.

asyncReadEntries(long, long, AsyncCallback.ReadCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Read a sequence of entries asynchronously.

asyncReadLastConfirmed(AsyncCallback.ReadLastConfirmedCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Obtains last confirmed write from a quorum of bookies.

asyncRecoverBookieData(InetSocketAddress, InetSocketAddress, AsyncCallback.RecoverCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Async method to rebuild and recover the ledger fragments data that was stored on the source bookie.

asyncSubscribe(ByteString, ByteString, PubSubProtocol.SubscribeRequest.CreateOrAttach, Callback<Void>, Object) - Method in interface org.apache.hedwig.client.api.Subscriber

Subscribe to the given topic asynchronously for the inputted subscriberId disregarding if the topic has been created yet or not.

asyncUnsubscribe(ByteString, ByteString, Callback<Void>, Object) - Method in interface org.apache.hedwig.client.api.Subscriber

Unsubscribe from a topic asynchronously that the subscriberId user has previously subscribed to.

AUTO_SEND_CONSUME_MESSAGE_ENABLED - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

await(CyclicBarrier) - Static method in class org.apache.hedwig.util.ConcurrencyUtils

B

BKException - Exception in org.apache.bookkeeper.client

Class the enumerates all the possible error conditions

BKException.BKBookieException - Exception in org.apache.bookkeeper.client

BKException.BKBookieException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKBookieException

BKException.BKBookieHandleNotAvailableException - Exception in org.apache.bookkeeper.client

BKException.BKBookieHandleNotAvailableException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKBookieHandleNotAvailableException

BKException.BKDigestMatchException - Exception in org.apache.bookkeeper.client

BKException.BKDigestMatchException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDigestMatchException

BKException.BKDigestNotInitializedException - Exception in org.apache.bookkeeper.client

BKException.BKDigestNotInitializedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDigestNotInitializedException

BKException.BKIllegalOpException - Exception in org.apache.bookkeeper.client

BKException.BKIllegalOpException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKIllegalOpException

BKException.BKIncorrectParameterException - Exception in org.apache.bookkeeper.client

BKException.BKIncorrectParameterException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKIncorrectParameterException

BKException.BKInterruptedException - Exception in org.apache.bookkeeper.client

BKException.BKInterruptedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKInterruptedException

BKException.BKLedgerClosedException - Exception in org.apache.bookkeeper.client

BKException.BKLedgerClosedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerClosedException

BKException.BKLedgerFencedException - Exception in org.apache.bookkeeper.client

BKException.BKLedgerFencedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerFencedException

BKException.BKLedgerRecoveryException - Exception in org.apache.bookkeeper.client

BKException.BKLedgerRecoveryException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerRecoveryException

BKException.BKNoSuchEntryException - Exception in org.apache.bookkeeper.client

BKException.BKNoSuchEntryException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNoSuchEntryException

BKException.BKNoSuchLedgerExistsException - Exception in org.apache.bookkeeper.client

BKException.BKNoSuchLedgerExistsException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNoSuchLedgerExistsException

BKException.BKNotEnoughBookiesException - Exception in org.apache.bookkeeper.client

BKException.BKNotEnoughBookiesException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNotEnoughBookiesException

BKException.BKProtocolVersionException - Exception in org.apache.bookkeeper.client

BKException.BKProtocolVersionException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKProtocolVersionException

BKException.BKQuorumException - Exception in org.apache.bookkeeper.client

BKException.BKQuorumException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKQuorumException

BKException.BKReadException - Exception in org.apache.bookkeeper.client

BKException.BKReadException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKReadException

BKException.BKWriteException - Exception in org.apache.bookkeeper.client

BKException.BKWriteException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKWriteException

BKException.Code - Interface in org.apache.bookkeeper.client

List of return codes

BKException.ZKException - Exception in org.apache.bookkeeper.client

BKException.ZKException() - Constructor for exception org.apache.bookkeeper.client.BKException.ZKException

BODY_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.Message

BOOKIE_PORT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

BookieHandleNotAvailableException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

BookKeeper - Class in org.apache.bookkeeper.client

BookKeeper client.

BookKeeper(String) - Constructor for class org.apache.bookkeeper.client.BookKeeper

Create a bookkeeper client.

BookKeeper(ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeper

Create a bookkeeper client using a configuration object.

BookKeeper(ClientConfiguration, ZooKeeper) - Constructor for class org.apache.bookkeeper.client.BookKeeper

Create a bookkeeper client but use the passed in zookeeper client instead of instantiating one.

BookKeeper(ClientConfiguration, ZooKeeper, ClientSocketChannelFactory) - Constructor for class org.apache.bookkeeper.client.BookKeeper

Create a bookkeeper client but use the passed in zookeeper client and client socket channel factory instead of instantiating those.

BookKeeper.DigestType - Enum in org.apache.bookkeeper.client

There are 2 digest types that can be used for verification.

BookKeeperAdmin - Class in org.apache.bookkeeper.client

Admin client for BookKeeper clusters

BookKeeperAdmin(String) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin

Constructor that takes in a ZooKeeper servers connect string so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster.

BookKeeperAdmin(ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin

Constructor that takes in a configuration object so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster.

build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

C

Callback<T> - Interface in org.apache.hedwig.util

This class is used for callbacks for asynchronous operations

CallbackUtils - Class in org.apache.hedwig.util

CallbackUtils() - Constructor for class org.apache.hedwig.util.CallbackUtils

clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

clearBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

clearConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

clearCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

clearEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

clearLedgerId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

clearLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

clearMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

clearMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

clearMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

clearMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

clearMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

clearProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

clearProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

clearPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

clearRanges() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

clearRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

clearRemoteComponents() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

clearSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

clearShouldClaim() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

clearSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

clearStartDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

clearStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

clearStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

clearStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

clearSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

clearSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

clearTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

clearTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

clearTriedServers() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

clearTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

clearTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

clearType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

clearUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

Client - Interface in org.apache.hedwig.client.api

Interface defining the client API for Hedwig

CLIENT_TCP_NODELAY - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

ClientConfiguration - Class in org.apache.bookkeeper.conf

Configuration settings for client side

ClientConfiguration() - Constructor for class org.apache.bookkeeper.conf.ClientConfiguration

Construct a default client-side configuration

ClientConfiguration(AbstractConfiguration) - Constructor for class org.apache.bookkeeper.conf.ClientConfiguration

Construct a client-side configuration using a base configuration

ClientConfiguration - Class in org.apache.hedwig.client.conf

ClientConfiguration() - Constructor for class org.apache.hedwig.client.conf.ClientConfiguration

clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

close() - Method in class org.apache.bookkeeper.client.BookKeeper

Shuts down client.

close() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Gracefully release resources that this client uses.

close() - Method in class org.apache.bookkeeper.client.LedgerHandle

Close this ledger synchronously.

close() - Method in interface org.apache.hedwig.client.api.Client

Close the client and free all associated resources.

close() - Method in class org.apache.hedwig.client.HedwigClient

closeComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.CloseCallback

Callback definition

closeSubscription(ByteString, ByteString) - Method in interface org.apache.hedwig.client.api.Subscriber

Closes all of the client side cached data for this subscription without actually sending an unsubscribe request to the server.

code - Variable in exception org.apache.hedwig.exceptions.PubSubException

COLON - Static variable in class org.apache.hedwig.util.HedwigSocketAddress

ConcurrencyUtils - Class in org.apache.hedwig.util

ConcurrencyUtils() - Constructor for class org.apache.hedwig.util.ConcurrencyUtils

consume(ByteString, ByteString, PubSubProtocol.MessageSeqId) - Method in interface org.apache.hedwig.client.api.Subscriber

Manually send a consume message to the server for the given inputs.

CONSUMED_MESSAGES_BUFFER_SIZE - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

CONSUMEREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

create(int) - Static method in exception org.apache.bookkeeper.client.BKException

Create an exception from an error code

create(PubSubProtocol.StatusCode, String) - Static method in exception org.apache.hedwig.exceptions.PubSubException

createComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.CreateCallback

Declaration of callback method

createLedger(BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper

Creates a new ledger.

createLedger(int, int, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper

Synchronous call to create ledger.

CREATEORATTACH_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

createTempDirectory(String) - Static method in class org.apache.hedwig.util.FileUtils

createTempDirectory(String, String) - Static method in class org.apache.hedwig.util.FileUtils

CURRENT_METADATA_FORMAT_VERSION - Static variable in class org.apache.bookkeeper.client.LedgerMetadata

curry(Callback<T>, T) - Static method in class org.apache.hedwig.util.CallbackUtils

Return a Callback that just calls the given Callback cb with the bound result.

D

DEATH_WATCH_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

DEFAULT_SERVER_HOST - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

deleteComplete(int, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.DeleteCallback

Callback definition for delete operations

deleteLedger(long) - Method in class org.apache.bookkeeper.client.BookKeeper

Synchronous call to delete a ledger.

deliver(ByteString, ByteString, PubSubProtocol.Message, Callback<Void>, Object) - Method in interface org.apache.hedwig.client.api.MessageHandler

Delivers a message which has been published for topic.

DIGEST_TYPE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

DigestMatchException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

DigestNotInitializedException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

E

Either<T,U> - Class in org.apache.hedwig.util

ENDSEQIDINCLUDED_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

ENTRY_LOG_SIZE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

equals(Object) - Method in class org.apache.hedwig.util.HedwigSocketAddress

F

FileUtils - Class in org.apache.hedwig.util

FileUtils() - Constructor for class org.apache.hedwig.util.FileUtils

first() - Method in class org.apache.hedwig.util.Pair

FLUSH_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

G

GC_WAIT_TIME - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

get() - Method in class org.apache.hedwig.util.Option

getBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

getBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

getBookiePort() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get bookie port that bookie server listen on

getBookieRecoveryDigestType() - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Get digest type used in bookkeeper admin

getBookieRecoveryPasswd() - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Get passwd used in bookkeeper admin

getClientTcpNoDelay() - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Is tcp connection no delay.

getCode() - Method in exception org.apache.bookkeeper.client.BKException

getCode() - Method in exception org.apache.hedwig.exceptions.PubSubException

getConf() - Method in class org.apache.bookkeeper.client.BookKeeper

getConsumedMessagesBufferSize() - Method in class org.apache.hedwig.client.conf.ClientConfiguration

getConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

getCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

getDeathWatchInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get bookie death watch interval

getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message

getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

getDefaultServerHedwigSocketAddress() - Method in class org.apache.hedwig.client.conf.ClientConfiguration

getDefaultServerHost() - Method in class org.apache.hedwig.client.conf.ClientConfiguration

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

getDescriptor() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

getDescriptor() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

getDescriptor() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

getDescriptor() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

getDescriptorForType() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

getDescriptorForType() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion

getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

getDescriptorForType() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

getDescriptorForType() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach

getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

getEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

getEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

getEnsembles() - Method in class org.apache.bookkeeper.client.LedgerMetadata

Get the Map of bookie ensembles for the various ledger fragments that make up the ledger.

getEntry() - Method in class org.apache.bookkeeper.client.LedgerEntry

getEntryId() - Method in class org.apache.bookkeeper.client.LedgerEntry

getEntryInputStream() - Method in class org.apache.bookkeeper.client.LedgerEntry

getEntryLogSizeLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get entry logger size limitation

getExceptions() - Method in exception org.apache.hedwig.exceptions.PubSubException.CompositeException

getFlushInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get flush interval

getGcWaitTime() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get Garbage collection wait time

getHostname() - Method in class org.apache.hedwig.util.HedwigSocketAddress

getId() - Method in class org.apache.bookkeeper.client.LedgerHandle

Get the id of the current ledger

getJournalDir() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get dir to store journal files

getJournalDirName() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get dir name to store journal files

getLastAddConfirmed() - Method in class org.apache.bookkeeper.client.LedgerHandle

Get the last confirmed entry id on this ledger

getLastAddPushed() - Method in class org.apache.bookkeeper.client.LedgerHandle

Get the entry id of the last entry that has been enqueued for addition (but may not have possibly been persited to the ledger)

getLedgerDirNames() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get dir names to store ledger data

getLedgerDirs() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get dirs that stores ledger data

getLedgerId() - Method in class org.apache.bookkeeper.client.LedgerEntry

getLedgerId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

getLedgerId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

getLedgerKey() - Method in class org.apache.bookkeeper.client.LedgerHandle

Get the Ledger's key/password.

getLedgerManagerType() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Get Ledger Manager Type.

getLength() - Method in class org.apache.bookkeeper.client.LedgerEntry

getLength() - Method in class org.apache.bookkeeper.client.LedgerHandle

Returns the length of the ledger in bytes.

getLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

getLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

getMaxBackupJournals() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Max number of older journal files kept

getMaximumMessageSize() - Method in class org.apache.hedwig.client.conf.ClientConfiguration

getMaximumOutstandingMessages() - Method in class org.apache.hedwig.client.conf.ClientConfiguration

getMaximumServerRedirects() - Method in class org.apache.hedwig.client.conf.ClientConfiguration

getMaxJournalSize() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Max journal file size

getMessage(int) - Static method in exception org.apache.bookkeeper.client.BKException

getMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

getMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

getMessageConsumeRetryWaitTime() - Method in class org.apache.hedwig.client.conf.ClientConfiguration

getMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

getMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

getNumber() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

getNumber() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion

getNumber() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

getNumber() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach

getOpenFileLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get open file limit

getPageLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get limitation number of index pages in ledger cache

getPageSize() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get page size

getPort() - Method in class org.apache.hedwig.util.HedwigSocketAddress

getProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

getProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

getPublisher() - Method in interface org.apache.hedwig.client.api.Client

Retrieve the Publisher object for the client.

getPublisher() - Method in class org.apache.hedwig.client.HedwigClient

getPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getRanges(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

getRanges(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

getRangesCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

getRangesCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

getRangesList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

getRangesList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

getRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

getRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

getRemoteComponents(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

getRemoteComponents(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

getRemoteComponentsCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

getRemoteComponentsCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

getRemoteComponentsList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

getRemoteComponentsList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

getSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

getSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

getServerAckResponseTimeout() - Method in class org.apache.hedwig.client.conf.ClientConfiguration

getServerTcpNoDelay() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Is tcp connection no delay.

getShouldClaim() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getShouldClaim() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getSocketAddress() - Method in class org.apache.hedwig.util.HedwigSocketAddress

getSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

getSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

getSSLPort() - Method in class org.apache.hedwig.util.HedwigSocketAddress

getSSLSocketAddress() - Method in class org.apache.hedwig.util.HedwigSocketAddress

getStartDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getStartDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

getStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

getStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

getStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

getStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getSubscriber() - Method in interface org.apache.hedwig.client.api.Client

Retrieve the Subscriber object for the client.

getSubscriber() - Method in class org.apache.hedwig.client.HedwigClient

getSubscribeReconnectRetryWaitTime() - Method in class org.apache.hedwig.client.conf.ClientConfiguration

getSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

getSubscriptionList(ByteString) - Method in interface org.apache.hedwig.client.api.Subscriber

Fills the input List with the subscriptions this subscriberId client is subscribed to.

getSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

getSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

getThrottleValue() - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Get throttle value

getTimeoutThreadRunInterval() - Method in class org.apache.hedwig.client.conf.ClientConfiguration

getTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

getTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

getTriedServers(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getTriedServers(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getTriedServersCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getTriedServersCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getTriedServersList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getTriedServersList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

getTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

getType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

getUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

getValueDescriptor() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

getValueDescriptor() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion

getValueDescriptor() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

getValueDescriptor() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach

getZkLedgersRootPath() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Get Zk Ledgers Root Path.

getZkServers() - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Get zookeeper servers to connect

getZkServers() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get zookeeper servers to connect

getZkTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Get zookeeper timeout

getZkTimeout() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get zookeeper timeout

getZnodeVersion() - Method in class org.apache.bookkeeper.client.LedgerMetadata

Returns the last znode version.

H

hasBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

hasBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

hasConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

hasConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

hasCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

hasCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

hasEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

hasEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

hasLedgerId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

hasLedgerId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

hasLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

hasLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

hasMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

hasMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

hasMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

hasMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

hasProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

hasProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

hasProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

hasProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

hasPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

hasPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

hasRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

hasRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

hasSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

hasSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

hasShouldClaim() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

hasShouldClaim() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

hasSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

hasSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

hasStartDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

hasStartDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

hasStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

hasStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

hasStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

hasStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

hasStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

hasStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

hasSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

hasSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

hasSubscription(ByteString, ByteString) - Method in interface org.apache.hedwig.client.api.Subscriber

Checks if the subscriberId client is currently subscribed to the given topic.

hasSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

hasSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

hasTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

hasTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

hasTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

hasTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

hasTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

hasTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

hasTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

hasTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

hasType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

hasType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

hasUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

hasUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

HedwigClient - Class in org.apache.hedwig.client

Hedwig client uses as starting point for all communications with the Hedwig service.

HedwigClient(ClientConfiguration) - Constructor for class org.apache.hedwig.client.HedwigClient

Construct a hedwig client object.

HedwigClient(ClientConfiguration, ChannelFactory) - Constructor for class org.apache.hedwig.client.HedwigClient

Construct a hedwig client object, using a preexisting socket factory.

HedwigSocketAddress - Class in org.apache.hedwig.util

This is a data wrapper class that is basically an InetSocketAddress with one extra piece of information for the SSL port (optional).

HedwigSocketAddress(String, int, int) - Constructor for class org.apache.hedwig.util.HedwigSocketAddress

HedwigSocketAddress(String, int) - Constructor for class org.apache.hedwig.util.HedwigSocketAddress

HedwigSocketAddress(String) - Constructor for class org.apache.hedwig.util.HedwigSocketAddress

I

IllegalOpException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

IN_RECOVERY - Static variable in class org.apache.bookkeeper.client.LedgerMetadata

IncorrectParameterException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

internalForceInit() - Static method in class org.apache.hedwig.protocol.PubSubProtocol

internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

internalGetResult() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

internalGetResult() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

internalGetResult() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

internalGetResult() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

internalGetResult() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

internalGetResult() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

internalGetResult() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

internalGetResult() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

internalGetResult() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

internalGetResult() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

internalGetResult() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

internalGetResult() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

internalGetResult() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

internalGetResult() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

internalGetValueMap() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

internalGetValueMap() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion

internalGetValueMap() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

internalGetValueMap() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach

InterruptedException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

isAutoSendConsumeMessageEnabled() - Method in class org.apache.hedwig.client.conf.ClientConfiguration

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

isPrefix(String, String) - Static method in class org.apache.hedwig.util.PathUtils

Return true iff prefix is a prefix of path.

isSSLEnabled() - Method in class org.apache.hedwig.client.conf.ClientConfiguration

isSSLEnabled() - Method in class org.apache.hedwig.util.HedwigSocketAddress

J

JOURNAL_DIR - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

L

LEDGER_DIRS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

LEDGER_MANAGER_TYPE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

LedgerClosedException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

LedgerEntry - Class in org.apache.bookkeeper.client

Ledger entry.

LedgerFencedException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

LedgerHandle - Class in org.apache.bookkeeper.client

Ledger handle contains ledger metadata and is used to access the read and write operations to a ledger.

LEDGERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

LedgerMetadata - Class in org.apache.bookkeeper.client

This class encapsulates all the ledger metadata that is persistently stored in zookeeper.

LedgerMetadata(int, int) - Constructor for class org.apache.bookkeeper.client.LedgerMetadata

LedgerRecoveryException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

left(T) - Static method in class org.apache.hedwig.util.Either

left() - Method in class org.apache.hedwig.util.Either

loadConf(URL) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

You can load configurations in precedence order.

loadConf(AbstractConfiguration) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

You can load configuration from other configuration

LOCALCOMPONENT_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

logger(Logger, String, String, Callback<T>) - Static method in class org.apache.hedwig.util.CallbackUtils

Logs what happened before continuing the callback chain.

logger(Logger, String, String) - Static method in class org.apache.hedwig.util.CallbackUtils

Logs what happened (no continuation).

LOWEST_COMPAT_METADATA_FORMAT_VERSION - Static variable in class org.apache.bookkeeper.client.LedgerMetadata

M

MAX_BACKUP_JOURNALS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MAX_JOURNAL_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MAX_MESSAGE_SIZE - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

MAX_OUTSTANDING_MESSAGES - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

MAX_SERVER_REDIRECTS - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

mergeConsumeRequest(PubSubProtocol.ConsumeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

mergeEndSeqIdIncluded(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

mergeFrom(PubSubProtocol.ConsumeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

mergeFrom(PubSubProtocol.LedgerRange) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

mergeFrom(PubSubProtocol.LedgerRanges) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

mergeFrom(PubSubProtocol.Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

mergeFrom(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

mergeFrom(PubSubProtocol.PublishRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

mergeFrom(PubSubProtocol.PubSubRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

mergeFrom(PubSubProtocol.PubSubResponse) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

mergeFrom(PubSubProtocol.RegionSpecificSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

mergeFrom(PubSubProtocol.StartDeliveryRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

mergeFrom(PubSubProtocol.StopDeliveryRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

mergeFrom(PubSubProtocol.SubscribeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

mergeFrom(PubSubProtocol.SubscriptionState) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

mergeFrom(PubSubProtocol.UnsubscribeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

mergeMessage(PubSubProtocol.Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

mergeMsg(PubSubProtocol.Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

mergeMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

mergeMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

mergeMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

mergePublishRequest(PubSubProtocol.PublishRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

mergeStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

mergeStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

mergeSubscribeRequest(PubSubProtocol.SubscribeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

mergeUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

MESSAGE_CONSUME_RETRY_WAIT_TIME - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

MESSAGE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

MessageHandler - Interface in org.apache.hedwig.client.api

Interface to define the client handler logic to deliver messages it is subscribed to.

MSG_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

MSGID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

MSGID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.Message

MSGID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

multiCallback(int, Callback<Void>, Object, Logger, String, String, Runnable) - Static method in class org.apache.hedwig.util.CallbackUtils

A callback that waits for all of a number of events to fire.

multiCallback(int, Callback<Void>, Object) - Static method in class org.apache.hedwig.util.CallbackUtils

A callback that waits for all of a number of events to fire.

multinCallback(int, Callback<Void>, Object, Runnable) - Static method in class org.apache.hedwig.util.CallbackUtils

A callback that waits for all of a number of events to fire.

myDefaultServerAddress - Variable in class org.apache.hedwig.client.conf.ClientConfiguration

N

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

newBuilder(PubSubProtocol.ConsumeRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

newBuilder(PubSubProtocol.LedgerRange) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

newBuilder(PubSubProtocol.LedgerRanges) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message

newBuilder(PubSubProtocol.Message) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

newBuilder(PubSubProtocol.MessageSeqId) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

newBuilder(PubSubProtocol.PublishRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

newBuilder(PubSubProtocol.PubSubRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

newBuilder(PubSubProtocol.PubSubResponse) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

newBuilder(PubSubProtocol.RegionSpecificSeqId) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

newBuilder(PubSubProtocol.StartDeliveryRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

newBuilder(PubSubProtocol.StopDeliveryRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

newBuilder(PubSubProtocol.SubscribeRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

newBuilder(PubSubProtocol.SubscriptionState) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

newBuilder(PubSubProtocol.UnsubscribeRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

NoBookieAvailableException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

nop() - Static method in class org.apache.hedwig.util.CallbackUtils

A do-nothing callback.

NoSuchEntryException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

NoSuchLedgerExistsException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

NOTCLOSED - Static variable in class org.apache.bookkeeper.client.LedgerMetadata

NotEnoughBookiesException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

O

of(T, U) - Static method in class org.apache.hedwig.util.Either

of(T) - Static method in class org.apache.hedwig.util.Option

of() - Static method in class org.apache.hedwig.util.Option

of(T, U) - Static method in class org.apache.hedwig.util.Pair

OK - Static variable in interface org.apache.bookkeeper.client.BKException.Code

OPEN_FILE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

openComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.OpenCallback

Callback for asynchronous call to open ledger

openLedger(long, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper

Synchronous open ledger call

openLedgerNoRecovery(long, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper

Synchronous, unsafe open ledger call

operationFailed(Object, PubSubException) - Method in interface org.apache.hedwig.util.Callback

This method is called when the operation failed due to some reason.

operationFinished(Object, T) - Method in interface org.apache.hedwig.util.Callback

This method is called when the asynchronous operation finishes

Option<T> - Class in org.apache.hedwig.util

Option() - Constructor for class org.apache.hedwig.util.Option

Option(T) - Constructor for class org.apache.hedwig.util.Option

org.apache.bookkeeper.client - package org.apache.bookkeeper.client

org.apache.bookkeeper.conf - package org.apache.bookkeeper.conf

org.apache.hedwig.client - package org.apache.hedwig.client

org.apache.hedwig.client.api - package org.apache.hedwig.client.api

org.apache.hedwig.client.conf - package org.apache.hedwig.client.conf

org.apache.hedwig.exceptions - package org.apache.hedwig.exceptions

org.apache.hedwig.protocol - package org.apache.hedwig.protocol

org.apache.hedwig.util - package org.apache.hedwig.util

P

PAGE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

PAGE_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

Pair<T,U> - Class in org.apache.hedwig.util

Pair(T, U) - Constructor for class org.apache.hedwig.util.Pair

parent(String) - Static method in class org.apache.hedwig.util.PathUtils

Like File.getParent but always uses the / separator.

parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message

parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message

parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message

parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message

parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message

parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

PASSWD - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

PathUtils - Class in org.apache.hedwig.util

PathUtils() - Constructor for class org.apache.hedwig.util.PathUtils

prefixes(String) - Static method in class org.apache.hedwig.util.PathUtils

Generate all prefixes for a path.

PROTOCOLVERSION_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

PROTOCOLVERSION_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

ProtocolVersionException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

publish(ByteString, PubSubProtocol.Message) - Method in interface org.apache.hedwig.client.api.Publisher

Publishes a message on the given topic.

Publisher - Interface in org.apache.hedwig.client.api

Interface to define the client Publisher API.

PUBLISHREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

PubSubException - Exception in org.apache.hedwig.exceptions

PubSubException(PubSubProtocol.StatusCode, String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException

PubSubException(PubSubProtocol.StatusCode, Exception) - Constructor for exception org.apache.hedwig.exceptions.PubSubException

PubSubException.ClientAlreadySubscribedException - Exception in org.apache.hedwig.exceptions

PubSubException.ClientAlreadySubscribedException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ClientAlreadySubscribedException

PubSubException.ClientNotSubscribedException - Exception in org.apache.hedwig.exceptions

PubSubException.ClientNotSubscribedException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedException

PubSubException.ClientNotSubscribedRuntimeException - Exception in org.apache.hedwig.exceptions

PubSubException.ClientNotSubscribedRuntimeException() - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedRuntimeException

PubSubException.CompositeException - Exception in org.apache.hedwig.exceptions

PubSubException.CompositeException(Collection<PubSubException>) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.CompositeException

PubSubException.CouldNotConnectException - Exception in org.apache.hedwig.exceptions

PubSubException.CouldNotConnectException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.CouldNotConnectException

PubSubException.MalformedRequestException - Exception in org.apache.hedwig.exceptions

PubSubException.MalformedRequestException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.MalformedRequestException

PubSubException.NoSuchTopicException - Exception in org.apache.hedwig.exceptions

PubSubException.NoSuchTopicException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.NoSuchTopicException

PubSubException.ServerNotResponsibleForTopicException - Exception in org.apache.hedwig.exceptions

PubSubException.ServerNotResponsibleForTopicException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ServerNotResponsibleForTopicException

PubSubException.ServiceDownException - Exception in org.apache.hedwig.exceptions

PubSubException.ServiceDownException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ServiceDownException

PubSubException.ServiceDownException(Exception) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ServiceDownException

PubSubException.TopicBusyException - Exception in org.apache.hedwig.exceptions

PubSubException.TopicBusyException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.TopicBusyException

PubSubException.UncertainStateException - Exception in org.apache.hedwig.exceptions

PubSubException.UncertainStateException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.UncertainStateException

PubSubException.UnexpectedConditionException - Exception in org.apache.hedwig.exceptions

PubSubException.UnexpectedConditionException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.UnexpectedConditionException

PubSubProtocol - Class in org.apache.hedwig.protocol

PubSubProtocol.ConsumeRequest - Class in org.apache.hedwig.protocol

PubSubProtocol.ConsumeRequest.Builder - Class in org.apache.hedwig.protocol

PubSubProtocol.LedgerRange - Class in org.apache.hedwig.protocol

PubSubProtocol.LedgerRange.Builder - Class in org.apache.hedwig.protocol

PubSubProtocol.LedgerRanges - Class in org.apache.hedwig.protocol

PubSubProtocol.LedgerRanges.Builder - Class in org.apache.hedwig.protocol

PubSubProtocol.Message - Class in org.apache.hedwig.protocol

PubSubProtocol.Message.Builder - Class in org.apache.hedwig.protocol

PubSubProtocol.MessageSeqId - Class in org.apache.hedwig.protocol

PubSubProtocol.MessageSeqId.Builder - Class in org.apache.hedwig.protocol

PubSubProtocol.OperationType - Enum in org.apache.hedwig.protocol

PubSubProtocol.ProtocolVersion - Enum in org.apache.hedwig.protocol

PubSubProtocol.PublishRequest - Class in org.apache.hedwig.protocol

PubSubProtocol.PublishRequest.Builder - Class in org.apache.hedwig.protocol

PubSubProtocol.PubSubRequest - Class in org.apache.hedwig.protocol

PubSubProtocol.PubSubRequest.Builder - Class in org.apache.hedwig.protocol

PubSubProtocol.PubSubResponse - Class in org.apache.hedwig.protocol

PubSubProtocol.PubSubResponse.Builder - Class in org.apache.hedwig.protocol

PubSubProtocol.RegionSpecificSeqId - Class in org.apache.hedwig.protocol

PubSubProtocol.RegionSpecificSeqId.Builder - Class in org.apache.hedwig.protocol

PubSubProtocol.StartDeliveryRequest - Class in org.apache.hedwig.protocol

PubSubProtocol.StartDeliveryRequest.Builder - Class in org.apache.hedwig.protocol

PubSubProtocol.StatusCode - Enum in org.apache.hedwig.protocol

PubSubProtocol.StopDeliveryRequest - Class in org.apache.hedwig.protocol

PubSubProtocol.StopDeliveryRequest.Builder - Class in org.apache.hedwig.protocol

PubSubProtocol.SubscribeRequest - Class in org.apache.hedwig.protocol

PubSubProtocol.SubscribeRequest.Builder - Class in org.apache.hedwig.protocol

PubSubProtocol.SubscribeRequest.CreateOrAttach - Enum in org.apache.hedwig.protocol

PubSubProtocol.SubscriptionState - Class in org.apache.hedwig.protocol

PubSubProtocol.SubscriptionState.Builder - Class in org.apache.hedwig.protocol

PubSubProtocol.UnsubscribeRequest - Class in org.apache.hedwig.protocol

PubSubProtocol.UnsubscribeRequest.Builder - Class in org.apache.hedwig.protocol

put(V, U) - Static method in class org.apache.hedwig.util.ConcurrencyUtils

Q

QuorumException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

R

RANGES_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

readComplete(int, LedgerHandle, Enumeration<LedgerEntry>, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.ReadCallback

Callback declaration

readEntries(long, long) - Method in class org.apache.bookkeeper.client.LedgerHandle

Read a sequence of entries synchronously.

ReadException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

readLastConfirmed() - Method in class org.apache.bookkeeper.client.LedgerHandle

readLastConfirmedComplete(int, long, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.ReadLastConfirmedCallback

Callback definition for bookie recover operations

recoverBookieData(InetSocketAddress, InetSocketAddress) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Synchronous method to rebuild and recover the ledger fragments data that was stored on the source bookie.

recoverComplete(int, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.RecoverCallback

Callback definition for bookie recover operations

REGION_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

registerAllExtensions(ExtensionRegistry) - Static method in class org.apache.hedwig.protocol.PubSubProtocol

REMOTECOMPONENTS_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

right(U) - Static method in class org.apache.hedwig.util.Either

right() - Method in class org.apache.hedwig.util.Either

S

second() - Method in class org.apache.hedwig.util.Pair

SEP - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

SEQID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

serialize() - Method in class org.apache.bookkeeper.client.LedgerMetadata

Generates a byte array of this object

SERVER_ACK_RESPONSE_TIMEOUT - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

SERVER_TCP_NODELAY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

ServerConfiguration - Class in org.apache.bookkeeper.conf

Configuration manages server-side settings

ServerConfiguration() - Constructor for class org.apache.bookkeeper.conf.ServerConfiguration

Construct a default configuration object

ServerConfiguration(AbstractConfiguration) - Constructor for class org.apache.bookkeeper.conf.ServerConfiguration

Construct a configuration based on other configuration

setBody(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

setBookiePort(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set new bookie port that bookie server listen on

setBookieRecoveryDigestType(BookKeeper.DigestType) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set digest type used in bookkeeper admin.

setBookieRecoveryPasswd(byte[]) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set passwd used in bookkeeper admin.

setClientTcpNoDelay(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set socket nodelay setting.

setCode(int) - Method in exception org.apache.bookkeeper.client.BKException

setConsumeRequest(PubSubProtocol.ConsumeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setConsumeRequest(PubSubProtocol.ConsumeRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setCreateOrAttach(PubSubProtocol.SubscribeRequest.CreateOrAttach) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

setEndSeqIdIncluded(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

setEndSeqIdIncluded(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

setEntryLogSizeLimit(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set entry logger size limitation

setFlushInterval(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set flush interval

setGcWaitTime(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set garbage collection wait time

setJournalDirName(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set dir name to store journal files

setLedgerDirNames(String[]) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set dir names to store ledger data

setLedgerId(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder

setLedgerManagerType(String) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Set Ledger Manager Type.

setLocalComponent(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

setMaxBackupJournals(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set max number of older journal files to kept

setMaxJournalSize(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set new max journal file size

setMessage(PubSubProtocol.Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

setMessage(PubSubProtocol.Message.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

setMsg(PubSubProtocol.Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

setMsg(PubSubProtocol.Message.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder

setMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

setMsgId(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

setMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

setMsgId(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

setMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

setMsgId(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder

setProtocolVersion(PubSubProtocol.ProtocolVersion) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setProtocolVersion(PubSubProtocol.ProtocolVersion) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

setPublishRequest(PubSubProtocol.PublishRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setPublishRequest(PubSubProtocol.PublishRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setRanges(int, PubSubProtocol.LedgerRange) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

setRanges(int, PubSubProtocol.LedgerRange.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder

setRegion(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

setRemoteComponents(int, PubSubProtocol.RegionSpecificSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

setRemoteComponents(int, PubSubProtocol.RegionSpecificSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder

setSeqId(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder

setServerTcpNoDelay(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set socket nodelay setting

setShouldClaim(boolean) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setSrcRegion(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder

setStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setStatusCode(PubSubProtocol.StatusCode) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

setStatusMsg(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

setStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setSubscribeRequest(PubSubProtocol.SubscribeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setSubscribeRequest(PubSubProtocol.SubscribeRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder

setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder

setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder

setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder

setSynchronous(boolean) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder

setThrottleValue(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set throttle value.

setTopic(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setTopic(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

setTriedServers(int, ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setTxnId(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setTxnId(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder

setType(PubSubProtocol.OperationType) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder

setZkLedgersRootPath(String) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Set Zk Ledgers Root Path.

setZkServers(String) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set zookeeper servers to connect

setZkServers(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set zookeeper servers to connect

setZkTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set zookeeper timeout

setZkTimeout(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set zookeeper timeout

SHOULDCLAIM_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

sockAddrStr(InetSocketAddress) - Static method in class org.apache.hedwig.util.HedwigSocketAddress

SRCREGION_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.Message

SSL_ENABLED - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

startDelivery(ByteString, ByteString, MessageHandler) - Method in interface org.apache.hedwig.client.api.Subscriber

Begin delivery of messages from the server to us for this topic and subscriberId.

STARTDELIVERYREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

STATUSCODE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

STATUSMSG_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

stopDelivery(ByteString, ByteString) - Method in interface org.apache.hedwig.client.api.Subscriber

Stop delivery of messages for this topic and subscriberId.

STOPDELIVERYREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

subscribe(ByteString, ByteString, PubSubProtocol.SubscribeRequest.CreateOrAttach) - Method in interface org.apache.hedwig.client.api.Subscriber

Subscribe to the given topic for the inputted subscriberId.

SUBSCRIBE_RECONNECT_RETRY_WAIT_TIME - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

Subscriber - Interface in org.apache.hedwig.client.api

Interface to define the client Subscriber API.

SUBSCRIBEREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

SUBSCRIBERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

SUBSCRIBERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

SUBSCRIBERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

SUBSCRIBERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

SUBSCRIBERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

SUBSCRIBERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

SYNCHRONOUS_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

T

take(BlockingQueue<T>) - Static method in class org.apache.hedwig.util.ConcurrencyUtils

THROTTLE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

TIMEOUT_THREAD_RUN_INTERVAL - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

TOPIC_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

TOPIC_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

toString() - Method in exception org.apache.hedwig.exceptions.PubSubException.CompositeException

toString() - Method in class org.apache.hedwig.util.HedwigSocketAddress

TRIEDSERVERS_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

TXNID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

TXNID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

TYPE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

U

unsubscribe(ByteString, ByteString) - Method in interface org.apache.hedwig.client.api.Subscriber

Unsubscribe from a topic that the subscriberId user has previously subscribed to.

UNSUBSCRIBEREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

updateZnodeStatus(Stat) - Method in class org.apache.bookkeeper.client.LedgerMetadata

Updates the status of this metadata in ZooKeeper.

V

validate() - Method in class org.apache.hedwig.client.conf.ClientConfiguration

valueOf(String) - Static method in enum org.apache.bookkeeper.client.BookKeeper.DigestType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

Returns the enum constant of this type with the specified name.

valueOf(int) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

valueOf(Descriptors.EnumValueDescriptor) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

valueOf(String) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion

Returns the enum constant of this type with the specified name.

valueOf(int) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion

valueOf(Descriptors.EnumValueDescriptor) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion

valueOf(String) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

Returns the enum constant of this type with the specified name.

valueOf(int) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

valueOf(Descriptors.EnumValueDescriptor) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

valueOf(String) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach

Returns the enum constant of this type with the specified name.

valueOf(int) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach

valueOf(Descriptors.EnumValueDescriptor) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach

values() - Static method in enum org.apache.bookkeeper.client.BookKeeper.DigestType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach

Returns an array containing the constants of this enum type, in the order they are declared.

VERSION_KEY - Static variable in class org.apache.bookkeeper.client.LedgerMetadata

W

WriteException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

Z

ZK_LEDGERS_ROOT_PATH - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

ZK_SERVERS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

ZK_SERVERS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

ZK_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

ZK_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

ZKException - Static variable in interface org.apache.bookkeeper.client.BKException.Code

A B C D E F G H I J L M N O P Q R S T U V W Z