A  B  C  D  E  F  G  I  K  L  M  N  P  R  S  T  U  V 

G

getActiveTopicChannels(java.lang.String) - function in com.abusix.knsq.http.NSQLookupDHTTPClient

Returns the active channels for a topic.

getActiveTopicProducers(java.lang.String) - function in com.abusix.knsq.http.NSQLookupDHTTPClient

Returns the broadcasted TCP addresses of all known nsqd producers for a topic.

getAttempts() - function in com.abusix.knsq.protocol.Message

The amount of attempts that already happened for this message.

getAuthIdentity() - function in com.abusix.knsq.http.model.ClientStats

 

getAuthorized() - function in com.abusix.knsq.http.model.ClientStats

 

getAuthRequired() - function in com.abusix.knsq.config.ConnectionConfig

Whether or not authorization is required by nsqd.

getAuthSecret() - function in com.abusix.knsq.config.ClientConfig

The secret used for authorization, if the server requires it.

getAutoFinish() - function in com.abusix.knsq.subscribe.BackoffHandler

Whether or not messages processed in this BackoffHandler should be automatically finished after receiving them without an exception.

getBackoffHandler() - function in com.abusix.knsq.subscribe.Subscription

The BackoffHandler of this subscription.

getBatcher(java.lang.String) - function in com.abusix.knsq.publish.Publisher

Obtain the Batcher for a certain topic.

getBroadcastAddress() - function in com.abusix.knsq.http.model.NsqD

The broadcast address of the nsqd node.

getCause() - function in kotlin.Throwable

 

getChannel() - function in com.abusix.knsq.subscribe.Subscription

 

getChannelName() - function in com.abusix.knsq.http.model.ChannelStats

 

getChannels() - function in com.abusix.knsq.http.model.LookupResponse

The list of channels that are active in the current requested context.

getChannels() - function in com.abusix.knsq.http.model.TopicStats

 

getClientCount() - function in com.abusix.knsq.http.model.ChannelStats

 

getClientId() - function in com.abusix.knsq.config.ClientConfig

