- 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
-
- getAddEntryTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get the timeout for add request.
- getAddr() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- getAddress() - Method in class org.apache.bookkeeper.client.LedgerFragment
-
Gets the failedBookie address
- getAllowLoopback() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Is the bookie allowed to use a loopback interface as its primary
interface(i.e.
- getAuditorPeriodicBookieCheckInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the interval between auditor bookie check runs.
- getAuditorPeriodicCheckInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the regularity at which the auditor checks all ledgers.
- getAvailableBookies() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
-
Get a list of the available bookies.
- 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.
- getClientConnectTimeoutMillis() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get client netty connect timeout in millis.
- getClientReceiveBufferSize() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get client netty channel receive buffer size.
- getClientSendBufferSize() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get client netty channel send buffer size.
- getClientTcpNoDelay() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Is tcp connection no delay.
- getClientWriteBufferHighWaterMark() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get client netty channel write buffer high water mark.
- getClientWriteBufferLowWaterMark() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get client netty channel write buffer low water mark.
- 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
-
- getCompactionMaxOutstandingRequests() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the maximum number of entries which can be compacted without flushing.
- getCompactionRate() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the rate of compaction adds.
- getConf() - Method in class org.apache.bookkeeper.client.BookKeeper
-
- getConf() - Method in interface org.apache.bookkeeper.conf.Configurable
-
Return the configuration used by this object.
- 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.
- getDiskUsageWarnThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Returns the warning threshold for disk usage.
- getEnableResubscribe() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
enable resubscribe
- getEnableResubscribe() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
enable resubscribe
- getEnableResubscribe() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
enable resubscribe
- 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
- getEnsemblePlacementPolicy() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get Ensemble Placement Policy Class.
- 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
-
force attach subscription which would kill existed channel
this option doesn't need to be persisted
- getForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
force attach subscription which would kill existed channel
this option doesn't need to be persisted
- getForceAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
force attach subscription which would kill existed channel
this option doesn't need to be persisted
- getForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
force attach subscription which would kill existed channel
this option doesn't need to be persisted
- getForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
force attach subscription which would kill existed channel
this option doesn't need to be persisted
- getForceAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
force attach subscription which would kill existed channel
this option doesn't need to be persisted
- 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
-
message header
- getHeader() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
message header
- getHeader() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
-
message header
- getHeaderBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
message header
- getHeaderOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
message header
- getHeaderOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
message header
- getHeaderOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
-
message header
- 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
- getIndexDirNames() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get dir name to store index files.
- getIndexDirs() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get index dir to store ledger index files.
- getIsCallSuccessful() - Method in class org.apache.hedwig.client.handlers.PubSubCallback
-
- getJournalAdaptiveGroupWrites() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Should we group journal force writes
- getJournalAlignmentSize() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
All the journal writes and commits should be aligned to given size.
- getJournalBufferedEntriesThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Maximum entries to buffer to impose on a journal write to achieve grouping.
- getJournalBufferedWritesThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Maximum bytes to buffer to impose on a journal write to achieve grouping
- 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
- getJournalFlushWhenQueueEmpty() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Should we flush the journal when queue is empty
- getJournalFormatVersionToWrite() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get journal format version to write.
- getJournalMaxGroupWaitMSec() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Maximum latency to impose on a journal write to achieve grouping
- getJournalPreAllocSizeMB() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
How much space should we pre-allocate at a time in the journal
- getJournalRemovePagesFromCache() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Should we remove pages from page cache after force write
- getJournalWriteBufferSizeKB() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Size of the write buffers used for the journal
- 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
-
- getLedgerMetadata(LedgerHandle) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
-
- 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
-
- getLevel() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- getListeningInterface() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the network interface that the bookie should
listen for connections on.
- 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
-
- getMaxJournalSizeMB() - 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
-
the following fields are sent in delivered messages
- getMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
the following fields are sent in delivered messages
- getMessage() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
the following fields are sent in delivered messages
- getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
@Deprecated.
- getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
@Deprecated.
- getMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
@Deprecated.
- 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
-
message bound
- getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
message bound
- getMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
message bound
- getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
@Deprecated.
- getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
-
@Deprecated.
- getMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionStateOrBuilder
-
@Deprecated.
- getMessageBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
the following fields are sent in delivered messages
- 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
-
server-side message filter
- getMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
server-side message filter
- getMessageFilter() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
server-side message filter
- getMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
server-side message filter
- getMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
server-side message filter
- getMessageFilter() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
server-side message filter
- getMessageFilterBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
server-side message filter
- getMessageFilterBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
server-side message filter
- getMessageFilterBytes() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
server-side message filter
- getMessageFilterBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
server-side message filter
- getMessageFilterBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
server-side message filter
- getMessageFilterBytes() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
server-side message filter
- getMessageHandler() - Method in class org.apache.hedwig.client.netty.FilterableMessageHandler
-
- getMessageOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
the following fields are sent in delivered messages
- getMessageOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
the following fields are sent in delivered messages
- getMessageOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
the following fields are sent in delivered messages
- getMessageType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
following are system properties in message header
- getMessageType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
following are system properties in message header
- getMessageType() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
-
following are system properties in message header
- getMessageTypeBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
following are system properties in message header
- getMessageTypeBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
following are system properties in message header
- getMessageTypeBytes() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
-
following are system properties in message header
- getMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
message window size, this is the maximum number of messages
which will be delivered without being consumed
- getMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
message window size, this is the maximum number of messages
which will be delivered without being consumed
- getMessageWindowSize() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
message window size, this is the maximum number of messages
which will be delivered without being consumed
- getMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
message window size, this is the maximum number of messages
which will be delivered without being consumed
- getMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
message window size, this is the maximum number of messages
which will be delivered without being consumed
- getMessageWindowSize() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
message window size, this is the maximum number of messages
which will be delivered without being consumed
- 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
-
the msgId is cumulative: all messages up to this id are marked as consumed
- getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
-
the msgId is cumulative: all messages up to this id are marked as consumed
- getMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequestOrBuilder
-
the msgId is cumulative: all messages up to this id are marked as consumed
- 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
-
the msgId is cumulative: all messages up to this id are marked as consumed
- 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
-
the msgId is cumulative: all messages up to this id are marked as consumed
- getMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
-
the msgId is cumulative: all messages up to this id are marked as consumed
- getMsgIdOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequestOrBuilder
-
the msgId is cumulative: all messages up to this id are marked as consumed
- 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;
- getName() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- getNetworkLocation() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- getNonSubscriptionChannelPipelineFactory() - Method in class org.apache.hedwig.client.netty.impl.AbstractHChannelManager
-
- getNumAddWorkerThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the number of threads that should handle write requests.
- 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
-
- getNumChannelsPerBookie() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get num channels per bookie.
- getNumJournalCallbackThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the number of threads that should handle journal callbacks.
- getNumReadWorkerThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the number of threads that should handle read requests.
- 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
-
user customized subscription options
- getOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
user customized subscription options
- getOptions() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
user customized subscription options
- getOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
user customized subscription options
- getOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
user customized subscription options
- getOptions() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
user customized subscription options
- getOptionsBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
user customized subscription options
- getOptionsBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
user customized subscription options
- getOptionsOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
user customized subscription options
- getOptionsOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
user customized subscription options
- getOptionsOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
user customized subscription options
- getOptionsOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
user customized subscription options
- getOptionsOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
user customized subscription options
- getOptionsOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
user customized subscription options
- 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
- getParent() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- 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
-
- getPCBCTimeoutTimerNumTicks() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get number of ticks that used for
HashedWheelTimer
that used by PCBC to timeout
requests.
- getPCBCTimeoutTimerTickDurationMs() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get the tick duration in milliseconds that used for the
HashedWheelTimer
that used by PCBC to timeout
requests.
- 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
-
subscription options
- getPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
subscription options
- getPreferences() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
subscription options
- 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
-
subscription options
- 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
-
subscription options
- getPreferencesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
subscription options
- getPreferencesOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
subscription options
- 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
-
user customized fields used for message filter
- getProperties() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
user customized fields used for message filter
- getProperties() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
-
user customized fields used for message filter
- getPropertiesBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
user customized fields used for message filter
- getPropertiesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
user customized fields used for message filter
- getPropertiesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
user customized fields used for message filter
- getPropertiesOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
-
user customized fields used for message filter
- 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
-
If the request was a publish request, this was the message Id of the published message.
- getPublishedMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
-
If the request was a publish request, this was the message Id of the published message.
- getPublishedMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishResponseOrBuilder
-
If the request was a publish request, this was the message Id of the published message.
- getPublishedMsgIdBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
-
If the request was a publish request, this was the message Id of the published message.
- getPublishedMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
-
If the request was a publish request, this was the message Id of the published message.
- getPublishedMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
-
If the request was a publish request, this was the message Id of the published message.
- getPublishedMsgIdOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishResponseOrBuilder
-
If the request was a publish request, this was the message Id of the published message.
- 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
-
one entry for each type of request
- getPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
one entry for each type of request
- getPublishRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
one entry for each type of request
- getPublishRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
one entry for each type of request
- getPublishRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
one entry for each type of request
- getPublishRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
one entry for each type of request
- getPublishRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
one entry for each type of request
- 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;
- getReadBufferBytes() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the number of bytes we should use as capacity for
org.apache.bookkeeper.bookie.BufferedReadChannel
Default is 512 bytes
- getReadEntryTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get the timeout for read entry.
- getReadOnlyBookies() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
-
Get a list of readonly bookies
- getReadTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
- 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;
- getRemoteRack(RackawareEnsemblePlacementPolicy.BookieNode) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
-
- 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
-
the following fields are sent by other requests
- getResponseBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
the following fields are sent by other requests
- getResponseBody() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
the following fields are sent by other requests
- getResponseBodyBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
the following fields are sent by other requests
- getResponseBodyOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
the following fields are sent by other requests
- getResponseBodyOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
the following fields are sent by other requests
- getResponseBodyOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
the following fields are sent by other requests
- 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;
- getSkipListArenaChunkSize() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the number of bytes we should use as chunk allocation for
org.apache.bookkeeper.bookie.SkipListArena
Default is 4 MB
- getSkipListArenaMaxAllocSize() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the max size we should allocate from the skiplist arena.
- getSkipListSizeLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get skip list data size limitation (default 64MB)
- getSocketAddress() - Method in class org.apache.hedwig.util.HedwigSocketAddress
-
- getSortedLedgerStorageEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Check if sorted-ledger storage enabled (default true)
- 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;
- getStatsProviderClass() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the stats provider used by bookie.
- 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
-
in case of a status code of NOT_RESPONSIBLE_FOR_TOPIC, the status
message will contain the name of the host actually responsible
for the topic
- getStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
in case of a status code of NOT_RESPONSIBLE_FOR_TOPIC, the status
message will contain the name of the host actually responsible
for the topic
- getStatusMsg() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
in case of a status code of NOT_RESPONSIBLE_FOR_TOPIC, the status
message will contain the name of the host actually responsible
for the topic
- getStatusMsgBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
in case of a status code of NOT_RESPONSIBLE_FOR_TOPIC, the status
message will contain the name of the host actually responsible
for the topic
- getStatusMsgBytes() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
in case of a status code of NOT_RESPONSIBLE_FOR_TOPIC, the status
message will contain the name of the host actually responsible
for the topic
- getStatusMsgBytes() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
in case of a status code of NOT_RESPONSIBLE_FOR_TOPIC, the status
message will contain the name of the host actually responsible
for the topic
- 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
-
wait for cross-regional subscriptions to be established before returning
- getSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
wait for cross-regional subscriptions to be established before returning
- getSynchronous() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
wait for cross-regional subscriptions to be established before returning
- getThrottleValue() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get throttle value
- getTimeoutTaskIntervalMillis() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Deprecated.
- 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
-
any authentication stuff and other general stuff here
- getTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
any authentication stuff and other general stuff here
- getTopic() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
any authentication stuff and other general stuff here
- 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;
- getUseHostNameAsBookieID() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get whether bookie is using hostname for registration and in ledger
metadata.
- 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.
- getWriteBufferBytes() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the number of bytes used as capacity for the write buffer.
- 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
- getZooKeeper() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
-
Get ZooKeeper
used by bookkeeper admin client.
- 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
-
enable resubscribe
- hasEnableResubscribe() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
enable resubscribe
- hasEnableResubscribe() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
enable resubscribe
- 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
-
force attach subscription which would kill existed channel
this option doesn't need to be persisted
- hasForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
force attach subscription which would kill existed channel
this option doesn't need to be persisted
- hasForceAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
force attach subscription which would kill existed channel
this option doesn't need to be persisted
- hasForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
force attach subscription which would kill existed channel
this option doesn't need to be persisted
- hasForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
force attach subscription which would kill existed channel
this option doesn't need to be persisted
- hasForceAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
force attach subscription which would kill existed channel
this option doesn't need to be persisted
- hashCode() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- hashCode() - Method in class org.apache.hedwig.client.data.TopicSubscriber
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
-
- hashCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
-
- hashCode() - Method in class org.apache.hedwig.util.HedwigSocketAddress
-
- hasHeader() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
message header
- hasHeader() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
-
message header
- hasHeader() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
-
message header
- 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
-
the following fields are sent in delivered messages
- hasMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
the following fields are sent in delivered messages
- hasMessage() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
the following fields are sent in delivered messages
- hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
@Deprecated.
- hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
@Deprecated.
- hasMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
@Deprecated.
- 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
-
message bound
- hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
message bound
- hasMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
message bound
- hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
@Deprecated.
- hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
-
@Deprecated.
- hasMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionStateOrBuilder
-
@Deprecated.
- hasMessageFilter() - Method in class org.apache.hedwig.client.netty.FilterableMessageHandler
-
- hasMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
server-side message filter
- hasMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
server-side message filter
- hasMessageFilter() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
server-side message filter
- hasMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
server-side message filter
- hasMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
server-side message filter
- hasMessageFilter() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
server-side message filter
- hasMessageHandler() - Method in class org.apache.hedwig.client.netty.FilterableMessageHandler
-
- hasMessageType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
following are system properties in message header
- hasMessageType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
following are system properties in message header
- hasMessageType() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
-
following are system properties in message header
- hasMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
message window size, this is the maximum number of messages
which will be delivered without being consumed
- hasMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
message window size, this is the maximum number of messages
which will be delivered without being consumed
- hasMessageWindowSize() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
message window size, this is the maximum number of messages
which will be delivered without being consumed
- hasMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
message window size, this is the maximum number of messages
which will be delivered without being consumed
- hasMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
message window size, this is the maximum number of messages
which will be delivered without being consumed
- hasMessageWindowSize() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
message window size, this is the maximum number of messages
which will be delivered without being consumed
- 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
-
the msgId is cumulative: all messages up to this id are marked as consumed
- hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
-
the msgId is cumulative: all messages up to this id are marked as consumed
- hasMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequestOrBuilder
-
the msgId is cumulative: all messages up to this id are marked as consumed
- 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
-
user customized subscription options
- hasOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
-
user customized subscription options
- hasOptions() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
-
user customized subscription options
- hasOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
user customized subscription options
- hasOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
-
user customized subscription options
- hasOptions() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
-
user customized subscription options
- hasPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
subscription options
- hasPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
subscription options
- hasPreferences() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
subscription options
- 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
-
user customized fields used for message filter
- hasProperties() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
-
user customized fields used for message filter
- hasProperties() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
-
user customized fields used for message filter
- 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
-
If the request was a publish request, this was the message Id of the published message.
- hasPublishedMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
-
If the request was a publish request, this was the message Id of the published message.
- hasPublishedMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishResponseOrBuilder
-
If the request was a publish request, this was the message Id of the published message.
- hasPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
one entry for each type of request
- hasPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
one entry for each type of request
- hasPublishRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
one entry for each type of request
- 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
-
the following fields are sent by other requests
- hasResponseBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
the following fields are sent by other requests
- hasResponseBody() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
the following fields are sent by other requests
- 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
-
in case of a status code of NOT_RESPONSIBLE_FOR_TOPIC, the status
message will contain the name of the host actually responsible
for the topic
- hasStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
-
in case of a status code of NOT_RESPONSIBLE_FOR_TOPIC, the status
message will contain the name of the host actually responsible
for the topic
- hasStatusMsg() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
-
in case of a status code of NOT_RESPONSIBLE_FOR_TOPIC, the status
message will contain the name of the host actually responsible
for the topic
- 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
-
wait for cross-regional subscriptions to be established before returning
- hasSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
-
wait for cross-regional subscriptions to be established before returning
- hasSynchronous() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
-
wait for cross-regional subscriptions to be established before returning
- hasTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
any authentication stuff and other general stuff here
- hasTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
-
any authentication stuff and other general stuff here
- hasTopic() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
-
any authentication stuff and other general stuff here
- 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
-
- selectFromRack(String, Set<Node>, RackawareEnsemblePlacementPolicy.Predicate, RackawareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
-
- selectRandom(int, Set<Node>, RackawareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
-
Choose a random node from whole cluster.
- selectRandomFromRack(String, Set<Node>, RackawareEnsemblePlacementPolicy.Predicate, RackawareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
-
Choose random node under a given network path.
- 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
-
- setAddEntryTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set timeout for add entry request.
- setAllowLoopback(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Configure the bookie to allow loopback interfaces to be used
as the primary bookie interface.
- setAuditorPeriodicBookieCheckInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the interval between auditor bookie checks.
- 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
-
- setChannelFactory(ClientSocketChannelFactory) - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
-
- setClientConnectTimeoutMillis(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set client netty connect timeout in millis.
- setClientReceiveBufferSize(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set client netty channel receive buffer size.
- setClientSendBufferSize(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set client netty channel send buffer size.
- setClientTcpNoDelay(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set socket nodelay setting.
- setClientWriteBufferHighWaterMark(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set client netty channel write buffer high water mark.
- setClientWriteBufferLowWaterMark(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set client netty channel write buffer low water mark.
- 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
-
- setCompactionMaxOutstandingRequests(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the maximum number of entries which can be compacted without flushing.
- setCompactionRate(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the rate of compaction adds.
- setConf(Configuration) - Method in interface org.apache.bookkeeper.conf.Configurable
-
Set the configuration to be used by this object.
- 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.
- setDiskUsageWarnThreshold(float) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the warning threshold for disk usage.
- setEnableResubscribe(boolean) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
enable resubscribe
- 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;
- setEnsemblePlacementPolicy(Class<? extends EnsemblePlacementPolicy>) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set Ensemble Placement Policy Class.
- 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;
- setEntryLogFilePreAllocationEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Enable/disable entry log file preallocation.
- 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;
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
- setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
-
- 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
-
force attach subscription which would kill existed channel
this option doesn't need to be persisted
- setForceAttach(boolean) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
force attach subscription which would kill existed channel
this option doesn't need to be persisted
- 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
-
message header
- setHeader(PubSubProtocol.MessageHeader.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
message header
- 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;
- setIndexDirName(String[]) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set dir name to store index files.
- setJournalAdaptiveGroupWrites(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Enable/disable group journal force writes
- setJournalAlignmentSize(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set journal alignment size.
- setJournalBufferedEntriesThreshold(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set maximum entries to buffer to impose on a journal write to achieve grouping.
- setJournalDirName(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set dir name to store journal files
- setJournalFlushWhenQueueEmpty(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set if we should flush the journal when queue is empty
- setJournalFormatVersionToWrite(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set journal format version to write.
- setJournalRemovePagesFromCache(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Sets that whether should we remove pages from page cache after force write.
- 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
-
- setLevel(int) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- setListeningInterface(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the network interface that the bookie should listen on.
- 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
- setMaxJournalSizeMB(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
-
the following fields are sent in delivered messages
- setMessage(PubSubProtocol.Message.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
the following fields are sent in delivered messages
- setMessageBound(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
@Deprecated.
- 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
-
message bound
- setMessageBound(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
@Deprecated.
- setMessageFilter(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
server-side message filter
- setMessageFilter(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
server-side message filter
- setMessageFilterBytes(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
server-side message filter
- setMessageFilterBytes(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
server-side message filter
- setMessageType(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
following are system properties in message header
- setMessageTypeBytes(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
following are system properties in message header
- setMessageWindowSize(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
message window size, this is the maximum number of messages
which will be delivered without being consumed
- setMessageWindowSize(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
message window size, this is the maximum number of messages
which will be delivered without being consumed
- 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
-
the msgId is cumulative: all messages up to this id are marked as consumed
- setMsgId(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
the msgId is cumulative: all messages up to this id are marked as consumed
- 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;
- setNetworkLocation(String) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- setNumAddWorkerThreads(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the number of threads that would handle write requests.
- setNumChannelsPerBookie(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set num channels per bookie.
- setNumJournalCallbackThreads(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the number of threads that would handle journal callbacks.
- setNumReadWorkerThreads(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the number of threads that would handle read requests.
- 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
-
user customized subscription options
- setOptions(PubSubProtocol.Map.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
user customized subscription options
- setOptions(PubSubProtocol.Map) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
user customized subscription options
- setOptions(PubSubProtocol.Map.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
user customized subscription options
- 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
- setParent(Node) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- setPCBCTimeoutTimerNumTicks(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set number of ticks that used for
HashedWheelTimer
that used by PCBC to timeout request.
- setPCBCTimeoutTimerTickDurationMs(long) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set the tick duration in milliseconds that used for
HashedWheelTimer
that used by PCBC to timeout
requests.
- setPreferences(PubSubProtocol.SubscriptionPreferences) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
subscription options
- setPreferences(PubSubProtocol.SubscriptionPreferences.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
subscription options
- 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
-
user customized fields used for message filter
- setProperties(PubSubProtocol.Map.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
user customized fields used for message filter
- 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
-
If the request was a publish request, this was the message Id of the published message.
- setPublishedMsgId(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
-
If the request was a publish request, this was the message Id of the published message.
- setPublishRequest(PubSubProtocol.PublishRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
one entry for each type of request
- setPublishRequest(PubSubProtocol.PublishRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
one entry for each type of request
- 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;
- setReadBufferBytes(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the number of bytes we should use as capacity for
org.apache.bookkeeper.bookie.BufferedReadChannel
- setReadEntryTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set the timeout for read entry request.
- 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
-
- 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;
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
- setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
-
- 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
-
the following fields are sent by other requests
- setResponseBody(PubSubProtocol.ResponseBody.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
the following fields are sent by other requests
- 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;
- setSkipListArenaChunkSize(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the number of bytes w used as chunk allocation for
org.apache.bookkeeper.bookie.SkipListArena
- setSkipListSizeLimit(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set skip list size limit.
- setSortedLedgerStorageEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set sorted-ledger storage enabled or not
- 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
- setStatsLogger(StatsLogger) - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
-
- setStatsProviderClass(Class<? extends StatsProvider>) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the stats provider used by bookie.
- 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
-
in case of a status code of NOT_RESPONSIBLE_FOR_TOPIC, the status
message will contain the name of the host actually responsible
for the topic
- setStatusMsgBytes(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
in case of a status code of NOT_RESPONSIBLE_FOR_TOPIC, the status
message will contain the name of the host actually responsible
for the topic
- 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
-
wait for cross-regional subscriptions to be established before returning
- setThrottleValue(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set throttle value.
- setTimeoutTaskIntervalMillis(long) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Deprecated.
- setTopic(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
any authentication stuff and other general stuff here
- 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;
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
-
- setUnknownFields(UnknownFieldSet) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
-
- 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;
- setUseHostNameAsBookieID(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Configure the bookie to use its hostname to register with the
co-ordination service(eg: zookeeper) and in ledger metadata
- 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.
- setWriteBufferBytes(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the number of bytes used as capacity for the write buffer.
- 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
- setZookeeper(ZooKeeper) - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
-
- 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
-
- SKIP_LIST_CHUNK_SIZE_ENTRY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
-
- SKIP_LIST_MAX_ALLOC_ENTRY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
-
- SKIP_LIST_SIZE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
-
- 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
-
- SORTED_LEDGER_STORAGE_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
-
- 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
-
the following two are only used for the hedwig proxy
- 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
-
- STATS_PROVIDER_CLASS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
-
- 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
-
end for requests only used for hedwig proxy
- 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 is force closed by other subscribers
- 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
-