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 

Copyright © 2014 The Apache Software Foundation. All Rights Reserved.