An identifier used to disambiguate this client (i.e.

getClientId() - function in com.abusix.knsq.http.model.ClientStats

 

getClients() - function in com.abusix.knsq.http.model.ChannelStats

 

getConnectTimeout() - function in com.abusix.knsq.config.ClientConfig

The timeout for establishing a connection.

getConnectTimestamp() - function in com.abusix.knsq.http.model.ClientStats

 

getCount() - function in com.abusix.knsq.http.model.E2EProcessingLatencyStats

 

getCount() - function in com.abusix.knsq.http.model.PublishedStats

 

getData() - function in com.abusix.knsq.protocol.Message

The data payload of the message.

getDEFAULT_ALIVE_CHECK_INTERVAL() - function in com.abusix.knsq.subscribe.DirectSubscriber.Companion

The default interval during which the live status of the connection is checked.

getDEFAULT_INIT_DELAY() - function in com.abusix.knsq.subscribe.BackoffHandler.Companion

The default initial length of a low traffic period after the first failed received packet.

getDEFAULT_LOOKUP_INTERVAL() - function in com.abusix.knsq.subscribe.Subscriber.Companion

The default interval for lookups.

getDEFAULT_MAX_BATCH_DELAY() - function in com.abusix.knsq.publish.Batcher.Companion

The default maximum batch delay.

getDEFAULT_MAX_DELAY() - function in com.abusix.knsq.subscribe.BackoffHandler.Companion

The default maximum delay until the full traffic volume is tried again.

getDEFAULT_MAX_FLUSH_DELAY() - function in com.abusix.knsq.subscribe.Subscriber.Companion

The default maximum delay until responses to the nsq nodes are flushed.

getDeferredCount() - function in com.abusix.knsq.http.model.ChannelStats

 

getDeflate() - function in com.abusix.knsq.config.ClientConfig

Enable deflate compression for this connection.

getDeflate() - function in com.abusix.knsq.config.ConnectionConfig

Whether deflate compression is enabled for this connection or not.

getDeflate() - function in com.abusix.knsq.http.model.ClientStats

 

getDeflateLevel() - function in com.abusix.knsq.config.ClientConfig

Configure the deflate compression level for this connection.

getDeflateLevel() - function in com.abusix.knsq.config.ConnectionConfig

The deflate level.

getDepth() - function in com.abusix.knsq.http.model.ChannelStats

 

getDepth() - function in com.abusix.knsq.http.model.TopicStats

 

getDiskDepth() - function in com.abusix.knsq.http.model.ChannelStats

 

getDiskDepth() - function in com.abusix.knsq.http.model.TopicStats

 

getE2eProcessingLatency() - function in com.abusix.knsq.http.model.ChannelStats

 

getE2eProcessingLatency() - function in com.abusix.knsq.http.model.TopicStats

 

getEntries() - function in com.abusix.knsq.protocol.ErrorType

 

getEntries() - function in com.abusix.knsq.protocol.FrameType

 

getError() - function in com.abusix.knsq.common.NSQException

The detailed error that NSQ returned.

getErrorType() - function in com.abusix.knsq.protocol.Error

The type of this error.

getFeatureNegotiation() - function in com.abusix.knsq.config.ClientConfig

Boolean used to indicate that the client supports feature negotiation.

getFinishCount() - function in com.abusix.knsq.http.model.ClientStats

 

getGcPauseUsec100() - function in com.abusix.knsq.http.model.MemoryStats

 

getGcPauseUSec95() - function in com.abusix.knsq.http.model.MemoryStats

 

getGcPauseUsec99() - function in com.abusix.knsq.http.model.MemoryStats

 

getGcTotalRuns() - function in com.abusix.knsq.http.model.MemoryStats

 

getHealth() - function in com.abusix.knsq.http.model.StatsResponse

 

getHeapIdleBytes() - function in com.abusix.knsq.http.model.MemoryStats

 

getHeapInUseBytes() - function in com.abusix.knsq.http.model.MemoryStats

 

getHeapObjects() - function in com.abusix.knsq.http.model.MemoryStats

 

getHeapReleasedBytes() - function in com.abusix.knsq.http.model.MemoryStats

 

getHeartbeatInterval() - function in com.abusix.knsq.config.ClientConfig

Milliseconds between heartbeats.

getHeartbeatInterval() - function in com.abusix.knsq.config.ConnectionConfig

The interval for which nsqd expects and sends heartbeats, if no other messages were sent.

getHostname() - function in com.abusix.knsq.http.model.ClientStats

 

getHostname() - function in com.abusix.knsq.http.model.NsqD

The hostname of the nsqd server.

getHttpPort() - function in com.abusix.knsq.http.model.NsqD

The HTTP port of the nsqd node.

getId() - function in com.abusix.knsq.protocol.Message

A unique identifier of the message mainly used for sending an acknowledgement.

getInFlightCount() - function in com.abusix.knsq.http.model.ChannelStats

 

getInFlightCount() - function in com.abusix.knsq.http.model.ClientStats

 

getInitDelay() - function in com.abusix.knsq.subscribe.BackoffHandler

The initial length of a low traffic period after the first failed received packet.

getInitialMaxInFlight() - function in com.abusix.knsq.subscribe.Subscriber

The initial setting for Subscription.maxInFlight.

getInitialMaxInFlight() - function in com.abusix.knsq.subscribe.Subscriber

The initial setting for Subscription.maxInFlight.

getJson() - function in com.abusix.knsq.http.AbstractHTTPClient.Companion

 

getLocalHostname() - function in com.abusix.knsq.config.ClientConfig

The hostname where the client is deployed

getLocalizedMessage() - function in kotlin.Throwable

 

getLookupInterval() - function in com.abusix.knsq.subscribe.Subscriber

 

getLookupInterval() - function in com.abusix.knsq.subscribe.Subscriber

 

getMaxDeflateLevel() - function in com.abusix.knsq.config.ConnectionConfig

The maximum deflate level supported by the server.

getMaxDelay() - function in com.abusix.knsq.publish.Batcher

The maximum delay before a message is guaranteed to be sent.

getMaxDelay() - function in com.abusix.knsq.subscribe.BackoffHandler

The maximum delay until the full traffic volume is tried again.

getMaxFlushDelay() - function in com.abusix.knsq.subscribe.Subscriber

 

getMaxFlushDelay() - function in com.abusix.knsq.subscribe.Subscriber

 

getMaxInFlight() - function in com.abusix.knsq.subscribe.Subscription

The maximum amount of messages to be in flight at the same time.

getMaxMessageAttempts() - function in com.abusix.knsq.subscribe.Subscriber

The maximum amount of attempts to deliver a message.

getMaxMessageAttempts() - function in com.abusix.knsq.subscribe.Subscriber

The maximum amount of attempts to deliver a message.

getMaxMsgTimeout() - function in com.abusix.knsq.config.ConnectionConfig

The maximum value for message timeout.

getMaxRdyCount() - function in com.abusix.knsq.config.ConnectionConfig

Each nsqd is configurable with a max-rdy-count.

getMaxSize() - function in com.abusix.knsq.publish.Batcher

The maximum size for a single message batch in bytes.

getMaxUnflushedBytes() - function in com.abusix.knsq.subscribe.Subscriber

The maximum amount of unflushed bytes.

getMaxUnflushedBytes() - function in com.abusix.knsq.subscribe.Subscriber

The maximum amount of unflushed bytes.

getMemory() - function in com.abusix.knsq.http.model.StatsResponse

 

getMessage() - function in kotlin.Throwable

 

getMessageBytes() - function in com.abusix.knsq.http.model.TopicStats

 

getMessageCount() - function in com.abusix.knsq.http.model.TopicStats

 

getMsg() - function in com.abusix.knsq.protocol.Response

The message of the response.

getMsgTimeout() - function in com.abusix.knsq.config.ClientConfig

Configure the server-side message timeout in milliseconds for messages delivered to this client.

getMsgTimeout() - function in com.abusix.knsq.config.ConnectionConfig

The effective message timeout.

getName() - function in kotlin.ErrorType

 

getName() - function in kotlin.FrameType

 

getNextGcBytes() - function in com.abusix.knsq.http.model.MemoryStats

 

getNodes() - function in com.abusix.knsq.http.NSQLookupDHTTPClient

Returns a list of all known nsqd instances (even if they have no active topics).

getNsqds() - function in com.abusix.knsq.http.model.LookupResponse

The list of nsqd nodes that are active in the current requested context.

getOnException() - function in com.abusix.knsq.publish.Publisher

A listener that can be used to obtain asynchronous exceptions.

getOnException() - function in com.abusix.knsq.subscribe.Subscription

A listener for Exceptions that happened within this Subscriber or its Subscriptions.

getOnFailedMessage() - function in com.abusix.knsq.subscribe.Subscription

A callback function for receiving failed messages.

getOnLookupException() - function in com.abusix.knsq.subscribe.Subscriber

An exception listener that can be used to receive exceptions that were thrown while trying to contact the nsqlookupd server.

getOnLookupException() - function in com.abusix.knsq.subscribe.Subscriber

An exception listener that can be used to receive exceptions that were thrown while trying to contact the nsqlookupd server.

getOnMessage() - function in com.abusix.knsq.subscribe.Subscription

A listener for receiving messages.

getOnNSQError() - function in com.abusix.knsq.subscribe.Subscription

A listener for errors that were returned by nsqd within this Subscriber or its Subscriptions.

getOrdinal() - function in kotlin.ErrorType

 

getOrdinal() - function in kotlin.FrameType

 

getPaused() - function in com.abusix.knsq.http.model.ChannelStats

 

getPercentiles() - function in com.abusix.knsq.http.model.E2EProcessingLatencyStats

 

getProducers() - function in com.abusix.knsq.http.model.StatsResponse

 

getPubCounts() - function in com.abusix.knsq.http.model.ClientStats

 

getQuantile() - function in com.abusix.knsq.http.model.E2EPercentile

 

getRawData() - function in com.abusix.knsq.protocol.Error

The raw content of the error returned by nsqd.

getReadTimeout() - function in com.abusix.knsq.config.ClientConfig

The read timeout for connection sockets and for awaiting responses from nsq.

getReadyCount() - function in com.abusix.knsq.http.model.ClientStats

 

getRemoteAddress() - function in com.abusix.knsq.http.model.ClientStats

 

getRequeueCount() - function in com.abusix.knsq.http.model.ChannelStats

 

getRequeueCount() - function in com.abusix.knsq.http.model.ClientStats

 

getResponseCode() - function in com.abusix.knsq.common.NSQHTTPResponseException

The returned response code.

getRunning() - function in com.abusix.knsq.subscribe.Subscription

Whether or not this subscription is still actively running.

getSampleRate() - function in com.abusix.knsq.config.ClientConfig

The sample rate for incoming data to deliver a percentage of all messages received to this connection.

getSampleRate() - function in com.abusix.knsq.http.model.ClientStats

 

getSize() - function in com.abusix.knsq.protocol.Frame

The size of this frame, which is determined by the first byte quartet of the raw frame.

getSize() - function in com.abusix.knsq.protocol.Frame

The size of this frame, which is determined by the first byte quartet of the raw frame.

getSnappy() - function in com.abusix.knsq.config.ClientConfig

Enable snappy compression for this connection.

getSnappy() - function in com.abusix.knsq.config.ConnectionConfig

Whether snappy compression is enabled for this connection or not.

getSnappy() - function in com.abusix.knsq.http.model.ClientStats

 

getSslSocketFactory() - function in com.abusix.knsq.config.ClientConfig

Using this property, you can use custom SSL configurations, e.g.

getStackTrace() - function in kotlin.Throwable

 

getStartTime() - function in com.abusix.knsq.http.model.StatsResponse

 

getState() - function in com.abusix.knsq.http.model.ClientStats

 

getSuppressed() - function in kotlin.Throwable

 

getTcpPort() - function in com.abusix.knsq.http.model.NsqD

The TCP port of the nsqd node.

getTerminateConnection() - function in com.abusix.knsq.protocol.ErrorType

A boolean indicating whether or not an Error with this type terminates the connection or not.

getTimeoutCount() - function in com.abusix.knsq.http.model.ChannelStats

 

getTimestamp() - function in com.abusix.knsq.protocol.Message

The timestamp of this message.

getTls() - function in com.abusix.knsq.config.ClientConfig

Enable TLS for this connection

getTls() - function in com.abusix.knsq.config.ConnectionConfig

Whether TLS is enabled for this connection or not.

getTls() - function in com.abusix.knsq.http.model.ClientStats

 

getTlsCipherSuite() - function in com.abusix.knsq.http.model.ClientStats

 

getTlsNegotiatedProtocol() - function in com.abusix.knsq.http.model.ClientStats

 

getTlsNegotiatedProtocolIsMutual() - function in com.abusix.knsq.http.model.ClientStats

 

getTlsVersion() - function in com.abusix.knsq.http.model.ClientStats

 

getTombstones() - function in com.abusix.knsq.http.model.NsqD

A list of boolean flags that indicate whether or not a given topic in topics is tombstoned.

getTopic() - function in com.abusix.knsq.http.model.PublishedStats

 

getTopic() - function in com.abusix.knsq.protocol.Message

 

getTopic() - function in com.abusix.knsq.subscribe.Subscription

 

getTopicName() - function in com.abusix.knsq.http.model.TopicStats

 

getTopics() - function in com.abusix.knsq.http.NSQLookupDHTTPClient

Returns a list of all known topics.

getTopics() - function in com.abusix.knsq.http.model.NsqD

The list of currently known topics on this nsqd node.

getTopics() - function in com.abusix.knsq.http.model.StatsResponse

 

getTopics() - function in com.abusix.knsq.http.model.TopicsResponse

 

getTotalMessageCount() - function in com.abusix.knsq.http.model.ChannelStats

 

getTotalMessageCount() - function in com.abusix.knsq.http.model.ClientStats

 

getType() - function in com.abusix.knsq.protocol.Frame

The type of this frame, which is determined by the second byte quartet of the raw frame.

getType() - function in com.abusix.knsq.protocol.Frame

The type of this frame, which is determined by the second byte quartet of the raw frame.

getUserAgent() - function in com.abusix.knsq.config.ClientConfig

A string identifying the agent for this client in the spirit of HTTP.

getUserAgent() - function in com.abusix.knsq.http.model.ClientStats

 

getValue() - function in com.abusix.knsq.http.model.E2EPercentile

 

getVersion() - function in com.abusix.knsq.config.ConnectionConfig

The nsqd version.

getVersion() - function in com.abusix.knsq.http.model.ClientStats

 

getVersion() - function in com.abusix.knsq.http.model.NsqD

The version of the nsqd node.

getVersion() - function in com.abusix.knsq.http.model.StatsResponse

 

A  B  C  D  E  F  G  I  K  L  M  N  P  R  S  T  U  V