- calcTp(int, long) - Static method in class org.apache.hedwig.client.benchmark.BenchmarkUtils
-
- call() - Method in class org.apache.hedwig.client.benchmark.BenchmarkPublisher
-
- call() - Method in class org.apache.hedwig.client.benchmark.BenchmarkSubscriber
-
- call() - Method in class org.apache.hedwig.client.benchmark.HedwigBenchmark
-
- 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
-
- cfg - Variable in class org.apache.hedwig.client.handlers.AbstractResponseHandler
-
- cfg - Variable in class org.apache.hedwig.client.netty.HedwigSubscriber
-
- cfg - Variable in class org.apache.hedwig.client.netty.impl.ActiveSubscriber
-
- cfg - Variable in class org.apache.hedwig.client.netty.impl.ClientChannelPipelineFactory
-
- channel - Variable in class org.apache.hedwig.client.netty.impl.ActiveSubscriber
-
- channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class org.apache.hedwig.client.netty.impl.HChannelHandler
-
- channelDisconnected(ChannelHandlerContext, ChannelStateEvent) - Method in class org.apache.hedwig.client.netty.impl.HChannelHandler
-
- channelManager - Variable in class org.apache.hedwig.client.handlers.AbstractResponseHandler
-
- channelManager - Variable in class org.apache.hedwig.client.netty.HedwigClientImpl
-
- channelManager - Variable in class org.apache.hedwig.client.netty.HedwigSubscriber
-
- channelManager - Variable in class org.apache.hedwig.client.netty.impl.ActiveSubscriber
-
- channelManager - Variable in class org.apache.hedwig.client.netty.impl.ClientChannelPipelineFactory
-
- checkLedger(LedgerHandle, BookkeeperInternalCallbacks.GenericCallback<Set<LedgerFragment>>) - Method in class org.apache.bookkeeper.client.LedgerChecker
-
Check that all the fragments in the passed in ledger, and report those
which are missing.
- checkTimeoutRequests() - Method in class org.apache.hedwig.client.netty.impl.HChannelHandler
-
- checkTimeoutRequestsOnSubscriptionChannels() - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
Chekout the pub/sub requests on subscription channels.
- checkTimeoutRequestsOnSubscriptionChannels() - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager
-
- checkTimeoutRequestsOnSubscriptionChannels() - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleHChannelManager
-
- CleanupChannelMap<T> - Class in org.apache.hedwig.client.netty
-
- CleanupChannelMap() - Constructor for class org.apache.hedwig.client.netty.CleanupChannelMap
-
- clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
-
- clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
- clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
- clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.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.ManagerMeta.Builder
-
- clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
- clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
- clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
- clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.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.PublishResponse.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.ResponseBody.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.SubscribeResponse.Builder
-
- clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
- clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
-
- clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
- clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
- clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
- clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
-
- clearAllTopicsForHost(InetSocketAddress) - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- clearBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
required bytes body = 1;
- clearCloseSubscriptionRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
- clearConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.ConsumeRequest consumeRequest = 54;
- clearCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 3 [default = CREATE_OR_ATTACH];
- clearCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH];
- clearCzxid() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
required uint64 czxid = 3;
- clearEnableResubscribe() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional bool enableResubscribe = 7 [default = true];
- clearEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2;
- clearEntries() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
repeated .Hedwig.Map.Entry entries = 1;
- clearEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
-
optional .Hedwig.SubscriptionEvent event = 1;
- clearForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional bool forceAttach = 7 [default = false];
- clearForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional bool forceAttach = 1 [default = false];
- clearHeader() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional .Hedwig.MessageHeader header = 4;
- clearHostForTopic(ByteString, InetSocketAddress) - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- clearHostname() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
required string hostname = 2;
- clearKey() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
optional string key = 1;
- clearLedgerId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
required uint64 ledgerId = 1;
- clearLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
optional uint64 localComponent = 1;
- clearManagerImpl() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
-
required string managerImpl = 2;
- clearManagerVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
-
required uint32 managerVersion = 3;
- clearMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional .Hedwig.Message message = 5;
- clearMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional uint32 messageBound = 5;
- clearMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional uint32 messageBound = 3 [default = 0];
- clearMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional uint32 messageBound = 2;
- clearMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
optional uint32 messageBound = 2;
- clearMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional string messageFilter = 5;
- clearMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional string messageFilter = 3;
- clearMessageType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
optional string messageType = 2;
- clearMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional uint32 messageWindowSize = 6;
- clearMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional uint32 messageWindowSize = 4;
- clearMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
-
required .Hedwig.Message msg = 2;
- clearMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
required .Hedwig.MessageSeqId msgId = 3;
- clearMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional .Hedwig.MessageSeqId msgId = 3;
- clearMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
required .Hedwig.MessageSeqId msgId = 1;
- clearNumTopics() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
-
required uint64 numTopics = 2;
- clearOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional .Hedwig.Map options = 4;
- clearOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional .Hedwig.Map options = 1;
- clearPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 6;
- clearPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- clearPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- clearProperties() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
optional .Hedwig.Map properties = 1;
- clearProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- clearProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- clearPublishedMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
-
required .Hedwig.MessageSeqId publishedMsgId = 1;
- clearPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.PublishRequest publishRequest = 52;
- clearPublishResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.PublishResponse publishResponse = 1;
- clearRanges() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
-
repeated .Hedwig.LedgerRange ranges = 1;
- clearRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
-
required bytes region = 1;
- clearRemoteComponents() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- clearResponseBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional .Hedwig.ResponseBody responseBody = 8;
- clearSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
-
required uint64 seqId = 2;
- clearServersList() - Method in class org.apache.hedwig.client.data.PubSubData
-
- clearShouldClaim() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional bool shouldClaim = 5;
- clearSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional bytes srcRegion = 2;
- clearStartDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
- clearStartSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
optional uint64 startSeqIdIncluded = 3;
- clearState() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
optional .Hedwig.SubscriptionState state = 1;
- clearStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
required .Hedwig.StatusCode statusCode = 2;
- clearStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional string statusMsg = 4;
- clearStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
- clearSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
- clearSubscribeResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.SubscribeResponse subscribeResponse = 2;
- clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
-
required bytes subscriberId = 2;
- clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
required bytes subscriberId = 2;
- clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional bytes subscriberId = 7;
- clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
-
required bytes subscriberId = 2;
- clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
-
required bytes subscriberId = 2;
- clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
required bytes subscriberId = 2;
- clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
-
required bytes subscriberId = 2;
- clearSubscriptionEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.SubscriptionEventResponse subscriptionEvent = 3;
- clearSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional bool synchronous = 4 [default = false];
- clearTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required bytes topic = 6;
- clearTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional bytes topic = 6;
- clearTriedServers() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
repeated bytes triedServers = 3;
- clearTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required uint64 txnId = 4;
- clearTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
required uint64 txnId = 3;
- clearType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required .Hedwig.OperationType type = 2;
- clearUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
- clearValue() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
optional bytes value = 2;
- Client - Interface in org.apache.hedwig.client.api
-
Interface defining the client API for Hedwig
- CLIENT_ALREADY_SUBSCRIBED_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
-
CLIENT_ALREADY_SUBSCRIBED = 403;
- CLIENT_NOT_SUBSCRIBED_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
-
CLIENT_NOT_SUBSCRIBED = 404;
- CLIENT_TCP_NODELAY - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
-
- ClientAlreadySubscribedException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ClientAlreadySubscribedException
-
- ClientChannelPipelineFactory - Class in org.apache.hedwig.client.netty.impl
-
- ClientChannelPipelineFactory(ClientConfiguration, AbstractHChannelManager) - Constructor for class org.apache.hedwig.client.netty.impl.ClientChannelPipelineFactory
-
- 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
-
- ClientNotSubscribedException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedException
-
- ClientNotSubscribedRuntimeException() - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedRuntimeException
-
- clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
-
- clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
- clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
- clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.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.ManagerMeta.Builder
-
- clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
- clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
- clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
- clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.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.PublishResponse.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.ResponseBody.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.SubscribeResponse.Builder
-
- clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
- clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
-
- clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
- clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.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
-
- close() - Method in class org.apache.hedwig.client.netty.CleanupChannelMap
-
Close the channels map.
- close() - Method in interface org.apache.hedwig.client.netty.HChannel
-
Close the channel without waiting.
- close(boolean) - Method in interface org.apache.hedwig.client.netty.HChannel
-
Close the channel
- close() - Method in interface org.apache.hedwig.client.netty.HChannelManager
-
Close the channel manager.
- close() - Method in class org.apache.hedwig.client.netty.HedwigClientImpl
-
- close() - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- close(boolean) - Method in class org.apache.hedwig.client.netty.impl.HChannelImpl
-
- close() - Method in class org.apache.hedwig.client.netty.impl.HChannelImpl
-
- closeComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.CloseCallback
-
Callback definition
- closed - Variable in class org.apache.hedwig.client.netty.CleanupChannelMap
-
- closed - Variable in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- closedLock - Variable in class org.apache.hedwig.client.netty.CleanupChannelMap
-
- closedLock - Variable in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- closeExplicitly() - Method in class org.apache.hedwig.client.netty.impl.HChannelHandler
-
- 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.
- closeSubscription(ByteString, ByteString) - Method in class org.apache.hedwig.client.netty.HedwigSubscriber
-
- CLOSESUBSCRIPTION_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType
-
CLOSESUBSCRIPTION = 6;
- closeSubscriptionChannels() - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
Close all subscription channels when close channel manager.
- closeSubscriptionChannels() - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager
-
- closeSubscriptionChannels() - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleHChannelManager
-
- CLOSESUBSCRIPTIONREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
- CloseSubscriptionResponseHandler - Class in org.apache.hedwig.client.handlers
-
- CloseSubscriptionResponseHandler(ClientConfiguration, HChannelManager) - Constructor for class org.apache.hedwig.client.handlers.CloseSubscriptionResponseHandler
-
- code - Variable in exception org.apache.hedwig.exceptions.PubSubException
-
- COLON - Static variable in class org.apache.hedwig.util.HedwigSocketAddress
-
- COMMA - Static variable in class org.apache.hedwig.client.data.PubSubData
-
- COMPOSITE_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
-
COMPOSITE = 700;
- CompositeException(Collection<PubSubException>) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.CompositeException
-
- ConcurrencyUtils - Class in org.apache.hedwig.util
-
- ConcurrencyUtils() - Constructor for class org.apache.hedwig.util.ConcurrencyUtils
-
- connect(InetSocketAddress, ClientChannelPipelineFactory) - Method in class org.apache.hedwig.client.netty.impl.HChannelImpl
-
This is a helper method to do the connect attempt to the server given the
inputted host/port.
- connectFailedServers - Variable in class org.apache.hedwig.client.data.PubSubData
-
- 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.
- consume(TopicSubscriber, PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.client.handlers.SubscribeResponseHandler
-
Consume a given message for given topic subscriber thru this handler.
- consume(ByteString, ByteString, PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.client.netty.HedwigSubscriber
-
- consume(TopicSubscriber, PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler
-
- consume(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.client.netty.impl.ActiveSubscriber
-
Consume a specific message.
- CONSUME_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType
-
CONSUME = 2;
- 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
-
- context - Variable in class org.apache.hedwig.client.data.PubSubData
-
- COULD_NOT_CONNECT_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
-
COULD_NOT_CONNECT = 405;
- CouldNotConnectException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.CouldNotConnectException
-
- create(int) - Static method in exception org.apache.bookkeeper.client.BKException
-
Create an exception from an error code
- create(ClientConfiguration) - Static method in class org.apache.hedwig.client.netty.HedwigClientImpl
-
- create(ClientConfiguration, ChannelFactory) - Static method in class org.apache.hedwig.client.netty.HedwigClientImpl
-
- create(PubSubProtocol.StatusCode, String) - Static method in exception org.apache.hedwig.exceptions.PubSubException
-
- CREATE_OR_ATTACH_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach
-
CREATE_OR_ATTACH = 2;
- CREATE_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach
-
CREATE = 0;
- createActiveSubscriber(ClientConfiguration, AbstractHChannelManager, TopicSubscriber, PubSubData, PubSubProtocol.SubscriptionPreferences, Channel, HChannel) - Method in class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler
-
- createActiveSubscriber(ClientConfiguration, AbstractHChannelManager, TopicSubscriber, PubSubData, PubSubProtocol.SubscriptionPreferences, Channel, HChannel) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleSubscribeResponseHandler
-
- createAndStoreSubscriptionChannel(Channel) - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
Create and store a subscription
HChannel
thru the underlying established
channel
- createAndStoreSubscriptionChannel(InetSocketAddress) - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
Create and store a subscription
HChannel
to target host.
- createAndStoreSubscriptionChannel(Channel) - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager
-
- createAndStoreSubscriptionChannel(InetSocketAddress) - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager
-
- createAndStoreSubscriptionChannel(Channel) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleHChannelManager
-
- createAndStoreSubscriptionChannel(InetSocketAddress) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleHChannelManager
-
- 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.
- createLedger(int, 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
-
- CREATEORATTACH_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
- createResponseHandlers() - Method in class org.apache.hedwig.client.netty.impl.ClientChannelPipelineFactory
-
- createResponseHandlers() - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexSubscriptionChannelPipelineFactory
-
- createResponseHandlers() - Method in class org.apache.hedwig.client.netty.impl.NonSubscriptionChannelPipelineFactory
-
- createResponseHandlers() - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleSubscriptionChannelPipelineFactory
-
- createTempDirectory(String) - Static method in class org.apache.hedwig.util.FileUtils
-
- createTempDirectory(String, String) - Static method in class org.apache.hedwig.util.FileUtils
-
- ctx - Variable in class org.apache.hedwig.client.ssl.SslContextFactory
-
- 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.
- CZXID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
-
- GC_WAIT_TIME - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
-
- get() - Method in class org.apache.hedwig.util.Option
-
- getAckQuorumSize() - Method in class org.apache.bookkeeper.client.LedgerMetadata
-
- getActiveSubscriber(TopicSubscriber) - Method in class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler
-
- getActiveSubscriber(TopicSubscriber) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleSubscribeResponseHandler
-
- getAddress() - Method in class org.apache.bookkeeper.client.LedgerFragment
-
Gets the failedBookie address
- getAuditorPeriodicCheckInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the regularity at which the auditor checks all ledgers.
- getBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
required bytes body = 1;
- getBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
required bytes body = 1;
- getBody() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
-
required bytes body = 1;
- 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
- getBookiesIndex() - Method in class org.apache.bookkeeper.client.LedgerFragment
-
Gets the failedBookie index
- getCallback() - Method in class org.apache.hedwig.client.data.PubSubData
-
- getChannel(T) - Method in class org.apache.hedwig.client.netty.CleanupChannelMap
-
Returns the channel bound with key
.
- getChannel() - Method in interface org.apache.hedwig.client.netty.HChannel
-
- getChannel() - Method in class org.apache.hedwig.client.netty.impl.HChannelImpl
-
- getChannelFactory() - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- getChannels() - Method in class org.apache.hedwig.client.netty.CleanupChannelMap
-
Return the channels in the map.
- getClientTcpNoDelay() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Is tcp connection no delay.
- getCloseSubscriptionRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
- getCloseSubscriptionRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
- getCloseSubscriptionRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
- getCloseSubscriptionRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
- getCloseSubscriptionRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
- getCloseSubscriptionRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
- getCloseSubscriptionRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
- 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
-
- getConfiguration() - Method in class org.apache.hedwig.client.netty.HedwigClientImpl
-
- getConfiguration() - Method in class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler
-
- getConsumeCallback() - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- getConsumedMessagesBufferSize() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
-
- getConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.ConsumeRequest consumeRequest = 54;
- getConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.ConsumeRequest consumeRequest = 54;
- getConsumeRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.ConsumeRequest consumeRequest = 54;
- getConsumeRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.ConsumeRequest consumeRequest = 54;
- getConsumeRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.ConsumeRequest consumeRequest = 54;
- getConsumeRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.ConsumeRequest consumeRequest = 54;
- getConsumeRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.ConsumeRequest consumeRequest = 54;
- getContext() - Method in class org.apache.hedwig.client.ssl.SslContextFactory
-
- getCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 3 [default = CREATE_OR_ATTACH];
- getCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 3 [default = CREATE_OR_ATTACH];
- getCreateOrAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 3 [default = CREATE_OR_ATTACH];
- getCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH];
- getCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH];
- getCreateOrAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH];
- getCzxid() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
required uint64 czxid = 3;
- getCzxid() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
-
required uint64 czxid = 3;
- getCzxid() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.HubInfoDataOrBuilder
-
required uint64 czxid = 3;
- getDeathWatchInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get bookie death watch interval
- getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
-
- getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
-
- getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
-
- getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
-
- 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.ManagerMeta
-
- getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
-
- getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
-
- getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
- getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
- 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.PublishResponse
-
- 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.ResponseBody
-
- 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.SubscribeResponse
-
- getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
-
- getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
-
- getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
- getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
- 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.CloseSubscriptionRequest.Builder
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
-
- 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.HubInfoData.Builder
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
-
- 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.ManagerMeta.Builder
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
-
- 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.MessageHeader.Builder
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
- 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.PublishResponse.Builder
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
-
- 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.ResponseBody.Builder
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
- 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.SubscribeResponse.Builder
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
- getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
- 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.CloseSubscriptionRequest.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
- 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.HubInfoData.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
- 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.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
-
- 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.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
- 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.SubscribeResponse.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
-
- getDescriptor() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
-
- getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
-
- getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
-
- getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
- getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
- getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.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.ManagerMeta.Builder
-
- getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
- getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
- getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
- getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.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.PublishResponse.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.ResponseBody.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.SubscribeResponse.Builder
-
- getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
- getDescriptorForType() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent
-
- getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
-
- getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
- getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
- getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
- getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
-
- getDiskCheckInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the disk checker interval
- getDiskUsageThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Returns disk free space threshold.
- getEnableResubscribe() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional bool enableResubscribe = 7 [default = true];
- getEnableResubscribe() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional bool enableResubscribe = 7 [default = true];
- getEnableResubscribe() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional bool enableResubscribe = 7 [default = true];
- getEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2;
- getEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
-
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2;
- getEndSeqIdIncluded() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangeOrBuilder
-
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2;
- getEndSeqIdIncludedBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2;
- getEndSeqIdIncludedOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2;
- getEndSeqIdIncludedOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
-
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2;
- getEndSeqIdIncludedOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangeOrBuilder
-
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2;
- getEngine() - Method in class org.apache.hedwig.client.ssl.SslContextFactory
-
- getEnsemble() - Method in class org.apache.bookkeeper.client.LedgerFragment
-
Gets the ensemble of fragment
- 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.
- getEnsembleSize() - Method in class org.apache.bookkeeper.client.LedgerMetadata
-
- getEntries(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntries(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntries(int) - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntriesBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntriesBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntriesCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntriesCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntriesCount() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntriesList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntriesList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntriesList() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntriesOrBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntriesOrBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntriesOrBuilder(int) - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntriesOrBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntriesOrBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
-
repeated .Hedwig.Map.Entry entries = 1;
- getEntriesOrBuilderList() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder
-
repeated .Hedwig.Map.Entry entries = 1;
- 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
- getEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
-
optional .Hedwig.SubscriptionEvent event = 1;
- getEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
-
optional .Hedwig.SubscriptionEvent event = 1;
- getEvent() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponseOrBuilder
-
optional .Hedwig.SubscriptionEvent event = 1;
- getExceptions() - Method in exception org.apache.hedwig.exceptions.PubSubException.CompositeException
-
- getFailureException() - Method in class org.apache.hedwig.client.handlers.PubSubCallback
-
- getFirstStoredEntryId() - Method in class org.apache.bookkeeper.client.LedgerFragment
-
Gets the first stored entry id of the fragment in failed bookie.
- getFlushInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get flush interval
- getForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional bool forceAttach = 7 [default = false];
- getForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
optional bool forceAttach = 7 [default = false];
- getForceAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
optional bool forceAttach = 7 [default = false];
- getForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional bool forceAttach = 1 [default = false];
- getForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional bool forceAttach = 1 [default = false];
- getForceAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional bool forceAttach = 1 [default = false];
- getGcWaitTime() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get Garbage collection wait time
- getHChannelHandlerFromChannel(Channel) - Static method in class org.apache.hedwig.client.netty.impl.HChannelImpl
-
Helper static method to get the ResponseHandler instance from a Channel
via the ChannelPipeline it is associated with.
- getHChannelManager() - Method in class org.apache.hedwig.client.netty.HedwigClientImpl
-
- getHChannelManager() - Method in class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler
-
- getHeader() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional .Hedwig.MessageHeader header = 4;
- getHeader() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
optional .Hedwig.MessageHeader header = 4;
- getHeader() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
-
optional .Hedwig.MessageHeader header = 4;
- getHeaderBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional .Hedwig.MessageHeader header = 4;
- getHeaderOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional .Hedwig.MessageHeader header = 4;
- getHeaderOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
optional .Hedwig.MessageHeader header = 4;
- getHeaderOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
-
optional .Hedwig.MessageHeader header = 4;
- getHostFromChannel(Channel) - Static method in class org.apache.hedwig.client.netty.NetUtils
-
Helper static method to get the String Hostname:Port from a netty
Channel.
- getHostname() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
required string hostname = 2;
- getHostname() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
-
required string hostname = 2;
- getHostname() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.HubInfoDataOrBuilder
-
required string hostname = 2;
- getHostname() - Method in class org.apache.hedwig.util.HedwigSocketAddress
-
- getHostnameBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
required string hostname = 2;
- getHostnameBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
-
required string hostname = 2;
- getHostnameBytes() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.HubInfoDataOrBuilder
-
required string hostname = 2;
- getId() - Method in class org.apache.bookkeeper.client.LedgerHandle
-
Get the id of the current ledger
- getIsCallSuccessful() - Method in class org.apache.hedwig.client.handlers.PubSubCallback
-
- 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
- getKey() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
optional string key = 1;
- getKey() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
-
optional string key = 1;
- getKey() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder
-
optional string key = 1;
- getKeyBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
optional string key = 1;
- getKeyBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
-
optional string key = 1;
- getKeyBytes() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder
-
optional string key = 1;
- 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)
- getLastEntryId() - Method in class org.apache.bookkeeper.client.LedgerMetadata
-
- getLastStoredEntryId() - Method in class org.apache.bookkeeper.client.LedgerFragment
-
Gets the last stored entry id of the fragment in failed bookie.
- 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
-
required uint64 ledgerId = 1;
- getLedgerId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
-
required uint64 ledgerId = 1;
- getLedgerId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangeOrBuilder
-
required uint64 ledgerId = 1;
- getLedgerKey() - Method in class org.apache.bookkeeper.client.LedgerHandle
-
Get the Ledger's key/password.
- getLedgerManagerFactoryClass() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Get ledger manager factory class.
- getLedgerManagerType() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
- 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.
- getLength() - Method in class org.apache.bookkeeper.client.LedgerMetadata
-
- getLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
optional uint64 localComponent = 1;
- getLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
-
optional uint64 localComponent = 1;
- getLocalComponent() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder
-
optional uint64 localComponent = 1;
- getMajorCompactionInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get interval to run major compaction, in seconds.
- getMajorCompactionThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get threshold of major compaction.
- getManagerImpl() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
-
required string managerImpl = 2;
- getManagerImpl() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
-
required string managerImpl = 2;
- getManagerImpl() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ManagerMetaOrBuilder
-
required string managerImpl = 2;
- getManagerImplBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
-
required string managerImpl = 2;
- getManagerImplBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
-
required string managerImpl = 2;
- getManagerImplBytes() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ManagerMetaOrBuilder
-
required string managerImpl = 2;
- getManagerVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
-
required uint32 managerVersion = 3;
- getManagerVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
-
required uint32 managerVersion = 3;
- getManagerVersion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ManagerMetaOrBuilder
-
required uint32 managerVersion = 3;
- 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
-
optional .Hedwig.Message message = 5;
- getMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
optional .Hedwig.Message message = 5;
- getMessage() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
optional .Hedwig.Message message = 5;
- getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional uint32 messageBound = 5;
- getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
optional uint32 messageBound = 5;
- getMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
optional uint32 messageBound = 5;
- getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional uint32 messageBound = 3 [default = 0];
- getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional uint32 messageBound = 3 [default = 0];
- getMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional uint32 messageBound = 3 [default = 0];
- getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional uint32 messageBound = 2;
- getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
optional uint32 messageBound = 2;
- getMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
optional uint32 messageBound = 2;
- getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
optional uint32 messageBound = 2;
- getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
-
optional uint32 messageBound = 2;
- getMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionStateOrBuilder
-
optional uint32 messageBound = 2;
- getMessageBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional .Hedwig.Message message = 5;
- getMessageConsumeRetryWaitTime() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
-
- getMessageFilter() - Method in class org.apache.hedwig.client.netty.FilterableMessageHandler
-
- getMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional string messageFilter = 5;
- getMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional string messageFilter = 5;
- getMessageFilter() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional string messageFilter = 5;
- getMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional string messageFilter = 3;
- getMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
optional string messageFilter = 3;
- getMessageFilter() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
optional string messageFilter = 3;
- getMessageFilterBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional string messageFilter = 5;
- getMessageFilterBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional string messageFilter = 5;
- getMessageFilterBytes() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional string messageFilter = 5;
- getMessageFilterBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional string messageFilter = 3;
- getMessageFilterBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
optional string messageFilter = 3;
- getMessageFilterBytes() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
optional string messageFilter = 3;
- getMessageHandler() - Method in class org.apache.hedwig.client.netty.FilterableMessageHandler
-
- getMessageOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional .Hedwig.Message message = 5;
- getMessageOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
optional .Hedwig.Message message = 5;
- getMessageOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
optional .Hedwig.Message message = 5;
- getMessageType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
optional string messageType = 2;
- getMessageType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
optional string messageType = 2;
- getMessageType() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
-
optional string messageType = 2;
- getMessageTypeBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
optional string messageType = 2;
- getMessageTypeBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
optional string messageType = 2;
- getMessageTypeBytes() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
-
optional string messageType = 2;
- getMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional uint32 messageWindowSize = 6;
- getMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional uint32 messageWindowSize = 6;
- getMessageWindowSize() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional uint32 messageWindowSize = 6;
- getMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional uint32 messageWindowSize = 4;
- getMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
optional uint32 messageWindowSize = 4;
- getMessageWindowSize() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
optional uint32 messageWindowSize = 4;
- getMetastoreImplClass() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Get metastore implementation class.
- getMetastoreMaxEntriesPerScan() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Get max entries per scan in metastore.
- getMinorCompactionInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get interval to run minor compaction, in seconds.
- getMinorCompactionThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get threshold of minor compaction.
- getMsg(int) - Method in class org.apache.hedwig.client.benchmark.BenchmarkPublisher
-
- getMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
-
required .Hedwig.Message msg = 2;
- getMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
-
required .Hedwig.Message msg = 2;
- getMsg() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishRequestOrBuilder
-
required .Hedwig.Message msg = 2;
- getMsgBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
-
required .Hedwig.Message msg = 2;
- getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
required .Hedwig.MessageSeqId msgId = 3;
- getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
-
required .Hedwig.MessageSeqId msgId = 3;
- getMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequestOrBuilder
-
required .Hedwig.MessageSeqId msgId = 3;
- getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional .Hedwig.MessageSeqId msgId = 3;
- getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
optional .Hedwig.MessageSeqId msgId = 3;
- getMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
-
optional .Hedwig.MessageSeqId msgId = 3;
- getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
required .Hedwig.MessageSeqId msgId = 1;
- getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
-
required .Hedwig.MessageSeqId msgId = 1;
- getMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionStateOrBuilder
-
required .Hedwig.MessageSeqId msgId = 1;
- getMsgIdBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
required .Hedwig.MessageSeqId msgId = 3;
- getMsgIdBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional .Hedwig.MessageSeqId msgId = 3;
- getMsgIdBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
required .Hedwig.MessageSeqId msgId = 1;
- getMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
required .Hedwig.MessageSeqId msgId = 3;
- getMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
-
required .Hedwig.MessageSeqId msgId = 3;
- getMsgIdOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequestOrBuilder
-
required .Hedwig.MessageSeqId msgId = 3;
- getMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional .Hedwig.MessageSeqId msgId = 3;
- getMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
optional .Hedwig.MessageSeqId msgId = 3;
- getMsgIdOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
-
optional .Hedwig.MessageSeqId msgId = 3;
- getMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
required .Hedwig.MessageSeqId msgId = 1;
- getMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
-
required .Hedwig.MessageSeqId msgId = 1;
- getMsgIdOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionStateOrBuilder
-
required .Hedwig.MessageSeqId msgId = 1;
- getMsgOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
-
required .Hedwig.Message msg = 2;
- getMsgOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
-
required .Hedwig.Message msg = 2;
- getMsgOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishRequestOrBuilder
-
required .Hedwig.Message msg = 2;
- getNonSubscriptionChannelPipelineFactory() - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- 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
-
- getNumber() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent
-
- getNumTopics() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
-
required uint64 numTopics = 2;
- getNumTopics() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
-
required uint64 numTopics = 2;
- getNumTopics() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.HubLoadDataOrBuilder
-
required uint64 numTopics = 2;
- getNumWorkerThreads() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get the number of worker threads.
- getOpenFileLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get open file limit
- getOpenLedgerRereplicationGracePeriod() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the grace period which the rereplication worker to wait before
fencing and rereplicating a ledger fragment which is still being written
to, on bookie failure.
- getOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional .Hedwig.Map options = 4;
- getOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional .Hedwig.Map options = 4;
- getOptions() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional .Hedwig.Map options = 4;
- getOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional .Hedwig.Map options = 1;
- getOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
optional .Hedwig.Map options = 1;
- getOptions() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
optional .Hedwig.Map options = 1;
- getOptionsBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional .Hedwig.Map options = 4;
- getOptionsBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional .Hedwig.Map options = 1;
- getOptionsOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional .Hedwig.Map options = 4;
- getOptionsOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional .Hedwig.Map options = 4;
- getOptionsOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional .Hedwig.Map options = 4;
- getOptionsOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional .Hedwig.Map options = 1;
- getOptionsOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
optional .Hedwig.Map options = 1;
- getOptionsOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
optional .Hedwig.Map options = 1;
- getOriginalChannelForResubscribe() - Method in class org.apache.hedwig.client.data.PubSubData
-
- 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
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
-
- getParserForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
-
- getPipeline() - Method in class org.apache.hedwig.client.netty.impl.ClientChannelPipelineFactory
-
- getPort() - Method in class org.apache.hedwig.util.HedwigSocketAddress
-
- getPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 6;
- getPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
optional .Hedwig.SubscriptionPreferences preferences = 6;
- getPreferences() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
optional .Hedwig.SubscriptionPreferences preferences = 6;
- getPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- getPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- getPreferences() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponseOrBuilder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- getPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- getPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- getPreferences() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionDataOrBuilder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- getPreferencesBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 6;
- getPreferencesBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- getPreferencesBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- getPreferencesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 6;
- getPreferencesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
optional .Hedwig.SubscriptionPreferences preferences = 6;
- getPreferencesOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
optional .Hedwig.SubscriptionPreferences preferences = 6;
- getPreferencesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- getPreferencesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- getPreferencesOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponseOrBuilder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- getPreferencesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- getPreferencesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- getPreferencesOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionDataOrBuilder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- getProperties() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
optional .Hedwig.Map properties = 1;
- getProperties() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
optional .Hedwig.Map properties = 1;
- getProperties() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
-
optional .Hedwig.Map properties = 1;
- getPropertiesBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
optional .Hedwig.Map properties = 1;
- getPropertiesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
optional .Hedwig.Map properties = 1;
- getPropertiesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
optional .Hedwig.Map properties = 1;
- getPropertiesOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
-
optional .Hedwig.Map properties = 1;
- getProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- getProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- getProtocolVersion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- getProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- getProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- getProtocolVersion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- getPublishedMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
-
required .Hedwig.MessageSeqId publishedMsgId = 1;
- getPublishedMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
-
required .Hedwig.MessageSeqId publishedMsgId = 1;
- getPublishedMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishResponseOrBuilder
-
required .Hedwig.MessageSeqId publishedMsgId = 1;
- getPublishedMsgIdBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
-
required .Hedwig.MessageSeqId publishedMsgId = 1;
- getPublishedMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
-
required .Hedwig.MessageSeqId publishedMsgId = 1;
- getPublishedMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
-
required .Hedwig.MessageSeqId publishedMsgId = 1;
- getPublishedMsgIdOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishResponseOrBuilder
-
required .Hedwig.MessageSeqId publishedMsgId = 1;
- 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
-
- getPublisher() - Method in class org.apache.hedwig.client.netty.HedwigClientImpl
-
- getPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.PublishRequest publishRequest = 52;
- getPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.PublishRequest publishRequest = 52;
- getPublishRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.PublishRequest publishRequest = 52;
- getPublishRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.PublishRequest publishRequest = 52;
- getPublishRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.PublishRequest publishRequest = 52;
- getPublishRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.PublishRequest publishRequest = 52;
- getPublishRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.PublishRequest publishRequest = 52;
- getPublishResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.PublishResponse publishResponse = 1;
- getPublishResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
optional .Hedwig.PublishResponse publishResponse = 1;
- getPublishResponse() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
-
optional .Hedwig.PublishResponse publishResponse = 1;
- getPublishResponseBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.PublishResponse publishResponse = 1;
- getPublishResponseOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.PublishResponse publishResponse = 1;
- getPublishResponseOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
optional .Hedwig.PublishResponse publishResponse = 1;
- getPublishResponseOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
-
optional .Hedwig.PublishResponse publishResponse = 1;
- getPubSubData() - Method in class org.apache.hedwig.client.netty.impl.ActiveSubscriber
-
- getRanges(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRanges(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRanges(int) - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangesOrBuilder
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRangesBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRangesBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRangesCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRangesCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRangesCount() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangesOrBuilder
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRangesList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRangesList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRangesList() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangesOrBuilder
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRangesOrBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRangesOrBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRangesOrBuilder(int) - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangesOrBuilder
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRangesOrBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRangesOrBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
-
repeated .Hedwig.LedgerRange ranges = 1;
- getRangesOrBuilderList() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangesOrBuilder
-
repeated .Hedwig.LedgerRange ranges = 1;
- getReadTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get the socket read timeout.
- getRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
-
required bytes region = 1;
- getRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
-
required bytes region = 1;
- getRegion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqIdOrBuilder
-
required bytes region = 1;
- getRemoteComponents(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponents(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponents(int) - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponentsBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponentsBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponentsCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponentsCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponentsCount() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponentsList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponentsList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponentsList() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponentsOrBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponentsOrBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponentsOrBuilder(int) - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponentsOrBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponentsOrBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRemoteComponentsOrBuilderList() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- getRereplicationEntryBatchSize() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Get the re-replication entry batch size
- getResponseBody() - Method in class org.apache.hedwig.client.handlers.PubSubCallback
-
- getResponseBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional .Hedwig.ResponseBody responseBody = 8;
- getResponseBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
optional .Hedwig.ResponseBody responseBody = 8;
- getResponseBody() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
optional .Hedwig.ResponseBody responseBody = 8;
- getResponseBodyBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional .Hedwig.ResponseBody responseBody = 8;
- getResponseBodyOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional .Hedwig.ResponseBody responseBody = 8;
- getResponseBodyOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
optional .Hedwig.ResponseBody responseBody = 8;
- getResponseBodyOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
optional .Hedwig.ResponseBody responseBody = 8;
- getSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
-
required uint64 seqId = 2;
- getSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
-
required uint64 seqId = 2;
- getSeqId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqIdOrBuilder
-
required uint64 seqId = 2;
- getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
-
- getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
-
- getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
-
- getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
-
- 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.ManagerMeta
-
- getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
-
- getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
-
- getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
- getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
- 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.PublishResponse
-
- 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.ResponseBody
-
- 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.SubscribeResponse
-
- getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
-
- getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
-
- getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
- getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
- 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
-
optional bool shouldClaim = 5;
- getShouldClaim() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional bool shouldClaim = 5;
- getShouldClaim() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional bool shouldClaim = 5;
- getSocketAddress() - Method in class org.apache.hedwig.util.HedwigSocketAddress
-
- getSpeculativeReadTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get the period of time after which a speculative entry read should be triggered.
- getSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional bytes srcRegion = 2;
- getSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
optional bytes srcRegion = 2;
- getSrcRegion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
-
optional bytes srcRegion = 2;
- getSslFactory() - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- 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
-
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
- getStartDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
- getStartDeliveryRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
- getStartDeliveryRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
- getStartDeliveryRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
- getStartDeliveryRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
- getStartDeliveryRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
- getStartSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
optional uint64 startSeqIdIncluded = 3;
- getStartSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
-
optional uint64 startSeqIdIncluded = 3;
- getStartSeqIdIncluded() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangeOrBuilder
-
optional uint64 startSeqIdIncluded = 3;
- getState() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
optional .Hedwig.SubscriptionState state = 1;
- getState() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
-
optional .Hedwig.SubscriptionState state = 1;
- getState() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionDataOrBuilder
-
optional .Hedwig.SubscriptionState state = 1;
- getStateBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
optional .Hedwig.SubscriptionState state = 1;
- getStateOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
optional .Hedwig.SubscriptionState state = 1;
- getStateOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
-
optional .Hedwig.SubscriptionState state = 1;
- getStateOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionDataOrBuilder
-
optional .Hedwig.SubscriptionState state = 1;
- getStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
required .Hedwig.StatusCode statusCode = 2;
- getStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
required .Hedwig.StatusCode statusCode = 2;
- getStatusCode() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
required .Hedwig.StatusCode statusCode = 2;
- getStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional string statusMsg = 4;
- getStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
optional string statusMsg = 4;
- getStatusMsg() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
optional string statusMsg = 4;
- getStatusMsgBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional string statusMsg = 4;
- getStatusMsgBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
optional string statusMsg = 4;
- getStatusMsgBytes() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
optional string statusMsg = 4;
- getStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
- getStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
- getStopDeliveryRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
- getStopDeliveryRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
- getStopDeliveryRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
- getStopDeliveryRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
- getStopDeliveryRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
- 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
-
- getSubscriber() - Method in class org.apache.hedwig.client.netty.HedwigClientImpl
-
- getSubscribeReconnectRetryWaitTime() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
-
- getSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
- getSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
- getSubscribeRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
- getSubscribeRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
- getSubscribeRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
- getSubscribeRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
- getSubscribeRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
- getSubscribeResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.SubscribeResponse subscribeResponse = 2;
- getSubscribeResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
optional .Hedwig.SubscribeResponse subscribeResponse = 2;
- getSubscribeResponse() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
-
optional .Hedwig.SubscribeResponse subscribeResponse = 2;
- getSubscribeResponseBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.SubscribeResponse subscribeResponse = 2;
- getSubscribeResponseHandler(TopicSubscriber) - Method in interface org.apache.hedwig.client.netty.HChannelManager
-
Get the subscribe response handler managed the given topicSubscriber
.
- getSubscribeResponseHandler() - Method in class org.apache.hedwig.client.netty.impl.HChannelHandler
-
- getSubscribeResponseHandler(TopicSubscriber) - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager
-
- getSubscribeResponseHandler(TopicSubscriber) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleHChannelManager
-
- getSubscribeResponseOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.SubscribeResponse subscribeResponse = 2;
- getSubscribeResponseOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
optional .Hedwig.SubscribeResponse subscribeResponse = 2;
- getSubscribeResponseOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
-
optional .Hedwig.SubscribeResponse subscribeResponse = 2;
- getSubscriberId() - Method in class org.apache.hedwig.client.data.TopicSubscriber
-
- getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequestOrBuilder
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequestOrBuilder
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional bytes subscriberId = 7;
- getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
optional bytes subscriberId = 7;
- getSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
optional bytes subscriberId = 7;
- getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequestOrBuilder
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequestOrBuilder
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
-
required bytes subscriberId = 2;
- getSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequestOrBuilder
-
required bytes subscriberId = 2;
- getSubscriptionChannel(InetSocketAddress) - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
Is there a subscription
HChannel
existed for a given host.
- getSubscriptionChannel(InetSocketAddress) - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager
-
- getSubscriptionChannel(TopicSubscriber) - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager
-
- getSubscriptionChannel(InetSocketAddress) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleHChannelManager
-
- getSubscriptionChannelByTopicSubscriber(TopicSubscriber) - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
Get a subscription channel for a given topicSubscriber
.
- getSubscriptionChannelByTopicSubscriber(TopicSubscriber) - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager
-
- getSubscriptionChannelByTopicSubscriber(TopicSubscriber) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleHChannelManager
-
- getSubscriptionChannelPipelineFactory() - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- getSubscriptionChannelPipelineFactory() - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager
-
- getSubscriptionChannelPipelineFactory() - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleHChannelManager
-
- getSubscriptionEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.SubscriptionEventResponse subscriptionEvent = 3;
- getSubscriptionEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
optional .Hedwig.SubscriptionEventResponse subscriptionEvent = 3;
- getSubscriptionEvent() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
-
optional .Hedwig.SubscriptionEventResponse subscriptionEvent = 3;
- getSubscriptionEventBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.SubscriptionEventResponse subscriptionEvent = 3;
- getSubscriptionEventEmitter() - Method in interface org.apache.hedwig.client.netty.HChannelManager
-
Return the subscription event emitter to emit subscription events.
- getSubscriptionEventEmitter() - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- getSubscriptionEventOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.SubscriptionEventResponse subscriptionEvent = 3;
- getSubscriptionEventOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
optional .Hedwig.SubscriptionEventResponse subscriptionEvent = 3;
- getSubscriptionEventOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
-
optional .Hedwig.SubscriptionEventResponse subscriptionEvent = 3;
- getSubscriptionList(ByteString) - Method in interface org.apache.hedwig.client.api.Subscriber
-
Fills the input List with the subscriptions this subscriberId client is
subscribed to.
- getSubscriptionList(ByteString) - Method in class org.apache.hedwig.client.netty.HedwigSubscriber
-
- getSubscriptionMessageBound() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
-
The maximum number of messages the hub will queue for subscriptions
created using this configuration.
- getSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional bool synchronous = 4 [default = false];
- getSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
optional bool synchronous = 4 [default = false];
- getSynchronous() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
optional bool synchronous = 4 [default = false];
- 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.client.data.TopicSubscriber
-
- getTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required bytes topic = 6;
- getTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
required bytes topic = 6;
- getTopic() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
required bytes topic = 6;
- getTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional bytes topic = 6;
- getTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
optional bytes topic = 6;
- getTopic() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
optional bytes topic = 6;
- getTopicSubscriber() - Method in class org.apache.hedwig.client.netty.impl.ActiveSubscriber
-
- getTriedServers(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
repeated bytes triedServers = 3;
- getTriedServers(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
repeated bytes triedServers = 3;
- getTriedServers(int) - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
repeated bytes triedServers = 3;
- getTriedServersCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
repeated bytes triedServers = 3;
- getTriedServersCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
repeated bytes triedServers = 3;
- getTriedServersCount() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
repeated bytes triedServers = 3;
- getTriedServersList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
repeated bytes triedServers = 3;
- getTriedServersList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
repeated bytes triedServers = 3;
- getTriedServersList() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
repeated bytes triedServers = 3;
- getTrustManagers() - Method in class org.apache.hedwig.client.ssl.SslContextFactory
-
- getTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required uint64 txnId = 4;
- getTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
required uint64 txnId = 4;
- getTxnId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
required uint64 txnId = 4;
- getTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
required uint64 txnId = 3;
- getTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
required uint64 txnId = 3;
- getTxnId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
required uint64 txnId = 3;
- getType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required .Hedwig.OperationType type = 2;
- getType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
required .Hedwig.OperationType type = 2;
- getType() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
required .Hedwig.OperationType type = 2;
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
-
- getUnknownFields() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
-
- getUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
- getUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
- getUnsubscribeRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
- getUnsubscribeRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
- getUnsubscribeRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
- getUnsubscribeRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
- getUnsubscribeRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
- getValue() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
optional bytes value = 2;
- getValue() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
-
optional bytes value = 2;
- getValue() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder
-
optional bytes value = 2;
- 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
-
- getValueDescriptor() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent
-
- getVersion() - Method in class org.apache.bookkeeper.client.LedgerMetadata
-
Returns the last version.
- getWriteQuorumSize() - Method in class org.apache.bookkeeper.client.LedgerMetadata
-
- getZkAvailableBookiesPath() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Get the node under which available bookies are stored
- 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
- globalCounter - Variable in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- handleMessage(PubSubProtocol.Message) - Method in class org.apache.hedwig.client.netty.impl.ActiveSubscriber
-
Handle received message.
- handleRedirectResponse(PubSubProtocol.PubSubResponse, PubSubData, Channel) - Method in class org.apache.hedwig.client.handlers.AbstractResponseHandler
-
Logic to repost a PubSubRequest when the server responds with a redirect
indicating they are not the topic master.
- handleResponse(PubSubProtocol.PubSubResponse, PubSubData, Channel) - Method in class org.apache.hedwig.client.handlers.AbstractResponseHandler
-
Logic to handle received response.
- handleResponse(PubSubProtocol.PubSubResponse, PubSubData, Channel) - Method in class org.apache.hedwig.client.handlers.CloseSubscriptionResponseHandler
-
- handleResponse(PubSubProtocol.PubSubResponse, PubSubData, Channel) - Method in class org.apache.hedwig.client.handlers.PublishResponseHandler
-
- handleResponse(PubSubProtocol.PubSubResponse, PubSubData, Channel) - Method in class org.apache.hedwig.client.handlers.UnsubscribeResponseHandler
-
- handleResponse(PubSubProtocol.PubSubResponse, PubSubData, Channel) - Method in class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler
-
- handleResponse(PubSubProtocol.PubSubResponse, PubSubData, Channel) - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexSubscribeResponseHandler
-
- handleResponse(PubSubProtocol.PubSubResponse, PubSubData, Channel) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleSubscribeResponseHandler
-
- handleSubscribeMessage(PubSubProtocol.PubSubResponse) - Method in class org.apache.hedwig.client.handlers.SubscribeResponseHandler
-
Handle Message delivered by the server.
- handleSubscribeMessage(PubSubProtocol.PubSubResponse) - Method in class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler
-
- handleSubscribeMessage(PubSubProtocol.PubSubResponse) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleSubscribeResponseHandler
-
- handleSubscriptionEvent(ByteString, ByteString, PubSubProtocol.SubscriptionEvent) - Method in class org.apache.hedwig.client.handlers.SubscribeResponseHandler
-
Handle a subscription event delivered by the server.
- handleSubscriptionEvent(ByteString, ByteString, PubSubProtocol.SubscriptionEvent) - Method in class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler
-
- handleSuccessResponse(TopicSubscriber, PubSubData, Channel) - Method in class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler
-
Handle success response for a specific TopicSubscriber ts
.
- handleSuccessResponse(TopicSubscriber, PubSubData, Channel) - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexSubscribeResponseHandler
-
- handleSuccessResponse(TopicSubscriber, PubSubData, Channel) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleSubscribeResponseHandler
-
- hasBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
required bytes body = 1;
- hasBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
required bytes body = 1;
- hasBody() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
-
required bytes body = 1;
- hasCloseSubscriptionRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
- hasCloseSubscriptionRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
- hasCloseSubscriptionRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
- hasConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.ConsumeRequest consumeRequest = 54;
- hasConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.ConsumeRequest consumeRequest = 54;
- hasConsumeRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.ConsumeRequest consumeRequest = 54;
- hasCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 3 [default = CREATE_OR_ATTACH];
- hasCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 3 [default = CREATE_OR_ATTACH];
- hasCreateOrAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 3 [default = CREATE_OR_ATTACH];
- hasCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH];
- hasCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH];
- hasCreateOrAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH];
- hasCzxid() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
required uint64 czxid = 3;
- hasCzxid() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
-
required uint64 czxid = 3;
- hasCzxid() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.HubInfoDataOrBuilder
-
required uint64 czxid = 3;
- hasEnableResubscribe() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional bool enableResubscribe = 7 [default = true];
- hasEnableResubscribe() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional bool enableResubscribe = 7 [default = true];
- hasEnableResubscribe() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional bool enableResubscribe = 7 [default = true];
- hasEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2;
- hasEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
-
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2;
- hasEndSeqIdIncluded() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangeOrBuilder
-
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2;
- hasEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
-
optional .Hedwig.SubscriptionEvent event = 1;
- hasEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
-
optional .Hedwig.SubscriptionEvent event = 1;
- hasEvent() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponseOrBuilder
-
optional .Hedwig.SubscriptionEvent event = 1;
- hasForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional bool forceAttach = 7 [default = false];
- hasForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
optional bool forceAttach = 7 [default = false];
- hasForceAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
optional bool forceAttach = 7 [default = false];
- hasForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional bool forceAttach = 1 [default = false];
- hasForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional bool forceAttach = 1 [default = false];
- hasForceAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional bool forceAttach = 1 [default = false];
- hashCode() - Method in class org.apache.hedwig.client.data.TopicSubscriber
-
- hashCode() - Method in class org.apache.hedwig.util.HedwigSocketAddress
-
- hasHeader() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional .Hedwig.MessageHeader header = 4;
- hasHeader() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
optional .Hedwig.MessageHeader header = 4;
- hasHeader() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
-
optional .Hedwig.MessageHeader header = 4;
- hasHostname() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
required string hostname = 2;
- hasHostname() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
-
required string hostname = 2;
- hasHostname() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.HubInfoDataOrBuilder
-
required string hostname = 2;
- hasKey() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
optional string key = 1;
- hasKey() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
-
optional string key = 1;
- hasKey() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder
-
optional string key = 1;
- hasLedgerId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
required uint64 ledgerId = 1;
- hasLedgerId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
-
required uint64 ledgerId = 1;
- hasLedgerId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangeOrBuilder
-
required uint64 ledgerId = 1;
- hasLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
optional uint64 localComponent = 1;
- hasLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
-
optional uint64 localComponent = 1;
- hasLocalComponent() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder
-
optional uint64 localComponent = 1;
- hasManagerImpl() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
-
required string managerImpl = 2;
- hasManagerImpl() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
-
required string managerImpl = 2;
- hasManagerImpl() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ManagerMetaOrBuilder
-
required string managerImpl = 2;
- hasManagerVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
-
required uint32 managerVersion = 3;
- hasManagerVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
-
required uint32 managerVersion = 3;
- hasManagerVersion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ManagerMetaOrBuilder
-
required uint32 managerVersion = 3;
- hasMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional .Hedwig.Message message = 5;
- hasMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
optional .Hedwig.Message message = 5;
- hasMessage() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
optional .Hedwig.Message message = 5;
- hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional uint32 messageBound = 5;
- hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
optional uint32 messageBound = 5;
- hasMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
optional uint32 messageBound = 5;
- hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional uint32 messageBound = 3 [default = 0];
- hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional uint32 messageBound = 3 [default = 0];
- hasMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional uint32 messageBound = 3 [default = 0];
- hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional uint32 messageBound = 2;
- hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
optional uint32 messageBound = 2;
- hasMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
optional uint32 messageBound = 2;
- hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
optional uint32 messageBound = 2;
- hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
-
optional uint32 messageBound = 2;
- hasMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionStateOrBuilder
-
optional uint32 messageBound = 2;
- hasMessageFilter() - Method in class org.apache.hedwig.client.netty.FilterableMessageHandler
-
- hasMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional string messageFilter = 5;
- hasMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional string messageFilter = 5;
- hasMessageFilter() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional string messageFilter = 5;
- hasMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional string messageFilter = 3;
- hasMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
optional string messageFilter = 3;
- hasMessageFilter() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
optional string messageFilter = 3;
- hasMessageHandler() - Method in class org.apache.hedwig.client.netty.FilterableMessageHandler
-
- hasMessageType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
optional string messageType = 2;
- hasMessageType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
optional string messageType = 2;
- hasMessageType() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
-
optional string messageType = 2;
- hasMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional uint32 messageWindowSize = 6;
- hasMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional uint32 messageWindowSize = 6;
- hasMessageWindowSize() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional uint32 messageWindowSize = 6;
- hasMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional uint32 messageWindowSize = 4;
- hasMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
optional uint32 messageWindowSize = 4;
- hasMessageWindowSize() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
optional uint32 messageWindowSize = 4;
- hasMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
-
required .Hedwig.Message msg = 2;
- hasMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
-
required .Hedwig.Message msg = 2;
- hasMsg() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishRequestOrBuilder
-
required .Hedwig.Message msg = 2;
- hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
required .Hedwig.MessageSeqId msgId = 3;
- hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
-
required .Hedwig.MessageSeqId msgId = 3;
- hasMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequestOrBuilder
-
required .Hedwig.MessageSeqId msgId = 3;
- hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional .Hedwig.MessageSeqId msgId = 3;
- hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
optional .Hedwig.MessageSeqId msgId = 3;
- hasMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
-
optional .Hedwig.MessageSeqId msgId = 3;
- hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
required .Hedwig.MessageSeqId msgId = 1;
- hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
-
required .Hedwig.MessageSeqId msgId = 1;
- hasMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionStateOrBuilder
-
required .Hedwig.MessageSeqId msgId = 1;
- hasNumTopics() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
-
required uint64 numTopics = 2;
- hasNumTopics() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
-
required uint64 numTopics = 2;
- hasNumTopics() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.HubLoadDataOrBuilder
-
required uint64 numTopics = 2;
- hasOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional .Hedwig.Map options = 4;
- hasOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
optional .Hedwig.Map options = 4;
- hasOptions() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
optional .Hedwig.Map options = 4;
- hasOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional .Hedwig.Map options = 1;
- hasOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
optional .Hedwig.Map options = 1;
- hasOptions() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
optional .Hedwig.Map options = 1;
- hasPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 6;
- hasPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
optional .Hedwig.SubscriptionPreferences preferences = 6;
- hasPreferences() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
optional .Hedwig.SubscriptionPreferences preferences = 6;
- hasPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- hasPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- hasPreferences() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponseOrBuilder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- hasPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- hasPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- hasPreferences() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionDataOrBuilder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- hasProperties() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
optional .Hedwig.Map properties = 1;
- hasProperties() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
optional .Hedwig.Map properties = 1;
- hasProperties() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
-
optional .Hedwig.Map properties = 1;
- hasProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- hasProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- hasProtocolVersion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- hasProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- hasProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- hasProtocolVersion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- hasPublishedMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
-
required .Hedwig.MessageSeqId publishedMsgId = 1;
- hasPublishedMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
-
required .Hedwig.MessageSeqId publishedMsgId = 1;
- hasPublishedMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishResponseOrBuilder
-
required .Hedwig.MessageSeqId publishedMsgId = 1;
- hasPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.PublishRequest publishRequest = 52;
- hasPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.PublishRequest publishRequest = 52;
- hasPublishRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.PublishRequest publishRequest = 52;
- hasPublishResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.PublishResponse publishResponse = 1;
- hasPublishResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
optional .Hedwig.PublishResponse publishResponse = 1;
- hasPublishResponse() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
-
optional .Hedwig.PublishResponse publishResponse = 1;
- hasRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
-
required bytes region = 1;
- hasRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
-
required bytes region = 1;
- hasRegion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqIdOrBuilder
-
required bytes region = 1;
- hasResponseBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional .Hedwig.ResponseBody responseBody = 8;
- hasResponseBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
optional .Hedwig.ResponseBody responseBody = 8;
- hasResponseBody() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
optional .Hedwig.ResponseBody responseBody = 8;
- hasSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
-
required uint64 seqId = 2;
- hasSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
-
required uint64 seqId = 2;
- hasSeqId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqIdOrBuilder
-
required uint64 seqId = 2;
- hasShouldClaim() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional bool shouldClaim = 5;
- hasShouldClaim() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional bool shouldClaim = 5;
- hasShouldClaim() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional bool shouldClaim = 5;
- hasSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional bytes srcRegion = 2;
- hasSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
optional bytes srcRegion = 2;
- hasSrcRegion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
-
optional bytes srcRegion = 2;
- hasStartDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
- hasStartDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
- hasStartDeliveryRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
- hasStartSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
optional uint64 startSeqIdIncluded = 3;
- hasStartSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
-
optional uint64 startSeqIdIncluded = 3;
- hasStartSeqIdIncluded() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangeOrBuilder
-
optional uint64 startSeqIdIncluded = 3;
- hasState() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
optional .Hedwig.SubscriptionState state = 1;
- hasState() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
-
optional .Hedwig.SubscriptionState state = 1;
- hasState() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionDataOrBuilder
-
optional .Hedwig.SubscriptionState state = 1;
- hasStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
required .Hedwig.StatusCode statusCode = 2;
- hasStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
required .Hedwig.StatusCode statusCode = 2;
- hasStatusCode() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
required .Hedwig.StatusCode statusCode = 2;
- hasStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional string statusMsg = 4;
- hasStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
optional string statusMsg = 4;
- hasStatusMsg() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
optional string statusMsg = 4;
- hasStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
- hasStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
- hasStopDeliveryRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
- hasSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
- hasSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
- hasSubscribeRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
- hasSubscribeResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.SubscribeResponse subscribeResponse = 2;
- hasSubscribeResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
optional .Hedwig.SubscribeResponse subscribeResponse = 2;
- hasSubscribeResponse() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
-
optional .Hedwig.SubscribeResponse subscribeResponse = 2;
- hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequestOrBuilder
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequestOrBuilder
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional bytes subscriberId = 7;
- hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
optional bytes subscriberId = 7;
- hasSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
optional bytes subscriberId = 7;
- hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequestOrBuilder
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequestOrBuilder
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
-
required bytes subscriberId = 2;
- hasSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequestOrBuilder
-
required bytes subscriberId = 2;
- hasSubscription(ByteString, ByteString) - Method in interface org.apache.hedwig.client.api.Subscriber
-
Checks if the subscriberId client is currently subscribed to the given
topic.
- hasSubscription(TopicSubscriber) - Method in class org.apache.hedwig.client.handlers.SubscribeResponseHandler
-
Whether the given topic subscriber subscribed thru this handler.
- hasSubscription(ByteString, ByteString) - Method in class org.apache.hedwig.client.netty.HedwigSubscriber
-
- hasSubscription(TopicSubscriber) - Method in class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler
-
- hasSubscription(TopicSubscriber) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleSubscribeResponseHandler
-
- hasSubscriptionEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.SubscriptionEventResponse subscriptionEvent = 3;
- hasSubscriptionEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
optional .Hedwig.SubscriptionEventResponse subscriptionEvent = 3;
- hasSubscriptionEvent() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
-
optional .Hedwig.SubscriptionEventResponse subscriptionEvent = 3;
- hasSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional bool synchronous = 4 [default = false];
- hasSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
optional bool synchronous = 4 [default = false];
- hasSynchronous() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
optional bool synchronous = 4 [default = false];
- hasTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required bytes topic = 6;
- hasTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
required bytes topic = 6;
- hasTopic() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
required bytes topic = 6;
- hasTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional bytes topic = 6;
- hasTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
optional bytes topic = 6;
- hasTopic() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
optional bytes topic = 6;
- hasTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required uint64 txnId = 4;
- hasTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
required uint64 txnId = 4;
- hasTxnId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
required uint64 txnId = 4;
- hasTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
required uint64 txnId = 3;
- hasTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
required uint64 txnId = 3;
- hasTxnId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
required uint64 txnId = 3;
- hasType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required .Hedwig.OperationType type = 2;
- hasType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
required .Hedwig.OperationType type = 2;
- hasType() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
required .Hedwig.OperationType type = 2;
- hasUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
- hasUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
- hasUnsubscribeRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
- hasValue() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
optional bytes value = 2;
- hasValue() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
-
optional bytes value = 2;
- hasValue() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder
-
optional bytes value = 2;
- HChannel - Interface in org.apache.hedwig.client.netty
-
A wrapper interface over netty
Channel
to submit hedwig's
PubSubData
requests.
- hChannel - Variable in class org.apache.hedwig.client.netty.impl.ActiveSubscriber
-
- HChannelHandler - Class in org.apache.hedwig.client.netty.impl
-
- HChannelHandler(ClientConfiguration, AbstractHChannelManager, Map<PubSubProtocol.OperationType, AbstractResponseHandler>) - Constructor for class org.apache.hedwig.client.netty.impl.HChannelHandler
-
- HChannelImpl - Class in org.apache.hedwig.client.netty.impl
-
Provide a wrapper over netty channel for Hedwig operations.
- HChannelImpl(InetSocketAddress, AbstractHChannelManager) - Constructor for class org.apache.hedwig.client.netty.impl.HChannelImpl
-
Create a un-established channel with provided target host
.
- HChannelImpl(InetSocketAddress, AbstractHChannelManager, ClientChannelPipelineFactory) - Constructor for class org.apache.hedwig.client.netty.impl.HChannelImpl
-
- HChannelImpl(InetSocketAddress, Channel, AbstractHChannelManager, ClientChannelPipelineFactory) - Constructor for class org.apache.hedwig.client.netty.impl.HChannelImpl
-
Create a HChannel
with an established netty channel.
- HChannelManager - Interface in org.apache.hedwig.client.netty
-
A manager manages 1) all channels established to hub servers,
2) the actions taken by the topic subscribers.
- HEADER_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
- HedwigBenchmark - Class in org.apache.hedwig.client.benchmark
-
- HedwigBenchmark(ClientConfiguration, CommandLine) - Constructor for class org.apache.hedwig.client.benchmark.HedwigBenchmark
-
- 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.
- HedwigClientImpl - Class in org.apache.hedwig.client.netty
-
This is a top level Hedwig Client class that encapsulates the common
functionality needed for both Publish and Subscribe operations.
- HedwigClientImpl(ClientConfiguration) - Constructor for class org.apache.hedwig.client.netty.HedwigClientImpl
-
- HedwigClientImpl(ClientConfiguration, ChannelFactory) - Constructor for class org.apache.hedwig.client.netty.HedwigClientImpl
-
- HedwigPublisher - Class in org.apache.hedwig.client.netty
-
This is the Hedwig Netty specific implementation of the Publisher interface.
- HedwigPublisher(HedwigClientImpl) - Constructor for class org.apache.hedwig.client.netty.HedwigPublisher
-
- 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
-
- HedwigSubscriber - Class in org.apache.hedwig.client.netty
-
This is the Hedwig Netty specific implementation of the Subscriber interface.
- HedwigSubscriber(HedwigClientImpl) - Constructor for class org.apache.hedwig.client.netty.HedwigSubscriber
-
- host2NonSubscriptionChannels - Variable in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- host2Topics - Variable in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- HOSTNAME_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
-
- schedule(TimerTask, long) - Method in interface org.apache.hedwig.client.netty.HChannelManager
-
Schedule a timer task after a given delay
.
- schedule(TimerTask, long) - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- second() - Method in class org.apache.hedwig.util.Pair
-
- 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
- ServerNotResponsibleForTopicException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ServerNotResponsibleForTopicException
-
- ServerRedirectLoopException - Exception in org.apache.hedwig.client.exceptions
-
This is a Hedwig client side exception when the PubSubRequest is being
redirected to a server where the request has already been sent to previously.
- ServerRedirectLoopException(String) - Constructor for exception org.apache.hedwig.client.exceptions.ServerRedirectLoopException
-
- ServerRedirectLoopException(String, Throwable) - Constructor for exception org.apache.hedwig.client.exceptions.ServerRedirectLoopException
-
- SERVICE_DOWN_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
-
SERVICE_DOWN = 502;
- ServiceDownException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ServiceDownException
-
- ServiceDownException(Exception) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ServiceDownException
-
- ServiceDownException(String, Throwable) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ServiceDownException
-
- setAuditorPeriodicCheckInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the regularity at which the auditor will run a check
of all ledgers.
- setAutoRecoveryDaemonEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Sets that whether the auto-recovery service can start along with Bookie
server itself or not
- setBody(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
required bytes body = 1;
- 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.
- setCallback(Callback<PubSubProtocol.ResponseBody>) - Method in class org.apache.hedwig.client.data.PubSubData
-
- setClientTcpNoDelay(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set socket nodelay setting.
- setCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
- setCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58;
- setCode(int) - Method in exception org.apache.bookkeeper.client.BKException
-
- setConsumeRequest(PubSubProtocol.ConsumeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.ConsumeRequest consumeRequest = 54;
- setConsumeRequest(PubSubProtocol.ConsumeRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.ConsumeRequest consumeRequest = 54;
- setCreateOrAttach(PubSubProtocol.SubscribeRequest.CreateOrAttach) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 3 [default = CREATE_OR_ATTACH];
- setCreateOrAttach(PubSubProtocol.SubscribeRequest.CreateOrAttach) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH];
- setCzxid(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
required uint64 czxid = 3;
- setDiskCheckInterval(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the disk checker interval to monitor ledger disk space
- setDiskUsageThreshold(float) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the Disk free space threshold as a fraction of the total
after which disk will be considered as full during disk check.
- setEnableResubscribe(boolean) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional bool enableResubscribe = 7 [default = true];
- setEndSeqIdIncluded(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2;
- setEndSeqIdIncluded(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2;
- setEntries(int, PubSubProtocol.Map.Entry) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
repeated .Hedwig.Map.Entry entries = 1;
- setEntries(int, PubSubProtocol.Map.Entry.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
repeated .Hedwig.Map.Entry entries = 1;
- setEntryLogSizeLimit(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set entry logger size limitation
- setEvent(PubSubProtocol.SubscriptionEvent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
-
optional .Hedwig.SubscriptionEvent event = 1;
- setFlushInterval(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set flush interval
- setForceAttach(boolean) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional bool forceAttach = 7 [default = false];
- setForceAttach(boolean) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional bool forceAttach = 1 [default = false];
- setGcWaitTime(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set garbage collection wait time
- setHeader(PubSubProtocol.MessageHeader) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional .Hedwig.MessageHeader header = 4;
- setHeader(PubSubProtocol.MessageHeader.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional .Hedwig.MessageHeader header = 4;
- setHostname(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
required string hostname = 2;
- setHostnameBytes(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
required string hostname = 2;
- setJournalDirName(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set dir name to store journal files
- setKey(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
optional string key = 1;
- setKeyBytes(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
optional string key = 1;
- 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
-
required uint64 ledgerId = 1;
- setLedgerManagerFactoryClass(Class<? extends LedgerManagerFactory>) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Set Ledger Manager Factory Class.
- setLedgerManagerFactoryClassName(String) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Set Ledger Manager Factory Class Name.
- setLedgerManagerType(String) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
- setLocalComponent(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
optional uint64 localComponent = 1;
- setMajorCompactionInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set interval to run major compaction.
- setMajorCompactionThreshold(double) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set threshold of major compaction.
- setManagerImpl(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
-
required string managerImpl = 2;
- setManagerImplBytes(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
-
required string managerImpl = 2;
- setManagerVersion(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
-
required uint32 managerVersion = 3;
- 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
-
optional .Hedwig.Message message = 5;
- setMessage(PubSubProtocol.Message.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional .Hedwig.Message message = 5;
- setMessageBound(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional uint32 messageBound = 5;
- setMessageBound(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional uint32 messageBound = 3 [default = 0];
- setMessageBound(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional uint32 messageBound = 2;
- setMessageBound(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
optional uint32 messageBound = 2;
- setMessageFilter(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional string messageFilter = 5;
- setMessageFilter(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional string messageFilter = 3;
- setMessageFilterBytes(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional string messageFilter = 5;
- setMessageFilterBytes(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional string messageFilter = 3;
- setMessageType(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
optional string messageType = 2;
- setMessageTypeBytes(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
optional string messageType = 2;
- setMessageWindowSize(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional uint32 messageWindowSize = 6;
- setMessageWindowSize(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional uint32 messageWindowSize = 4;
- setMetastoreImplClass(String) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Set metastore implementation class.
- setMetastoreMaxEntriesPerScan(int) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Set max entries per scan in metastore.
- setMinorCompactionInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set interval to run minor compaction
- setMinorCompactionThreshold(double) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set threshold of minor compaction
- setMsg(PubSubProtocol.Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
-
required .Hedwig.Message msg = 2;
- setMsg(PubSubProtocol.Message.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
-
required .Hedwig.Message msg = 2;
- setMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
required .Hedwig.MessageSeqId msgId = 3;
- setMsgId(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
required .Hedwig.MessageSeqId msgId = 3;
- setMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional .Hedwig.MessageSeqId msgId = 3;
- setMsgId(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional .Hedwig.MessageSeqId msgId = 3;
- setMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
required .Hedwig.MessageSeqId msgId = 1;
- setMsgId(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
required .Hedwig.MessageSeqId msgId = 1;
- setNumTopics(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
-
required uint64 numTopics = 2;
- setNumWorkerThreads(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set the number of worker threads.
- setOpenFileLimit(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set limitation of number of open files.
- setOpenLedgerRereplicationGracePeriod(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the grace period which the rereplication worker will wait before
fencing and rereplicating a ledger fragment which is still being written
to, on bookie failure.
- setOptions(PubSubProtocol.Map) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional .Hedwig.Map options = 4;
- setOptions(PubSubProtocol.Map.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
optional .Hedwig.Map options = 4;
- setOptions(PubSubProtocol.Map) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional .Hedwig.Map options = 1;
- setOptions(PubSubProtocol.Map.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
optional .Hedwig.Map options = 1;
- setOriginalChannelForResubscribe(HChannel) - Method in class org.apache.hedwig.client.data.PubSubData
-
- setPageLimit(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set limitation number of index pages in ledger cache.
- setPageSize(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set page size
- setPreferences(PubSubProtocol.SubscriptionPreferences) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 6;
- setPreferences(PubSubProtocol.SubscriptionPreferences.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 6;
- setPreferences(PubSubProtocol.SubscriptionPreferences) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- setPreferences(PubSubProtocol.SubscriptionPreferences.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- setPreferences(PubSubProtocol.SubscriptionPreferences) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- setPreferences(PubSubProtocol.SubscriptionPreferences.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
optional .Hedwig.SubscriptionPreferences preferences = 2;
- setProperties(PubSubProtocol.Map) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
optional .Hedwig.Map properties = 1;
- setProperties(PubSubProtocol.Map.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
optional .Hedwig.Map properties = 1;
- setProtocolVersion(PubSubProtocol.ProtocolVersion) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- setProtocolVersion(PubSubProtocol.ProtocolVersion) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
required .Hedwig.ProtocolVersion protocolVersion = 1;
- setPublishedMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
-
required .Hedwig.MessageSeqId publishedMsgId = 1;
- setPublishedMsgId(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
-
required .Hedwig.MessageSeqId publishedMsgId = 1;
- setPublishRequest(PubSubProtocol.PublishRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.PublishRequest publishRequest = 52;
- setPublishRequest(PubSubProtocol.PublishRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.PublishRequest publishRequest = 52;
- setPublishResponse(PubSubProtocol.PublishResponse) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.PublishResponse publishResponse = 1;
- setPublishResponse(PubSubProtocol.PublishResponse.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.PublishResponse publishResponse = 1;
- setRanges(int, PubSubProtocol.LedgerRange) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
-
repeated .Hedwig.LedgerRange ranges = 1;
- setRanges(int, PubSubProtocol.LedgerRange.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
-
repeated .Hedwig.LedgerRange ranges = 1;
- setReadOnlyModeEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set whether the bookie is able to go into read-only mode.
- setReadTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set the socket read timeout.
- setRegion(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
-
required bytes region = 1;
- setRemoteComponents(int, PubSubProtocol.RegionSpecificSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- setRemoteComponents(int, PubSubProtocol.RegionSpecificSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2;
- setRereplicationEntryBatchSize(long) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Set the max entries to keep in fragment for re-replication.
- setResponseBody(PubSubProtocol.ResponseBody) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional .Hedwig.ResponseBody responseBody = 8;
- setResponseBody(PubSubProtocol.ResponseBody.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional .Hedwig.ResponseBody responseBody = 8;
- setSeqId(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
-
required uint64 seqId = 2;
- 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
-
optional bool shouldClaim = 5;
- setSpeculativeReadTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set the speculative read timeout.
- setSrcRegion(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
optional bytes srcRegion = 2;
- setStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
- setStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57;
- setStartSeqIdIncluded(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
optional uint64 startSeqIdIncluded = 3;
- setState(PubSubProtocol.SubscriptionState) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
optional .Hedwig.SubscriptionState state = 1;
- setState(PubSubProtocol.SubscriptionState.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
optional .Hedwig.SubscriptionState state = 1;
- setStatisticsEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Turn on/off statistics
- setStatusCode(PubSubProtocol.StatusCode) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
required .Hedwig.StatusCode statusCode = 2;
- setStatusMsg(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional string statusMsg = 4;
- setStatusMsgBytes(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional string statusMsg = 4;
- setStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
- setStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56;
- setSubscriber(HedwigSubscriber) - Method in class org.apache.hedwig.client.netty.HedwigClientImpl
-
- setSubscribeRequest(PubSubProtocol.SubscribeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
- setSubscribeRequest(PubSubProtocol.SubscribeRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.SubscribeRequest subscribeRequest = 53;
- setSubscribeResponse(PubSubProtocol.SubscribeResponse) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.SubscribeResponse subscribeResponse = 2;
- setSubscribeResponse(PubSubProtocol.SubscribeResponse.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.SubscribeResponse subscribeResponse = 2;
- setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
-
required bytes subscriberId = 2;
- setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
required bytes subscriberId = 2;
- setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional bytes subscriberId = 7;
- setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
-
required bytes subscriberId = 2;
- setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
-
required bytes subscriberId = 2;
- setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
required bytes subscriberId = 2;
- setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
-
required bytes subscriberId = 2;
- setSubscriptionEvent(PubSubProtocol.SubscriptionEventResponse) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.SubscriptionEventResponse subscriptionEvent = 3;
- setSubscriptionEvent(PubSubProtocol.SubscriptionEventResponse.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
optional .Hedwig.SubscriptionEventResponse subscriptionEvent = 3;
- setSynchronous(boolean) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
optional bool synchronous = 4 [default = false];
- 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
-
required bytes topic = 6;
- setTopic(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
optional bytes topic = 6;
- setTriedServers(int, ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
repeated bytes triedServers = 3;
- setTxnId(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required uint64 txnId = 4;
- setTxnId(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
required uint64 txnId = 3;
- setType(PubSubProtocol.OperationType) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
required .Hedwig.OperationType type = 2;
- setUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
- setUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55;
- setValue(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
optional bytes value = 2;
- setVersion(Version) - Method in class org.apache.bookkeeper.client.LedgerMetadata
-
Updates the version of this metadata.
- 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 - Variable in class org.apache.hedwig.client.data.PubSubData
-
- SHOULDCLAIM_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
- SimpleHChannelManager - Class in org.apache.hedwig.client.netty.impl.simple
-
Simple HChannel Manager which establish a connection for each subscription.
- SimpleHChannelManager(ClientConfiguration, ChannelFactory) - Constructor for class org.apache.hedwig.client.netty.impl.simple.SimpleHChannelManager
-
- SimpleSubscribeResponseHandler - Class in org.apache.hedwig.client.netty.impl.simple
-
- SimpleSubscribeResponseHandler(ClientConfiguration, HChannelManager) - Constructor for class org.apache.hedwig.client.netty.impl.simple.SimpleSubscribeResponseHandler
-
- SimpleSubscriptionChannelPipelineFactory - Class in org.apache.hedwig.client.netty.impl.simple
-
- SimpleSubscriptionChannelPipelineFactory(ClientConfiguration, SimpleHChannelManager) - Constructor for class org.apache.hedwig.client.netty.impl.simple.SimpleSubscriptionChannelPipelineFactory
-
- sockAddrStr(InetSocketAddress) - Static method in class org.apache.hedwig.util.HedwigSocketAddress
-
- socketFactory - Variable in class org.apache.hedwig.client.netty.HedwigClientImpl
-
- socketFactory - Variable in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- SPECULATIVE_READ_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
-
- 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
-
- SslClientContextFactory - Class in org.apache.hedwig.client.ssl
-
- SslClientContextFactory(ClientConfiguration) - Constructor for class org.apache.hedwig.client.ssl.SslClientContextFactory
-
- SslContextFactory - Class in org.apache.hedwig.client.ssl
-
- SslContextFactory() - Constructor for class org.apache.hedwig.client.ssl.SslContextFactory
-
- START_DELIVERY_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType
-
START_DELIVERY = 4;
- 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.
- startDelivery(TopicSubscriber, MessageHandler) - Method in class org.apache.hedwig.client.handlers.SubscribeResponseHandler
-
Start delivering messages for a given topic subscriber.
- startDelivery(TopicSubscriber, MessageHandler) - Method in interface org.apache.hedwig.client.netty.HChannelManager
-
Start delivering messages for a given topic subscriber.
- startDelivery(ByteString, ByteString, MessageHandler) - Method in class org.apache.hedwig.client.netty.HedwigSubscriber
-
- startDelivery(TopicSubscriber, MessageHandler) - Method in class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler
-
- startDelivery(MessageHandler) - Method in class org.apache.hedwig.client.netty.impl.ActiveSubscriber
-
Start delivering messages using given message handler.
- startDelivery(TopicSubscriber, MessageHandler) - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager
-
- startDelivery(TopicSubscriber, MessageHandler) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleHChannelManager
-
- STARTDELIVERYREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
- startDeliveryWithFilter(ByteString, ByteString, MessageHandler, ClientMessageFilter) - Method in interface org.apache.hedwig.client.api.Subscriber
-
Begin delivery of messages from the server to us for this topic and
subscriberId.
- startDeliveryWithFilter(ByteString, ByteString, MessageHandler, ClientMessageFilter) - Method in class org.apache.hedwig.client.netty.HedwigSubscriber
-
- startProgress() - Method in class org.apache.hedwig.client.benchmark.BenchmarkUtils.ThroughputAggregator
-
- startProgress() - Method in class org.apache.hedwig.client.benchmark.BenchmarkUtils.ThroughputLatencyAggregator
-
- STARTSEQIDINCLUDED_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
-
- STATE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
-
- 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
-
- STOP_DELIVERY_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType
-
STOP_DELIVERY = 5;
- stopDelivery(ByteString, ByteString) - Method in interface org.apache.hedwig.client.api.Subscriber
-
Stop delivery of messages for this topic and subscriberId.
- stopDelivery(TopicSubscriber) - Method in class org.apache.hedwig.client.handlers.SubscribeResponseHandler
-
Stop delivering messages for a given topic subscriber.
- stopDelivery(TopicSubscriber) - Method in interface org.apache.hedwig.client.netty.HChannelManager
-
Stop delivering messages for a given topic subscriber.
- stopDelivery(ByteString, ByteString) - Method in class org.apache.hedwig.client.netty.HedwigSubscriber
-
- stopDelivery(TopicSubscriber) - Method in class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler
-
- stopDelivery() - Method in class org.apache.hedwig.client.netty.impl.ActiveSubscriber
-
Stop delivering messages to the subscriber.
- stopDelivery(TopicSubscriber) - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager
-
- stopDelivery(TopicSubscriber) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleHChannelManager
-
- STOPDELIVERYREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
- storeSubscriptionChannel(TopicSubscriber, PubSubData, HChannel) - Method in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager
-
- storeSubscriptionChannel(TopicSubscriber, PubSubData, Channel) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleHChannelManager
-
- storeTopic2HostMapping(ByteString, InetSocketAddress) - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
Helper method to store the topic2Host mapping in the channel manager cache
map.
- sub2Channels - Variable in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager
-
- submitOp(PubSubData) - Method in interface org.apache.hedwig.client.netty.HChannel
-
Submit a pub/sub request.
- submitOp(PubSubData) - Method in interface org.apache.hedwig.client.netty.HChannelManager
-
Submit a pub/sub request.
- submitOp(PubSubData) - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- submitOp(PubSubData) - Method in class org.apache.hedwig.client.netty.impl.HChannelImpl
-
- submitOp(PubSubData) - Method in class org.apache.hedwig.client.netty.impl.simple.SimpleHChannelManager
-
- submitOpAfterDelay(PubSubData, long) - Method in interface org.apache.hedwig.client.netty.HChannelManager
-
Submit a pub/sub request after a given delay
.
- submitOpAfterDelay(PubSubData, long) - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- submitOpToDefaultServer(PubSubData) - Method in interface org.apache.hedwig.client.netty.HChannelManager
-
Submit a pub/sub request to default server.
- submitOpToDefaultServer(PubSubData) - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- subscribe(ByteString, ByteString, PubSubProtocol.SubscribeRequest.CreateOrAttach) - Method in interface org.apache.hedwig.client.api.Subscriber
-
- subscribe(ByteString, ByteString, PubSubProtocol.SubscriptionOptions) - Method in interface org.apache.hedwig.client.api.Subscriber
-
Subscribe to the given topic for the inputted subscriberId.
- subscribe(ByteString, ByteString, PubSubProtocol.SubscribeRequest.CreateOrAttach) - Method in class org.apache.hedwig.client.netty.HedwigSubscriber
-
- subscribe(ByteString, ByteString, PubSubProtocol.SubscriptionOptions) - Method in class org.apache.hedwig.client.netty.HedwigSubscriber
-
- subscribe(ByteString, ByteString, PubSubProtocol.SubscriptionOptions, boolean) - Method in class org.apache.hedwig.client.netty.HedwigSubscriber
-
- SUBSCRIBE_RECONNECT_RETRY_WAIT_TIME - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration
-
- SUBSCRIBE_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType
-
SUBSCRIBE = 1;
- 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
-
- SUBSCRIBERESPONSE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
- SubscribeResponseHandler - Class in org.apache.hedwig.client.handlers
-
An interface provided to manage all subscriptions on a channel.
- SubscribeResponseHandler(ClientConfiguration, HChannelManager) - Constructor for class org.apache.hedwig.client.handlers.SubscribeResponseHandler
-
- subscriberId - Variable in class org.apache.hedwig.client.data.PubSubData
-
- SUBSCRIBERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
-
- 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
-
- SUBSCRIPTION_CHANNEL_SHARING_ENABLED - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration
-
- SUBSCRIPTION_FORCED_CLOSED_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent
-
SUBSCRIPTION_FORCED_CLOSED = 2;
- SUBSCRIPTION_MESSAGE_BOUND - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration
-
- SUBSCRIPTION_STATE_EXISTS_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
-
SUBSCRIPTION_STATE_EXISTS = 524;
- subscriptionChannels - Variable in class org.apache.hedwig.client.netty.impl.multiplex.MultiplexHChannelManager
-
- SUBSCRIPTIONEVENT_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
- SubscriptionEventEmitter - Class in org.apache.hedwig.client.netty
-
- SubscriptionEventEmitter() - Constructor for class org.apache.hedwig.client.netty.SubscriptionEventEmitter
-
- SubscriptionListener - Interface in org.apache.hedwig.util
-
This class is used for subscriber to listen on subscription event.
- subscriptions - Variable in class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler
-
- SubscriptionStateExistsException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.SubscriptionStateExistsException
-
- SUCCESS_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
-
SUCCESS = 0;
- summarize(long) - Method in class org.apache.hedwig.client.benchmark.BenchmarkUtils.ThroughputAggregator
-
- summarize(long) - Method in class org.apache.hedwig.client.benchmark.BenchmarkUtils.ThroughputLatencyAggregator
-
- SYNCHRONOUS_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-