Package com.couchbase.client.core.endpoint

Class KeyValueEndpoint

java.lang.Object

com.couchbase.client.core.endpoint.BaseEndpoint

com.couchbase.client.core.endpoint.KeyValueEndpoint

All Implemented Interfaces:

Endpoint, Stateful<EndpointState>

public class KeyValueEndpoint
extends BaseEndpoint

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	KeyValueEndpoint.KeyValuePipelineInitializer

Constructor Summary

Constructors

Constructor	Description
KeyValueEndpoint(ServiceContext ctx, String hostname, int port, Optional<String> bucketname, Authenticator authenticator)

Method Summary

Modifier and Type	Method	Description
protected PipelineInitializer	pipelineInitializer()	Returns the initialize which adds endpoint-specific handlers to the pipeline.

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

channelFutureIntoMono, connect, context, decrementOutstandingRequests, diagnostics, disconnect, freeToWrite, internalDiagnostics, lastConnectAttemptFailure, lastConnectedAt, lastResponseReceived, markRequestCompletion, notifyChannelInactive, 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

KeyValueEndpoint

public KeyValueEndpoint(ServiceContext ctx,
 String hostname,
 int port,
 Optional<String> bucketname,
 Authenticator authenticator)

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