Class KeyValueEndpoint
java.lang.Object
com.couchbase.client.core.state.AbstractStateMachine<LifecycleState>
com.couchbase.client.core.endpoint.AbstractEndpoint
com.couchbase.client.core.endpoint.kv.KeyValueEndpoint
- All Implemented Interfaces:
Endpoint
,Stateful<LifecycleState>
public class KeyValueEndpoint extends AbstractEndpoint
This endpoint defines the pipeline for binary requests and responses.
- Since:
- 1.0
- Author:
- Michael Nitschinger
-
Field Summary
Fields inherited from class com.couchbase.client.core.endpoint.AbstractEndpoint
FORCE_DNS_LOOKUP_ON_RECONNECT
-
Constructor Summary
Constructors Constructor Description KeyValueEndpoint(String hostname, String bucket, String password, int port, CoreContext ctx)
Deprecated.KeyValueEndpoint(String hostname, String bucket, String username, String password, int port, CoreContext ctx)
Create a newKeyValueEndpoint
. -
Method Summary
Modifier and Type Method Description protected void
customEndpointHandlers(ChannelPipeline pipeline)
Add custom endpoint handlers to theChannelPipeline
.Methods inherited from class com.couchbase.client.core.endpoint.AbstractEndpoint
bucket, connect, connect, context, diagnostics, disconnect, doConnect, environment, isFree, lastConnectedAt, lastResponse, logIdent, notifyChannelInactive, notifyResponseDecoded, password, remoteAddress, responseBuffer, send, setLastKeepAliveLatency, signalConfigReload, username
Methods inherited from class com.couchbase.client.core.state.AbstractStateMachine
hasSubscribers, isState, state, states, transitionState
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface com.couchbase.client.core.state.Stateful
hasSubscribers, isState, state, states
-
Constructor Details
-
KeyValueEndpoint
@Deprecated public KeyValueEndpoint(String hostname, String bucket, String password, int port, CoreContext ctx)Deprecated.Create a newKeyValueEndpoint
.- Parameters:
hostname
- the hostname to connect on this endpoint.ctx
- the core context used.
-
KeyValueEndpoint
public KeyValueEndpoint(String hostname, String bucket, String username, String password, int port, CoreContext ctx)Create a newKeyValueEndpoint
.- Parameters:
hostname
- the hostname to connect on this endpoint.ctx
- the core context used.
-
-
Method Details
-
customEndpointHandlers
Description copied from class:AbstractEndpoint
Add custom endpoint handlers to theChannelPipeline
. This method needs to be implemented by the actual endpoint implementations to add specific handlers to the pipeline depending on the endpoint type and intended behavior.- Specified by:
customEndpointHandlers
in classAbstractEndpoint
- Parameters:
pipeline
- the pipeline where to add handlers.
-