Package com.couchbase.client.core.endpoint

Class QueryEndpoint

java.lang.Object

com.couchbase.client.core.endpoint.BaseEndpoint

com.couchbase.client.core.endpoint.QueryEndpoint

All Implemented Interfaces:

Endpoint, Stateful<EndpointState>

public class QueryEndpoint
extends BaseEndpoint

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	QueryEndpoint.QueryPipelineInitializer

Constructor Summary

Constructors

Constructor	Description
QueryEndpoint(ServiceContext ctx, String hostname, int port)

Method Summary

Modifier and Type	Method	Description
void	disconnect()	Instruct this Endpoint to disconnect.
void	markRequestCompletion()	Called from the event loop handlers to mark a request as being completed.
void	notifyChannelInactive()	This method is called from inside the channel to tell the endpoint hat it got inactive.
protected PipelineInitializer	pipelineInitializer()	Returns the initialize which adds endpoint-specific handlers to the pipeline.

Methods inherited from class com.couchbase.client.core.endpoint.BaseEndpoint

channelFrom, channelFutureIntoMono, connect, context, decrementOutstandingRequests, diagnostics, freeToWrite, internalDiagnostics, lastConnectAttemptFailure, lastConnectedAt, lastResponseReceived, outstandingRequests, pipelined, receivedDisconnectSignal, remoteAddress, remoteHostname, remotePort, send, state, states

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

QueryEndpoint

public QueryEndpoint(ServiceContext ctx,
 String hostname,
 int port)

Method Details

pipelineInitializer

protected PipelineInitializer pipelineInitializer()

Description copied from class: BaseEndpoint

Returns the initialize which adds endpoint-specific handlers to the pipeline.

Specified by:

pipelineInitializer in class BaseEndpoint

disconnect

public void disconnect()

Description copied from interface: Endpoint

Instruct this Endpoint to disconnect.

This method is async and will return immediately. Use the other methods available to inspect the current state of the endpoint, signaling potential successful disconnection attempts.

Specified by:

disconnect in interface Endpoint

Overrides:

disconnect in class BaseEndpoint

markRequestCompletion

@Internal
public void markRequestCompletion()

Description copied from class: BaseEndpoint

Called from the event loop handlers to mark a request as being completed.

We need to make this call explicitly from the outside and cannot just listen on the request response callback because with streaming responses the actual completion might happen much later.

Overrides:

markRequestCompletion in class BaseEndpoint

notifyChannelInactive

@Internal
public void notifyChannelInactive()

Description copied from class: BaseEndpoint

This method is called from inside the channel to tell the endpoint hat it got inactive.

The endpoint needs to perform certain steps when the channel is inactive so that it quickly tries to reconnect, as long as it should (i.e. don't do it if already disconnected)

Overrides:

notifyChannelInactive in class BaseEndpoint