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

A

accumulateExceptions() - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction

action() - Method in class org.xbib.elasticsearch.transport.netty.NettyTransportChannel

add(IndexRequest) - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler

Adds an IndexRequest to the list of actions to execute.

add(DeleteRequest) - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler

Adds an DeleteRequest to the list of actions to execute.

add(ActionRequest) - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler

add(IndexRequest, InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler

Adds an IndexRequest to the list of actions to execute.

add(DeleteRequest, InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler

Adds an DeleteRequest to the list of actions to execute.

add(ActionRequest, InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler

addInteractiveAction(Class<? extends BaseInteractiveHandler>) - Method in class org.xbib.elasticsearch.plugin.websocket.WebSocketModule

address() - Method in class org.xbib.elasticsearch.http.HttpInfo

address() - Method in class org.xbib.elasticsearch.http.HttpServer

addressesFromString(String) - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

addressSupported(Class<? extends TransportAddress>) - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

afterBulk(long, BulkRequest, BulkResponse) - Method in interface org.xbib.elasticsearch.action.websocket.bulk.BulkHandler.Listener

Callback after a successful execution of bulk request.

afterBulk(long, BulkRequest, Throwable) - Method in interface org.xbib.elasticsearch.action.websocket.bulk.BulkHandler.Listener

Callback after a failed execution of bulk request.

array() - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

array() - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

The underlying byte array (if exists).

array() - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

array() - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

arrayOffset() - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

arrayOffset() - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

The offset into the underlying byte array.

arrayOffset() - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

arrayOffset() - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

asMap() - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

asMap() - Method in interface org.xbib.elasticsearch.websocket.InteractiveRequest

available() - Method in class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInput

B

BaseInteractiveHandler - Class in org.xbib.elasticsearch.websocket

The BaseInteractiveHandler is the base class for interactive actions.

BaseInteractiveHandler(Settings, Client) - Constructor for class org.xbib.elasticsearch.websocket.BaseInteractiveHandler

beforeBulk(long, BulkRequest) - Method in interface org.xbib.elasticsearch.action.websocket.bulk.BulkHandler.Listener

Callback before the bulk is executed.

bigarrays - Variable in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

BindHttpException - Exception in org.xbib.elasticsearch.http

BindHttpException(String) - Constructor for exception org.xbib.elasticsearch.http.BindHttpException

BindHttpException(String, Throwable) - Constructor for exception org.xbib.elasticsearch.http.BindHttpException

boundAddress() - Method in interface org.xbib.elasticsearch.http.HttpServerTransport

Return the bound transport addess

boundAddress() - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransport

boundAddress() - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

build() - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler.Builder

Builds a new bulk processor.

Build - Class in org.xbib.elasticsearch.plugin.websocket

builder(Client, BulkHandler.Listener) - Static method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler

builder - Variable in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

BulkDeleteAction - Class in org.xbib.elasticsearch.action.websocket.bulk

Bulk delete action

BulkDeleteAction(Settings, Client, InteractiveController) - Constructor for class org.xbib.elasticsearch.action.websocket.bulk.BulkDeleteAction

BulkFlushAction - Class in org.xbib.elasticsearch.action.websocket.bulk

Bulk flush action.

BulkFlushAction(Settings, Client, InteractiveController) - Constructor for class org.xbib.elasticsearch.action.websocket.bulk.BulkFlushAction

BulkHandler - Class in org.xbib.elasticsearch.action.websocket.bulk

The bulk handler is derived from the BulkProcessor, but offers explicit flushing and can receive requests from multiple threads into a global action queue.

BulkHandler(Settings, Client) - Constructor for class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler

BulkHandler.Builder - Class in org.xbib.elasticsearch.action.websocket.bulk

A builder used to create a build an instance of a bulk processor.

BulkHandler.Builder(Client, BulkHandler.Listener) - Constructor for class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler.Builder

Creates a builder of bulk processor with the client to use and the listener that will be used to be notified on the completion of bulk requests.

BulkHandler.Listener - Interface in org.xbib.elasticsearch.action.websocket.bulk

A listener for the execution.

BulkIndexAction - Class in org.xbib.elasticsearch.action.websocket.bulk

BulkIndexAction(Settings, Client, InteractiveController) - Constructor for class org.xbib.elasticsearch.action.websocket.bulk.BulkIndexAction

bytearray - Variable in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

bytes - Variable in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

bytes() - Method in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

bytes() - Method in class org.xbib.elasticsearch.common.io.stream.CachedStreamOutput.Entry

bytes(Compressor) - Method in class org.xbib.elasticsearch.common.io.stream.CachedStreamOutput.Entry

BYTES_LIMIT - Static variable in class org.xbib.elasticsearch.common.io.stream.CachedStreamOutput

BytesArray - Class in org.xbib.elasticsearch.common.bytes

BytesArray for un-relocated netty.

BytesArray(String) - Constructor for class org.xbib.elasticsearch.common.bytes.BytesArray

BytesArray(BytesRef) - Constructor for class org.xbib.elasticsearch.common.bytes.BytesArray

BytesArray(BytesRef, boolean) - Constructor for class org.xbib.elasticsearch.common.bytes.BytesArray

BytesArray(byte[]) - Constructor for class org.xbib.elasticsearch.common.bytes.BytesArray

BytesArray(byte[], int, int) - Constructor for class org.xbib.elasticsearch.common.bytes.BytesArray

bytesEqual(BytesReference, BytesReference) - Static method in class org.xbib.elasticsearch.common.bytes.BytesReference.Helper

bytesHashCode(BytesReference) - Static method in class org.xbib.elasticsearch.common.bytes.BytesReference.Helper

BytesReference - Interface in org.xbib.elasticsearch.common.bytes

A reference to bytes for our Netty.

BytesReference.Helper - Class in org.xbib.elasticsearch.common.bytes

BytesReference.Helper() - Constructor for class org.xbib.elasticsearch.common.bytes.BytesReference.Helper

BytesStreamOutput - Class in org.xbib.elasticsearch.common.io.stream

BytesStreamOutput() - Constructor for class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

Create a non recycling BytesStreamOutput with 1 initial page acquired.

BytesStreamOutput(int) - Constructor for class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

Create a non recycling BytesStreamOutput with enough initial pages acquired to satisfy the capacity given by expected size.

BytesStreamOutput(int, BigArrays) - Constructor for class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

C

CachedStreamOutput - Class in org.xbib.elasticsearch.common.io.stream

CachedStreamOutput() - Constructor for class org.xbib.elasticsearch.common.io.stream.CachedStreamOutput

CachedStreamOutput.Entry - Class in org.xbib.elasticsearch.common.io.stream

channel(Integer) - Method in class org.xbib.elasticsearch.common.netty.OpenChannelsHandler

channel(Integer) - Method in class org.xbib.elasticsearch.http.HttpServer

channel(Integer) - Method in interface org.xbib.elasticsearch.http.HttpServerTransport

Find channel for a given channel ID

channel() - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientHandler

channel(Integer) - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransport

Returns a channel if it is in the server open channel table, given by ID.

channel(TransportRequestOptions.Type) - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport.NodeChannels

channel() - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClient

The channel this client has opened.

ChannelBufferBytesReference - Class in org.xbib.elasticsearch.common.bytes

ChannelBufferBytesReference for un-relocated netty

ChannelBufferBytesReference(ChannelBuffer) - Constructor for class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

ChannelBufferStreamInput - Class in org.xbib.elasticsearch.transport.netty

A Netty ChannelBuffer based StreamInput.

ChannelBufferStreamInput(ChannelBuffer) - Constructor for class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInput

ChannelBufferStreamInput(ChannelBuffer, int) - Constructor for class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInput

ChannelBufferStreamInputFactory - Class in org.xbib.elasticsearch.transport.netty

ChannelBufferStreamInputFactory() - Constructor for class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInputFactory

channelClosed(ChannelHandlerContext, ChannelStateEvent) - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientHandler

channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientHandler

checkpoint(String) - Method in class org.xbib.elasticsearch.action.websocket.pubsub.Checkpointer

Checkpointing a topic or a subscriber.

checkpointedAt(String) - Method in class org.xbib.elasticsearch.action.websocket.pubsub.Checkpointer

Checkpointer - Class in org.xbib.elasticsearch.action.websocket.pubsub

Checkpointer(Settings, Client) - Constructor for class org.xbib.elasticsearch.action.websocket.pubsub.Checkpointer

clear() - Static method in class org.xbib.elasticsearch.common.io.stream.CachedStreamOutput

client - Variable in class org.xbib.elasticsearch.websocket.BaseInteractiveHandler

close() - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler

Closes the processor.

close() - Method in class org.xbib.elasticsearch.common.bytes.ReleasablePagedBytesReference

close() - Method in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

close() - Method in class org.xbib.elasticsearch.common.netty.OpenChannelsHandler

close() - Method in class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInput

close() - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport.NodeChannels

configure() - Method in class org.xbib.elasticsearch.http.HttpServerModule

configure() - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransportModule

configure() - Method in class org.xbib.elasticsearch.plugin.websocket.WebSocketModule

configure() - Method in class org.xbib.elasticsearch.websocket.InteractiveActionModule

connect() - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientHandler

connect() - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClient

Connect to host and port.

connectToNode(DiscoveryNode) - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

connectToNode(DiscoveryNode, boolean) - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

connectToNodeLight(DiscoveryNode) - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

content() - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequest

contentUnsafe() - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequest

copyBytesArray() - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

copyBytesArray() - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

Returns the bytes copied over as a byte array.

copyBytesArray() - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

copyBytesArray() - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

copyBytesRef() - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

copyBytesRef() - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

Converts to a copied Lucene BytesRef.

copyBytesRef() - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

copyBytesRef() - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

count - Variable in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

COUNT_LIMIT - Static variable in class org.xbib.elasticsearch.common.io.stream.CachedStreamOutput

create(ChannelBuffer) - Static method in class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInputFactory

create(ChannelBuffer, int) - Static method in class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInputFactory

D

data(XContentBuilder) - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketBulkRequest

data - Variable in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

data(XContentBuilder) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

data(XContentBuilder) - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClientBulkRequest

data(XContentBuilder) - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClientRequest

decode(ChannelHandlerContext, Channel, ChannelBuffer) - Method in class org.xbib.elasticsearch.common.netty.KeepFrameDecoder

decode(ChannelHandlerContext, Channel, ChannelBuffer) - Method in class org.xbib.elasticsearch.transport.netty.SizeHeaderFrameDecoder

decoder - Static variable in class org.xbib.elasticsearch.common.netty.KeepFrameDecoder

DEFAULT_INDEX_NAME - Static variable in class org.xbib.elasticsearch.action.websocket.pubsub.PubSubIndexName.Conf

DEFAULT_MIME_TYPES - Static variable in class org.xbib.elasticsearch.http.HttpServer

deleteBulk(DeleteRequest, InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.pubsub.Checkpointer

Perform bulk delete

deleteRequest() - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientFactory

deleteRequest() - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClientFactory

description() - Method in class org.xbib.elasticsearch.plugin.websocket.WebSocketPlugin

determineThreadName(String, String) - Method in class org.xbib.elasticsearch.common.netty.NettyStaticSetup.EsThreadNameDeterminer

disconnect() - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientHandler

disconnect() - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClient

Disconnect from the server

disconnectFromNode(DiscoveryNode) - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

dispatchRequest(HttpRequest, HttpChannel) - Method in interface org.xbib.elasticsearch.http.HttpServerAdapter

dispatchRequest(RestRequest, RestChannel) - Method in class org.xbib.elasticsearch.rest.HttpPatchRestController

doClose() - Method in class org.xbib.elasticsearch.action.websocket.pubsub.Checkpointer

doClose() - Method in class org.xbib.elasticsearch.http.HttpServer

doClose() - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransport

doClose() - Method in class org.xbib.elasticsearch.rest.HttpPatchRestController

doClose() - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

doClose() - Method in class org.xbib.elasticsearch.websocket.InteractiveController

doExecute(ActionListener<WebsocketInfoResponse>) - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoRequestBuilder

doStart() - Method in class org.xbib.elasticsearch.action.websocket.pubsub.Checkpointer

doStart() - Method in class org.xbib.elasticsearch.http.HttpServer

doStart() - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransport

doStart() - Method in class org.xbib.elasticsearch.rest.HttpPatchRestController

doStart() - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

doStart() - Method in class org.xbib.elasticsearch.websocket.InteractiveController

doStop() - Method in class org.xbib.elasticsearch.action.websocket.pubsub.Checkpointer

doStop() - Method in class org.xbib.elasticsearch.http.HttpServer

doStop() - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransport

doStop() - Method in class org.xbib.elasticsearch.rest.HttpPatchRestController

doStop() - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

doStop() - Method in class org.xbib.elasticsearch.websocket.InteractiveController

E

emptyBuilder(RestRequest) - Static method in class org.xbib.elasticsearch.rest.RestXContentBuilder

equals(Object) - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

equals(Object) - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

equals(Object) - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientHandler

exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequestHandler

exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketRequestHandler

executor() - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction

F

flush() - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler

Flushes open bulk actions

flush(InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler

Flushes open bulk actions

flush() - Method in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

flushBulk(InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.pubsub.Checkpointer

Flush bulk

flushCheckpoint() - Method in class org.xbib.elasticsearch.action.websocket.pubsub.Checkpointer

flushRequest() - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientFactory

flushRequest() - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClientFactory

forward(String, Integer, XContentBuilder) - Method in interface org.xbib.elasticsearch.http.HttpServerTransport

Forward a message to a node for a given channel ID

forward(String, Integer, XContentBuilder) - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransport

Forward a message to another node with websockets for delivery.

ForwardAction - Class in org.xbib.elasticsearch.action.websocket.pubsub

Forwarding a message to a destination.

ForwardAction(Settings, Client, HttpServerTransport, InteractiveController) - Constructor for class org.xbib.elasticsearch.action.websocket.pubsub.ForwardAction

frame(WebSocketServerHandshaker, WebSocketFrame, ChannelHandlerContext) - Method in interface org.xbib.elasticsearch.http.WebSocketServerAdapter

Emit a frame.

frame(WebSocketServerHandshaker, WebSocketFrame, ChannelHandlerContext) - Method in class org.xbib.elasticsearch.websocket.InteractiveController

G

get(int) - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

get(int) - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

Returns the byte at the specified index.

get(int) - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

get(int) - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

getAddress() - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfo

getAddress() - Method in class org.xbib.elasticsearch.http.HttpInfo

getChannel() - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveChannel

getChannel() - Method in interface org.xbib.elasticsearch.websocket.InteractiveChannel

getDate() - Method in class org.xbib.elasticsearch.plugin.websocket.Build

getHash() - Method in class org.xbib.elasticsearch.plugin.websocket.Build

getInstance() - Static method in class org.xbib.elasticsearch.plugin.websocket.Build

getListener() - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler

getMaxContentLength() - Method in class org.xbib.elasticsearch.http.HttpInfo

getMethod() - Method in class org.xbib.elasticsearch.http.HttpRequest

getMethod() - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequest

getPipeline() - Method in class org.xbib.elasticsearch.http.netty.NettyHttpServerPipelineFactory

getPipeline() - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketServerPipelineFactory

getServerOpen() - Method in class org.xbib.elasticsearch.http.HttpStats

getShortHash() - Method in class org.xbib.elasticsearch.plugin.websocket.Build

getTimestamp() - Method in class org.xbib.elasticsearch.plugin.websocket.Build

getTotalOpen() - Method in class org.xbib.elasticsearch.http.HttpStats

getVersion() - Method in class org.xbib.elasticsearch.plugin.websocket.Build

H

handleRequest(InteractiveRequest, InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkDeleteAction

handleRequest(InteractiveRequest, InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkFlushAction

handleRequest(InteractiveRequest, InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler

handleRequest(InteractiveRequest, InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkIndexAction

handleRequest(InteractiveRequest, InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.pubsub.ForwardAction

handleRequest(InteractiveRequest, InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.pubsub.PublishAction

handleRequest(InteractiveRequest, InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.pubsub.SubscribeAction

handleRequest(InteractiveRequest, InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.pubsub.UnsubscribeAction

handleRequest(RestRequest, RestChannel, Client) - Method in class org.xbib.elasticsearch.rest.action.websocket.RestPublishAction

handleRequest(RestRequest, RestChannel, Client) - Method in class org.xbib.elasticsearch.rest.action.websocket.RestUnsubscribeAction

handleRequest(InteractiveRequest, InteractiveChannel) - Method in interface org.xbib.elasticsearch.websocket.InteractiveHandler

handles() - Method in class org.xbib.elasticsearch.common.io.stream.CachedStreamOutput.Entry

handles(Compressor) - Method in class org.xbib.elasticsearch.common.io.stream.CachedStreamOutput.Entry

handleUpstream(ChannelHandlerContext, ChannelEvent) - Method in class org.xbib.elasticsearch.common.netty.OpenChannelsHandler

handshaker - Variable in class org.xbib.elasticsearch.http.netty.NettyHttpRequestHandler

hasArray() - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

hasArray() - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

Is there an underlying byte array for this bytes reference.

hasArray() - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

hasArray() - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

hasChannel(Channel) - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport.NodeChannels

hasContent() - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequest

hashCode() - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

hashCode() - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

hashCode() - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

hasParam(String) - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequest

hasParam(String) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

hasParam(String) - Method in interface org.xbib.elasticsearch.websocket.InteractiveRequest

header(String) - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequest

HEADER_SIZE - Static variable in class org.xbib.elasticsearch.transport.netty.NettyHeader

headers() - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequest

HttpChannel - Class in org.xbib.elasticsearch.http

HttpChannel(RestRequest) - Constructor for class org.xbib.elasticsearch.http.HttpChannel

HttpException - Exception in org.xbib.elasticsearch.http

HttpException(String) - Constructor for exception org.xbib.elasticsearch.http.HttpException

HttpException(String, Throwable) - Constructor for exception org.xbib.elasticsearch.http.HttpException

HttpInfo - Class in org.xbib.elasticsearch.http

HttpInfo(BoundTransportAddress, long) - Constructor for class org.xbib.elasticsearch.http.HttpInfo

HttpPatchRestController - Class in org.xbib.elasticsearch.rest

HttpPatchRestController(Settings) - Constructor for class org.xbib.elasticsearch.rest.HttpPatchRestController

HttpRequest - Class in org.xbib.elasticsearch.http

HttpRequest() - Constructor for class org.xbib.elasticsearch.http.HttpRequest

HttpServer - Class in org.xbib.elasticsearch.http

HttpServer(Settings, Environment, HttpServerTransport, RestController, HttpPatchRestController, InteractiveController, NodeService) - Constructor for class org.xbib.elasticsearch.http.HttpServer

HttpServerAdapter - Interface in org.xbib.elasticsearch.http

httpServerAdapter(HttpServerAdapter) - Method in interface org.xbib.elasticsearch.http.HttpServerTransport

Set HTTP server adapter

httpServerAdapter(HttpServerAdapter) - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransport

HttpServerModule - Class in org.xbib.elasticsearch.http

HttpServerModule(Settings) - Constructor for class org.xbib.elasticsearch.http.HttpServerModule

HttpServerTransport - Interface in org.xbib.elasticsearch.http

HttpServerTransport extended by Websocket services

HttpStats - Class in org.xbib.elasticsearch.http

HttpStats(long, long) - Constructor for class org.xbib.elasticsearch.http.HttpStats

I

indexBulk(IndexRequest, InteractiveChannel) - Method in class org.xbib.elasticsearch.action.websocket.pubsub.Checkpointer

Perform bulk indexing

indexName(Settings) - Static method in class org.xbib.elasticsearch.action.websocket.pubsub.PubSubIndexName.Conf

indexRequest() - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientFactory

indexRequest() - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClientFactory

info() - Method in class org.xbib.elasticsearch.http.HttpServer

info() - Method in interface org.xbib.elasticsearch.http.HttpServerTransport

info() - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransport

INSTANCE - Static variable in class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoAction

InteractiveActionModule - Class in org.xbib.elasticsearch.websocket

The InteractiveActionModule binds all WebSocket actions.

InteractiveActionModule(List<Class<? extends BaseInteractiveHandler>>) - Constructor for class org.xbib.elasticsearch.websocket.InteractiveActionModule

InteractiveChannel - Interface in org.xbib.elasticsearch.websocket

InteractiveChannel writes responses to a a channel

InteractiveController - Class in org.xbib.elasticsearch.websocket

The InteractiveController controls the presence of websocket connections and the flow of websocket frames for interactive use.

InteractiveController(Settings) - Constructor for class org.xbib.elasticsearch.websocket.InteractiveController

InteractiveHandler - Interface in org.xbib.elasticsearch.websocket

A request handler for interactive requests

InteractiveRequest - Interface in org.xbib.elasticsearch.websocket

The InteractiveRequest manages parameters in an interaction.

InteractiveResponse - Interface in org.xbib.elasticsearch.websocket

The InteractiveResponse can serve frames to websocket connections.

internalDispatchRequest(HttpRequest, HttpChannel) - Method in class org.xbib.elasticsearch.http.HttpServer

internalFrame(WebSocketServerHandshaker, WebSocketFrame, ChannelHandlerContext) - Method in class org.xbib.elasticsearch.http.HttpServer

internalPresence(Presence, String, Channel) - Method in class org.xbib.elasticsearch.http.HttpServer

K

KeepFrameDecoder - Class in org.xbib.elasticsearch.common.netty

A marker to not remove frame decoder from the resulting jar, so plugins can use it.

KeepFrameDecoder() - Constructor for class org.xbib.elasticsearch.common.netty.KeepFrameDecoder

L

length() - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

length() - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

The length.

length() - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

length() - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

M

mark(int) - Method in class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInput

markSupported() - Method in class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInput

maxContentLength() - Method in class org.xbib.elasticsearch.http.HttpInfo

MessageChannelHandler - Class in org.xbib.elasticsearch.transport.netty

A handler (must be the last one!) that does size based frame decoding and forwards the actual message to the relevant action.

MessageChannelHandler(NettyTransport, ESLogger) - Constructor for class org.xbib.elasticsearch.transport.netty.MessageChannelHandler

messageReceived(ChannelHandlerContext, MessageEvent) - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientHandler

messageReceived(ChannelHandlerContext, MessageEvent) - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequestHandler

messageReceived(ChannelHandlerContext, MessageEvent) - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketRequestHandler

messageReceived(ChannelHandlerContext, MessageEvent) - Method in class org.xbib.elasticsearch.transport.netty.MessageChannelHandler

method() - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequest

modules() - Method in class org.xbib.elasticsearch.plugin.websocket.WebSocketPlugin

N

NAME - Static variable in class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoAction

name() - Method in class org.xbib.elasticsearch.plugin.websocket.WebSocketPlugin

NettyHeader - Class in org.xbib.elasticsearch.transport.netty

NettyHeader() - Constructor for class org.xbib.elasticsearch.transport.netty.NettyHeader

NettyHttpChannel - Class in org.xbib.elasticsearch.http.netty

NettyHttpChannel(NettyWebSocketServerTransport, Channel, NettyHttpRequest) - Constructor for class org.xbib.elasticsearch.http.netty.NettyHttpChannel

NettyHttpRequest - Class in org.xbib.elasticsearch.http.netty

NettyHttpRequest(HttpRequest) - Constructor for class org.xbib.elasticsearch.http.netty.NettyHttpRequest

NettyHttpRequestHandler - Class in org.xbib.elasticsearch.http.netty

Handles HTTP request and upgrades HTTP to WebSocket if appropriate.

NettyHttpRequestHandler(NettyWebSocketServerTransport) - Constructor for class org.xbib.elasticsearch.http.netty.NettyHttpRequestHandler

NettyHttpServerPipelineFactory - Class in org.xbib.elasticsearch.http.netty

NettyInteractiveChannel - Class in org.xbib.elasticsearch.http.netty

Netty implementation for an interactive channel

NettyInteractiveChannel(Channel) - Constructor for class org.xbib.elasticsearch.http.netty.NettyInteractiveChannel

NettyInteractiveRequest - Class in org.xbib.elasticsearch.http.netty

Netty implemenation for an interactive request.

NettyInteractiveRequest() - Constructor for class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

NettyInteractiveRequest(Map<String, Object>) - Constructor for class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

NettyInteractiveResponse - Class in org.xbib.elasticsearch.http.netty

Netty implementation of an interactive response

NettyInteractiveResponse(String, XContentBuilder) - Constructor for class org.xbib.elasticsearch.http.netty.NettyInteractiveResponse

NettyInteractiveResponse(String, Map<String, Object>) - Constructor for class org.xbib.elasticsearch.http.netty.NettyInteractiveResponse

NettyInteractiveResponse(String, Throwable) - Constructor for class org.xbib.elasticsearch.http.netty.NettyInteractiveResponse

NettyStaticSetup - Class in org.xbib.elasticsearch.common.netty

NettyStaticSetup() - Constructor for class org.xbib.elasticsearch.common.netty.NettyStaticSetup

NettyStaticSetup.EsThreadNameDeterminer - Class in org.xbib.elasticsearch.common.netty

NettyStaticSetup.EsThreadNameDeterminer() - Constructor for class org.xbib.elasticsearch.common.netty.NettyStaticSetup.EsThreadNameDeterminer

NettyTransport - Class in org.xbib.elasticsearch.transport.netty

There are 4 types of connections per node, low/med/high/ping.

NettyTransport(Settings, ThreadPool, NetworkService, BigArrays, Version) - Constructor for class org.xbib.elasticsearch.transport.netty.NettyTransport

NettyTransport.NodeChannels - Class in org.xbib.elasticsearch.transport.netty

NettyTransport.NodeChannels(Channel[], Channel[], Channel[], Channel[], Channel[]) - Constructor for class org.xbib.elasticsearch.transport.netty.NettyTransport.NodeChannels

NettyTransportChannel - Class in org.xbib.elasticsearch.transport.netty

NettyTransportChannel(NettyTransport, String, Channel, long, Version) - Constructor for class org.xbib.elasticsearch.transport.netty.NettyTransportChannel

NettyWebSocketBulkRequest - Class in org.xbib.elasticsearch.http.netty.client

Netty bulk request convenience class.

NettyWebSocketBulkRequest(String) - Constructor for class org.xbib.elasticsearch.http.netty.client.NettyWebSocketBulkRequest

NettyWebSocketClient - Interface in org.xbib.elasticsearch.http.netty.client

A Websocket client.

NettyWebSocketClientFactory - Class in org.xbib.elasticsearch.http.netty.client

A factory for creating Websocket clients.

NettyWebSocketClientFactory() - Constructor for class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientFactory

NettyWebSocketClientHandler - Class in org.xbib.elasticsearch.http.netty.client

Handles socket communication for a connected WebSocket client.

NettyWebSocketClientHandler(ClientBootstrap, URI, WebSocketActionListener) - Constructor for class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientHandler

NettyWebSocketException - Exception in org.xbib.elasticsearch.http.netty.client

A WebSocket related exception

NettyWebSocketException(String) - Constructor for exception org.xbib.elasticsearch.http.netty.client.NettyWebSocketException

NettyWebSocketRequestHandler - Class in org.xbib.elasticsearch.http.netty

Netty implementation for a WebSocket request handler.

NettyWebSocketRequestHandler(NettyWebSocketServerTransport) - Constructor for class org.xbib.elasticsearch.http.netty.NettyWebSocketRequestHandler

NettyWebSocketServerPipelineFactory - Class in org.xbib.elasticsearch.http.netty

Netty implementation for a WebSocket server pipeline factory.

NettyWebSocketServerPipelineFactory(NettyWebSocketServerTransport) - Constructor for class org.xbib.elasticsearch.http.netty.NettyWebSocketServerPipelineFactory

NettyWebSocketServerTransport - Class in org.xbib.elasticsearch.http.netty

WebSocket server transport.

NettyWebSocketServerTransport(Settings, NetworkService, BigArrays) - Constructor for class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransport

NettyWebSocketServerTransportModule - Class in org.xbib.elasticsearch.http.netty

Module for HttpServerModule.

NettyWebSocketServerTransportModule() - Constructor for class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransportModule

newBytesOutput() - Method in class org.xbib.elasticsearch.http.netty.NettyHttpChannel

newClient(URI, WebSocketActionListener) - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientFactory

Create a new WebSocket client

newClient(URI, WebSocketActionListener) - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClientFactory

newNodeRequest() - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction

newNodeRequest(String, WebsocketInfoRequest) - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction

newNodeResponse() - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction

newRequest() - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction

newRequest() - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientFactory

newRequest() - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClientFactory

newRequestBuilder(ClusterAdminClient) - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoAction

newResponse(WebsocketInfoRequest, AtomicReferenceArray) - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction

newResponse() - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoAction

nodeConnected(DiscoveryNode) - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

nodeOperation(TransportWebsocketInfoAction.TransportWebsocketInfoRequest) - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction

numberOfOpenChannels() - Method in class org.xbib.elasticsearch.common.netty.OpenChannelsHandler

O

onConnect(WebSocketClient) - Method in class org.xbib.elasticsearch.websocket.client.WebSocketActionListener.Adapter

onConnect(C) - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketActionListener

Called when the client is connected to the server

onDisconnect(WebSocketClient) - Method in class org.xbib.elasticsearch.websocket.client.WebSocketActionListener.Adapter

onDisconnect(C) - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketActionListener

Called when the client got disconnected from the server

onError(Throwable) - Method in class org.xbib.elasticsearch.websocket.client.WebSocketActionListener.Adapter

onError(Throwable) - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketActionListener

Called when an unhandled errors occurs.

onMessage(WebSocketClient, WebSocketFrame) - Method in class org.xbib.elasticsearch.websocket.client.WebSocketActionListener.Adapter

onMessage(C, F) - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketActionListener

Called when a message arrives from the server

onModule(ActionModule) - Method in class org.xbib.elasticsearch.plugin.websocket.WebSocketPlugin

onModule(RestModule) - Method in class org.xbib.elasticsearch.plugin.websocket.WebSocketPlugin

OpenChannelsHandler - Class in org.xbib.elasticsearch.common.netty

OpenChannelsHandler(ESLogger) - Constructor for class org.xbib.elasticsearch.common.netty.OpenChannelsHandler

operationComplete(ChannelFuture) - Method in class org.xbib.elasticsearch.common.netty.ReleaseChannelFutureListener

org.xbib.elasticsearch.action.cluster.admin.websocket - package org.xbib.elasticsearch.action.cluster.admin.websocket

org.xbib.elasticsearch.action.websocket.bulk - package org.xbib.elasticsearch.action.websocket.bulk

org.xbib.elasticsearch.action.websocket.pubsub - package org.xbib.elasticsearch.action.websocket.pubsub

org.xbib.elasticsearch.common.bytes - package org.xbib.elasticsearch.common.bytes

org.xbib.elasticsearch.common.io - package org.xbib.elasticsearch.common.io

org.xbib.elasticsearch.common.io.stream - package org.xbib.elasticsearch.common.io.stream

org.xbib.elasticsearch.common.netty - package org.xbib.elasticsearch.common.netty

org.xbib.elasticsearch.http - package org.xbib.elasticsearch.http

org.xbib.elasticsearch.http.netty - package org.xbib.elasticsearch.http.netty

org.xbib.elasticsearch.http.netty.client - package org.xbib.elasticsearch.http.netty.client

org.xbib.elasticsearch.plugin.websocket - package org.xbib.elasticsearch.plugin.websocket

org.xbib.elasticsearch.rest - package org.xbib.elasticsearch.rest

org.xbib.elasticsearch.rest.action.websocket - package org.xbib.elasticsearch.rest.action.websocket

org.xbib.elasticsearch.transport.netty - package org.xbib.elasticsearch.transport.netty

org.xbib.elasticsearch.websocket - package org.xbib.elasticsearch.websocket

org.xbib.elasticsearch.websocket.client - package org.xbib.elasticsearch.websocket.client

ourBytes() - Method in interface org.xbib.elasticsearch.common.io.ReleasableBytesStream

ourBytes() - Method in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

ourBytes() - Method in class org.xbib.elasticsearch.common.io.stream.ReleasableBytesStreamOutput

P

PagedBytesReference - Class in org.xbib.elasticsearch.common.bytes

A page based bytes reference, internally holding the bytes in a paged data structure.

PagedBytesReference(BigArrays, ByteArray, int) - Constructor for class org.xbib.elasticsearch.common.bytes.PagedBytesReference

PagedBytesReference(BigArrays, ByteArray, int, int) - Constructor for class org.xbib.elasticsearch.common.bytes.PagedBytesReference

param(String) - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequest

param(String, String) - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequest

param(String) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

param(String) - Method in interface org.xbib.elasticsearch.websocket.InteractiveRequest

paramAsBoolean(String) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

paramAsBoolean(String, boolean) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

paramAsBoolean(String) - Method in interface org.xbib.elasticsearch.websocket.InteractiveRequest

paramAsBoolean(String, boolean) - Method in interface org.xbib.elasticsearch.websocket.InteractiveRequest

paramAsLong(String) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

paramAsLong(String, long) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

paramAsLong(String) - Method in interface org.xbib.elasticsearch.websocket.InteractiveRequest

paramAsLong(String, long) - Method in interface org.xbib.elasticsearch.websocket.InteractiveRequest

paramAsString(String) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

paramAsString(String, String) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

paramAsString(String) - Method in interface org.xbib.elasticsearch.websocket.InteractiveRequest

paramAsString(String, String) - Method in interface org.xbib.elasticsearch.websocket.InteractiveRequest

paramAsTime(String) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

paramAsTime(String, TimeValue) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

paramAsTime(String) - Method in interface org.xbib.elasticsearch.websocket.InteractiveRequest

paramAsTime(String, TimeValue) - Method in interface org.xbib.elasticsearch.websocket.InteractiveRequest

params() - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequest

popEntry() - Static method in class org.xbib.elasticsearch.common.io.stream.CachedStreamOutput

position() - Method in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

presence(Presence, String, Channel) - Method in interface org.xbib.elasticsearch.http.WebSocketServerAdapter

Emit a presence event.

presence(Presence, String, Channel) - Method in class org.xbib.elasticsearch.websocket.InteractiveController

Presence - Enum in org.xbib.elasticsearch.websocket

The presence states of a websocket client

PublishAction - Class in org.xbib.elasticsearch.action.websocket.pubsub

Publish action

PublishAction(Settings, Client, HttpServerTransport, InteractiveController, Checkpointer) - Constructor for class org.xbib.elasticsearch.action.websocket.pubsub.PublishAction

PublishSubscribe - Class in org.xbib.elasticsearch.action.websocket.pubsub

Base class for Publish/Subscribe actions

PublishSubscribe(Settings, Client, HttpServerTransport, InteractiveController, Checkpointer) - Constructor for class org.xbib.elasticsearch.action.websocket.pubsub.PublishSubscribe

pubSubIndexName - Variable in class org.xbib.elasticsearch.action.websocket.pubsub.PublishSubscribe

PubSubIndexName - Annotation Type in org.xbib.elasticsearch.action.websocket.pubsub

Configuration for the pubsub index name.

PubSubIndexName.Conf - Class in org.xbib.elasticsearch.action.websocket.pubsub

PubSubIndexName.Conf() - Constructor for class org.xbib.elasticsearch.action.websocket.pubsub.PubSubIndexName.Conf

pushEntry(CachedStreamOutput.Entry) - Static method in class org.xbib.elasticsearch.common.io.stream.CachedStreamOutput

R

rawPath() - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequest

read() - Method in class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInput

read(byte[], int, int) - Method in class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInput

readByte() - Method in class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInput

readBytes(byte[], int, int) - Method in class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInput

readBytesReference(int) - Method in class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInput

readFrom(StreamInput) - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfo

readFrom(StreamInput) - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoRequest

readFrom(StreamInput) - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoResponse

readFrom(StreamInput) - Method in class org.xbib.elasticsearch.http.HttpInfo

readFrom(StreamInput) - Method in class org.xbib.elasticsearch.http.HttpStats

readHttpInfo(StreamInput) - Static method in class org.xbib.elasticsearch.http.HttpInfo

readHttpStats(StreamInput) - Static method in class org.xbib.elasticsearch.http.HttpStats

readInfo(StreamInput) - Static method in class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfo

registerHandler(String, String, RestHandler) - Method in class org.xbib.elasticsearch.rest.HttpPatchRestController

registerHandler(String, InteractiveHandler) - Method in class org.xbib.elasticsearch.websocket.InteractiveController

ReleasableBytesReference - Interface in org.xbib.elasticsearch.common.bytes

ReleasableBytesStream - Interface in org.xbib.elasticsearch.common.io

A bytes stream that requires its bytes to be released once no longer used.

ReleasableBytesStreamOutput - Class in org.xbib.elasticsearch.common.io.stream

ReleasableBytesStreamOutput(BigArrays) - Constructor for class org.xbib.elasticsearch.common.io.stream.ReleasableBytesStreamOutput

ReleasableBytesStreamOutput(int, BigArrays) - Constructor for class org.xbib.elasticsearch.common.io.stream.ReleasableBytesStreamOutput

ReleasablePagedBytesReference - Class in org.xbib.elasticsearch.common.bytes

An extension to PagedBytesReference that requires releasing its content.

ReleasablePagedBytesReference(BigArrays, ByteArray, int) - Constructor for class org.xbib.elasticsearch.common.bytes.ReleasablePagedBytesReference

ReleasablePagedBytesReference(BigArrays, ByteArray, int, int) - Constructor for class org.xbib.elasticsearch.common.bytes.ReleasablePagedBytesReference

ReleaseChannelFutureListener - Class in org.xbib.elasticsearch.common.netty

ReleaseChannelFutureListener(Releasable) - Constructor for class org.xbib.elasticsearch.common.netty.ReleaseChannelFutureListener

request() - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequest

reset() - Method in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

reset() - Method in class org.xbib.elasticsearch.common.io.stream.CachedStreamOutput.Entry

reset() - Method in class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInput

response() - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveResponse

The response frame with content, ready for writing to a Channel

response() - Method in interface org.xbib.elasticsearch.websocket.InteractiveResponse

restContentBuilder(RestRequest) - Static method in class org.xbib.elasticsearch.rest.RestXContentBuilder

RestPublishAction - Class in org.xbib.elasticsearch.rest.action.websocket

Publish action for REST

RestPublishAction(Settings, Client, RestController, HttpServerTransport, Checkpointer) - Constructor for class org.xbib.elasticsearch.rest.action.websocket.RestPublishAction

RestUnsubscribeAction - Class in org.xbib.elasticsearch.rest.action.websocket

Unsubscribe action for REST

RestUnsubscribeAction(Settings, Client, RestController) - Constructor for class org.xbib.elasticsearch.rest.action.websocket.RestUnsubscribeAction

RestXContentBuilder - Class in org.xbib.elasticsearch.rest

RestXContentBuilder() - Constructor for class org.xbib.elasticsearch.rest.RestXContentBuilder

S

scrollSize - Variable in class org.xbib.elasticsearch.action.websocket.pubsub.PublishSubscribe

scrollTimeout - Variable in class org.xbib.elasticsearch.action.websocket.pubsub.PublishSubscribe

seek(long) - Method in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

seekPositionSupported() - Method in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

send(WebSocketClient) - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketBulkRequest

send(WebSocketFrame) - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientHandler

send(WebSocketClient) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

send(Frame) - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClient

Send data to server

send(WebSocketClient) - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClientBulkRequest

send(WebSocketClient) - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClientRequest

sendRequest(DiscoveryNode, long, String, TransportRequest, TransportRequestOptions) - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

sendResponse(RestResponse) - Method in class org.xbib.elasticsearch.http.netty.NettyHttpChannel

sendResponse(InteractiveResponse) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveChannel

sendResponse(String, Throwable) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveChannel

sendResponse(String, XContentBuilder) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveChannel

sendResponse(TransportResponse) - Method in class org.xbib.elasticsearch.transport.netty.NettyTransportChannel

sendResponse(TransportResponse, TransportResponseOptions) - Method in class org.xbib.elasticsearch.transport.netty.NettyTransportChannel

sendResponse(Throwable) - Method in class org.xbib.elasticsearch.transport.netty.NettyTransportChannel

sendResponse(InteractiveResponse) - Method in interface org.xbib.elasticsearch.websocket.InteractiveChannel

sendResponse(String, Throwable) - Method in interface org.xbib.elasticsearch.websocket.InteractiveChannel

sendResponse(String, XContentBuilder) - Method in interface org.xbib.elasticsearch.websocket.InteractiveChannel

serverOpen() - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

serverOpenChannels - Variable in class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransport

serverTransport - Variable in class org.xbib.elasticsearch.http.netty.NettyHttpRequestHandler

service - Variable in class org.xbib.elasticsearch.action.websocket.pubsub.PublishSubscribe

services() - Method in class org.xbib.elasticsearch.plugin.websocket.WebSocketPlugin

setBulkActions(int) - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler.Builder

Sets when to flush a new bulk request based on the number of actions currently added.

setConcurrentRequests(int) - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler.Builder

Sets the number of concurrent requests allowed to be executed.

setFlushInterval(TimeValue) - Method in class org.xbib.elasticsearch.action.websocket.bulk.BulkHandler.Builder

Sets a flush interval flushing *any* bulk actions pending if the interval passes.

settings() - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransport

settings() - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

setup() - Static method in class org.xbib.elasticsearch.common.netty.NettyStaticSetup

shutdown() - Method in class org.xbib.elasticsearch.http.netty.client.NettyWebSocketClientFactory

shutdown() - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClientFactory

size() - Method in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

Returns the current size of the buffer.

SizeHeaderFrameDecoder - Class in org.xbib.elasticsearch.transport.netty

SizeHeaderFrameDecoder() - Constructor for class org.xbib.elasticsearch.transport.netty.SizeHeaderFrameDecoder

skip(int) - Method in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

skip(long) - Method in class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInput

skipBytes(int) - Method in class org.xbib.elasticsearch.transport.netty.ChannelBufferStreamInput

slice(int, int) - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

slice(int, int) - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

Slice the bytes from the from index up to length.

slice(int, int) - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

slice(int, int) - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

spawnModules() - Method in class org.xbib.elasticsearch.http.HttpServerModule

stats() - Method in class org.xbib.elasticsearch.http.HttpServer

stats() - Method in interface org.xbib.elasticsearch.http.HttpServerTransport

Get HTTP statistics

stats() - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransport

streamInput() - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

streamInput() - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

A stream input of the bytes.

streamInput() - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

streamInput() - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

SubscribeAction - Class in org.xbib.elasticsearch.action.websocket.pubsub

Subscribe action.

SubscribeAction(Settings, Client, HttpServerTransport, InteractiveController, Checkpointer) - Constructor for class org.xbib.elasticsearch.action.websocket.pubsub.SubscribeAction

T

toBytes() - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

toBytes() - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

Returns the bytes as a single byte array.

toBytes() - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

toBytes() - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

toBytesArray() - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

toBytesArray() - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

Returns the bytes as a byte array, possibly sharing the underlying byte buffer.

toBytesArray() - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

toBytesArray() - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

toBytesRef() - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

toBytesRef() - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

Converts to Lucene BytesRef.

toBytesRef() - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

toBytesRef() - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

toChannelBuffer() - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

toChannelBuffer() - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

Returns the bytes as a channel buffer.

toChannelBuffer() - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

toChannelBuffer() - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

toString() - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoResponse

totalChannels() - Method in class org.xbib.elasticsearch.common.netty.OpenChannelsHandler

toUtf8() - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

toUtf8() - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

Converts to a string based on utf8.

toUtf8() - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

toUtf8() - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

toXContent(XContentBuilder, ToXContent.Params) - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoResponse

toXContent(XContentBuilder, ToXContent.Params) - Method in class org.xbib.elasticsearch.http.HttpInfo

toXContent(XContentBuilder, ToXContent.Params) - Method in class org.xbib.elasticsearch.http.HttpStats

transport - Variable in class org.xbib.elasticsearch.action.websocket.pubsub.PublishSubscribe

transport - Variable in class org.xbib.elasticsearch.http.netty.NettyHttpServerPipelineFactory

transportServiceAdapter(TransportServiceAdapter) - Method in class org.xbib.elasticsearch.transport.netty.NettyTransport

TransportWebsocketInfoAction - Class in org.xbib.elasticsearch.action.cluster.admin.websocket

TransportWebsocketInfoAction(Settings, ClusterName, ThreadPool, ClusterService, TransportService, Discovery, HttpServer) - Constructor for class org.xbib.elasticsearch.action.cluster.admin.websocket.TransportWebsocketInfoAction

TYPE - Static variable in class org.xbib.elasticsearch.action.websocket.pubsub.PublishAction

TYPE - Static variable in class org.xbib.elasticsearch.action.websocket.pubsub.SubscribeAction

type - Variable in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

type(String) - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveRequest

type() - Method in class org.xbib.elasticsearch.http.netty.NettyInteractiveResponse

type(String) - Method in interface org.xbib.elasticsearch.websocket.client.WebSocketClientRequest

type() - Method in interface org.xbib.elasticsearch.websocket.InteractiveResponse

U

UnsubscribeAction - Class in org.xbib.elasticsearch.action.websocket.pubsub

Unsubscribe action.

UnsubscribeAction(Settings, Client, InteractiveController) - Constructor for class org.xbib.elasticsearch.action.websocket.pubsub.UnsubscribeAction

uri() - Method in class org.xbib.elasticsearch.http.netty.NettyHttpRequest

utf8StreamWriter() - Static method in class org.xbib.elasticsearch.common.io.stream.CachedStreamOutput

V

valueOf(String) - Static method in enum org.xbib.elasticsearch.websocket.Presence

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.xbib.elasticsearch.websocket.Presence

Returns an array containing the constants of this enum type, in the order they are declared.

W

WebSocketActionListener<C extends WebSocketClient,F extends org.jboss.netty.handler.codec.http.websocketx.WebSocketFrame> - Interface in org.xbib.elasticsearch.websocket.client

Listening to WebSocket actions.

WebSocketActionListener.Adapter - Class in org.xbib.elasticsearch.websocket.client

WebSocketActionListener.Adapter() - Constructor for class org.xbib.elasticsearch.websocket.client.WebSocketActionListener.Adapter

WebSocketClient<F extends org.jboss.netty.channel.ChannelFuture,Frame extends org.jboss.netty.handler.codec.http.websocketx.WebSocketFrame> - Interface in org.xbib.elasticsearch.websocket.client

A WebSocket client.

WebSocketClientBulkRequest - Interface in org.xbib.elasticsearch.websocket.client

WebSocketClientFactory - Interface in org.xbib.elasticsearch.websocket.client

A WebSocketClientFactory has methods for creating WebSocket clients and for creating WebSocket requests.

WebSocketClientRequest - Interface in org.xbib.elasticsearch.websocket.client

WebsocketInfo - Class in org.xbib.elasticsearch.action.cluster.admin.websocket

WebsocketInfo(DiscoveryNode, InetSocketTransportAddress) - Constructor for class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfo

WebsocketInfoAction - Class in org.xbib.elasticsearch.action.cluster.admin.websocket

WebsocketInfoRequest - Class in org.xbib.elasticsearch.action.cluster.admin.websocket

WebsocketInfoRequest() - Constructor for class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoRequest

WebsocketInfoRequest(String...) - Constructor for class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoRequest

WebsocketInfoRequestBuilder - Class in org.xbib.elasticsearch.action.cluster.admin.websocket

WebsocketInfoRequestBuilder(ClusterAdminClient) - Constructor for class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoRequestBuilder

WebsocketInfoResponse - Class in org.xbib.elasticsearch.action.cluster.admin.websocket

WebsocketInfoResponse() - Constructor for class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoResponse

WebsocketInfoResponse(ClusterName, List<WebsocketInfo>) - Constructor for class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoResponse

WebSocketModule - Class in org.xbib.elasticsearch.plugin.websocket

WebSocketModule(Settings) - Constructor for class org.xbib.elasticsearch.plugin.websocket.WebSocketModule

WebSocketPlugin - Class in org.xbib.elasticsearch.plugin.websocket

Websocket plugin

WebSocketPlugin(Settings) - Constructor for class org.xbib.elasticsearch.plugin.websocket.WebSocketPlugin

webSocketServerAdapter(WebSocketServerAdapter) - Method in interface org.xbib.elasticsearch.http.HttpServerTransport

Set WebSocket server adapter

webSocketServerAdapter(WebSocketServerAdapter) - Method in class org.xbib.elasticsearch.http.netty.NettyWebSocketServerTransport

WebSocketServerAdapter - Interface in org.xbib.elasticsearch.http

WebSocket server adapter

writeByte(byte) - Method in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

writeBytes(byte[], int, int) - Method in class org.xbib.elasticsearch.common.io.stream.BytesStreamOutput

writeHeader(ChannelBuffer, long, byte, Version) - Static method in class org.xbib.elasticsearch.transport.netty.NettyHeader

writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoRequest

writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.action.cluster.admin.websocket.WebsocketInfoResponse

writeTo(OutputStream) - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

writeTo(GatheringByteChannel) - Method in class org.xbib.elasticsearch.common.bytes.BytesArray

writeTo(OutputStream) - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

Writes the bytes directly to the output stream.

writeTo(GatheringByteChannel) - Method in interface org.xbib.elasticsearch.common.bytes.BytesReference

Writes the bytes directly to the channel.

writeTo(OutputStream) - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

writeTo(GatheringByteChannel) - Method in class org.xbib.elasticsearch.common.bytes.ChannelBufferBytesReference

writeTo(OutputStream) - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

writeTo(GatheringByteChannel) - Method in class org.xbib.elasticsearch.common.bytes.PagedBytesReference

writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.http.HttpInfo

writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.http.HttpStats

X

XContentRestResponse - Class in org.xbib.elasticsearch.rest

XContentRestResponse(RestRequest, RestStatus, XContentBuilder) - Constructor for class org.xbib.elasticsearch.rest.XContentRestResponse

XContentThrowableRestResponse - Class in org.xbib.elasticsearch.rest

XContentThrowableRestResponse(RestRequest, Throwable) - Constructor for class org.xbib.elasticsearch.rest.XContentThrowableRestResponse

XContentThrowableRestResponse(RestRequest, RestStatus, Throwable) - Constructor for class org.xbib.elasticsearch.rest.XContentThrowableRestResponse

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