Modifier and Type | Method and Description |
---|---|
protected AbstractEndpoint |
AbstractGenericHandler.endpoint()
The parent endpoint.
|
Constructor and Description |
---|
AbstractGenericHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
boolean isTransient)
Creates a new
AbstractGenericHandler with the default queue. |
AbstractGenericHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
Queue<REQUEST> queue,
boolean isTransient)
Creates a new
AbstractGenericHandler with a custom queue. |
Modifier and Type | Class and Description |
---|---|
class |
ConfigEndpoint |
Constructor and Description |
---|
ConfigHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
boolean isTransient)
Creates a new
ConfigHandler with the default queue for requests. |
Modifier and Type | Class and Description |
---|---|
class |
DCPEndpoint
This endpoint defines the pipeline for DCP requests and responses.
|
Constructor and Description |
---|
DCPHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
boolean isTransient)
Creates a new
DCPHandler with the default queue for requests. |
DCPHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
Queue<DCPRequest> queue,
boolean isTransient)
Creates a new
DCPHandler with a custom queue for requests (suitable for tests). |
Modifier and Type | Class and Description |
---|---|
class |
KeyValueEndpoint
This endpoint defines the pipeline for binary requests and responses.
|
Constructor and Description |
---|
KeyValueHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
boolean isTransient)
Creates a new
KeyValueHandler with the default queue for requests. |
Modifier and Type | Class and Description |
---|---|
class |
QueryEndpoint
This endpoint defines the pipeline for query requests and responses (N1QL).
|
Constructor and Description |
---|
QueryHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
boolean isTransient)
Creates a new
QueryHandler with the default queue for requests. |
Modifier and Type | Class and Description |
---|---|
class |
ViewEndpoint
This endpoint defines the pipeline for binary requests and responses.
|
Constructor and Description |
---|
ViewHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
boolean isTransient)
Creates a new
ViewHandler with the default queue for requests. |
Copyright © 2016 Couchbase, Inc.. All rights reserved.