Package | Description |
---|---|
org.forgerock.opendj.ldap |
Classes and interfaces for core types including connections, entries, and
attributes.
|
org.forgerock.opendj.ldap.messages |
Classes and interfaces for core LDAP requests/responses.
|
org.forgerock.opendj.ldif |
Classes and interfaces for reading and writing LDIF.
|
org.forgerock.opendj.server.core |
Classes implementing a Grizzly based
ConnectionHandler using reactive api. |
org.opends.server.api |
Contains a number of API declarations for use throughout the
Directory Server.
|
org.opends.server.authorization.policy |
Contains the policy based access control handler implementation.
|
org.opends.server.backends |
Contains various Directory Server backend implementations.
|
org.opends.server.loggers |
Contains implementations of Directory Server access, error, and debug loggers.
|
org.opends.server.protocols |
Contains various Directory Server connection handler implementations which will be used to accept connections from
and perform communication with clients over various protocols.
|
org.opends.server.protocols.jmx |
Contains the implementation for the Directory Server connection handler that is responsible for interacting with
clients using JMX.
|
org.opends.server.protocols.ldap |
Contains the implementation for the Directory Server connection handler that is responsible for interacting with
clients using LDAPv3.
|
Modifier and Type | Method and Description |
---|---|
Flowable<Response> |
MemoryBackend.handleRequest(int msgId,
Request request)
Returns a
Flowable which, when subscribed, will apply the provided request to this memory
backend. |
Flowable<Response> |
MemoryBackend.handleRequest(Request request)
Returns a
Flowable which, when subscribed, will apply the provided request to this memory
backend. |
default Flowable<Response> |
LdapClientSocket.send(Request request)
Sends a request to the Directory Server.
|
Flowable<Response> |
LdapClientSocket.send(Request request,
RequestHandle handle)
Sends a request to the Directory Server.
|
Modifier and Type | Method and Description |
---|---|
static Connection |
Connections.newInternalConnection(BiFunction<Integer,Request,Flowable<Response>> requestHandler)
Creates a new
Connection which will route requests to the provided requestHandler . |
static ConnectionFactory |
Connections.newInternalConnectionFactory(BiFunction<Integer,Request,Flowable<Response>> requestHandler)
Creates a new
ConnectionFactory which will route requests to the provided requestHandler . |
static LdapClient |
LdapClients.newInternalLdapClient(BiFunction<Integer,Request,Flowable<Response>> requestHandler)
Creates a new
LdapClient which will route requests to the provided requestHandler . |
static LdapClientSocket |
LdapClients.newInternalLdapClientSocket(BiFunction<Integer,Request,Flowable<Response>> requestHandler)
Creates a new
LdapClientSocket which will route requests to the provided requestHandler . |
Constructor and Description |
---|
LdapServer(int port,
Function<LdapSession,BiFunction<Integer,Request,Flowable<Response>>> factory)
Creates a new LDAP listener implementation which will listen for LDAP
client connections at the provided address.
|
LdapServer(int port,
Function<LdapSession,BiFunction<Integer,Request,Flowable<Response>>> factory,
Options options)
Creates a new LDAP listener implementation which will listen for LDAP
client connections at the provided address.
|
LdapServer(Set<InetSocketAddress> addresses,
Function<LdapSession,BiFunction<Integer,Request,Flowable<Response>>> factory)
Creates a new LDAP listener implementation which will listen for LDAP
client connections at the provided address.
|
LdapServer(Set<InetSocketAddress> addresses,
Function<LdapSession,BiFunction<Integer,Request,Flowable<Response>>> factory,
Options options)
Creates a new LDAP listener implementation which will listen for LDAP
client connections at the provided address.
|
LdapServer(String host,
int port,
Function<LdapSession,BiFunction<Integer,Request,Flowable<Response>>> factory)
Creates a new LDAP listener implementation which will listen for LDAP
client connections at the provided address.
|
LdapServer(String host,
int port,
Function<LdapSession,BiFunction<Integer,Request,Flowable<Response>>> factory,
Options options)
Creates a new LDAP listener implementation which will listen for LDAP
client connections at the provided address.
|
Modifier and Type | Interface and Description |
---|---|
interface |
BindResult
A Bind result indicates the status of the client's request for
authentication.
|
interface |
CompareResult
An Compare result indicates the final status of an Compare operation.
|
interface |
ExtendedResult
A Extended result indicates the status of an Extended operation and any
additional information associated with the Extended operation, including the
optional response name and value.
|
interface |
GenericExtendedResult
A Generic Extended result indicates the final status of an Generic Extended
operation.
|
interface |
GenericIntermediateResponse
A Generic Intermediate response provides a mechanism for communicating
unrecognized or unsupported Intermediate responses to the client.
|
interface |
IntermediateResponse
An Intermediate response provides a general mechanism for defining
single-request/multiple-response operations.
|
interface |
PasswordModifyExtendedResult
The password modify extended result as defined in RFC 3062.
|
interface |
Result
A Result is used to indicate the status of an operation performed by the
server.
|
interface |
SearchResultEntry
A Search Result Entry represents an entry found during a Search operation.
|
interface |
SearchResultReference
A Search Result Reference represents an area not yet explored during a Search
operation.
|
interface |
StartTlsExtendedResult
The start tls extended result as defined in RFC 4511.
|
interface |
WhoAmIExtendedResult
The who am I extended result as defined in RFC 4532.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractExtendedResult<S extends ExtendedResult>
An abstract Extended result which can be used as the basis for implementing
new Extended operations.
|
class |
AbstractIntermediateResponse<S extends IntermediateResponse>
An abstract Intermediate response which can be used as the basis for
implementing new Intermediate responses.
|
Modifier and Type | Method and Description |
---|---|
Response |
Response.addControl(Control control) |
Response |
Response.addControls(Iterable<? extends Control> control) |
Modifier and Type | Method and Description |
---|---|
static LdapMessage |
LdapMessage.newResponseMessage(int messageId,
Request forRequest,
Response response)
Builds and returns an
LdapMessage containing a Response . |
Constructor and Description |
---|
ConnectionEntryReader(Connection connection,
SearchRequest searchRequest,
BlockingQueue<Response> entries)
Creates a new connection entry reader whose destination is the provided
connection.
|
Modifier and Type | Method and Description |
---|---|
Flowable<Response> |
AddBinaryOptionReactiveFilter.filter(org.forgerock.services.context.Context context,
Request request,
RequestHandler next) |
FlowableOperator<Response,Response> |
RequestContext.getCancellationOperator()
Returns a probe monitoring the response sent to the client in order to maintain the cancellation state.
|
FlowableOperator<Response,Response> |
RequestContext.getCancellationOperator()
Returns a probe monitoring the response sent to the client in order to maintain the cancellation state.
|
Flowable<Response> |
Router.handle(org.forgerock.services.context.Context context,
Request request) |
Modifier and Type | Method and Description |
---|---|
Flowable<Response> |
TypedRequestFilter.filter(org.forgerock.services.context.Context context,
Request request,
RequestHandler next) |
Flowable<Response> |
TypedProtocolOpFilter.filter(org.forgerock.services.context.Context context,
Request request,
RequestHandler next) |
Flowable<Response> |
RequestFilterChain.filter(org.forgerock.services.context.Context context,
Request request,
RequestHandler next) |
Flowable<Response> |
RequestFilter.filter(org.forgerock.services.context.Context context,
Request request,
RequestHandler next)
Filters the request and/or response of an exchange.
|
Flowable<Response> |
ClientSideResultCodeRequestFilter.filter(org.forgerock.services.context.Context context,
Request request,
RequestHandler next) |
protected Flowable<Response> |
TypedRequestFilter.filterAbandon(org.forgerock.services.context.Context context,
AbandonRequest request,
RequestHandler next)
Filters abandon requests and their responses.
|
protected Flowable<Response> |
TypedProtocolOpFilter.filterAbandon(org.forgerock.services.context.Context context,
AbandonRequest request,
RequestHandler next)
Forwards the request to the next handler in the chain.
|
protected Flowable<Response> |
TypedRequestFilter.filterAdd(org.forgerock.services.context.Context context,
AddRequest request,
RequestHandler next)
Filters add requests and their responses.
|
protected Flowable<Response> |
TypedProtocolOpFilter.filterAdd(org.forgerock.services.context.Context context,
AddRequest request,
RequestHandler next)
Forwards the request to the next handler in the chain.
|
protected Flowable<Response> |
TypedRequestFilter.filterAny(org.forgerock.services.context.Context context,
Request request,
RequestHandler next)
Filters requests and their responses.
|
protected Flowable<Response> |
TypedProtocolOpFilter.filterAny(org.forgerock.services.context.Context context,
Request request,
RequestHandler next)
Forwards the request to the next handler in the chain.
|
protected Flowable<Response> |
TypedRequestFilter.filterBind(org.forgerock.services.context.Context context,
BindRequest request,
RequestHandler next)
Filters bind requests and their responses.
|
protected Flowable<Response> |
TypedProtocolOpFilter.filterBind(org.forgerock.services.context.Context context,
BindRequest request,
RequestHandler next)
Forwards the request to the next handler in the chain.
|
protected Flowable<Response> |
TypedRequestFilter.filterCompare(org.forgerock.services.context.Context context,
CompareRequest request,
RequestHandler next)
Filters compare requests and their responses.
|
protected Flowable<Response> |
TypedProtocolOpFilter.filterCompare(org.forgerock.services.context.Context context,
CompareRequest request,
RequestHandler next)
Forwards the request to the next handler in the chain.
|
protected Flowable<Response> |
TypedRequestFilter.filterDelete(org.forgerock.services.context.Context context,
DeleteRequest request,
RequestHandler next)
Filters delete requests and their responses.
|
protected Flowable<Response> |
TypedProtocolOpFilter.filterDelete(org.forgerock.services.context.Context context,
DeleteRequest request,
RequestHandler next)
Forwards the request to the next handler in the chain.
|
protected Flowable<Response> |
TypedRequestFilter.filterExtended(org.forgerock.services.context.Context context,
ExtendedRequest<?> request,
RequestHandler next)
Filters extended requests and their responses.
|
protected Flowable<Response> |
TypedProtocolOpFilter.filterExtended(org.forgerock.services.context.Context context,
ExtendedRequest<?> request,
RequestHandler next)
Forwards the request to the next handler in the chain.
|
protected Flowable<Response> |
TypedRequestFilter.filterInvalid(org.forgerock.services.context.Context context,
InvalidRequest request,
RequestHandler next)
Filters invalid requests and their responses.
|
protected Flowable<Response> |
TypedProtocolOpFilter.filterInvalid(org.forgerock.services.context.Context context,
InvalidRequest request,
RequestHandler next)
Forwards the request to the next handler in the chain.
|
protected Flowable<Response> |
TypedRequestFilter.filterModify(org.forgerock.services.context.Context context,
ModifyRequest request,
RequestHandler next)
Filters modify requests and their responses.
|
protected Flowable<Response> |
TypedProtocolOpFilter.filterModify(org.forgerock.services.context.Context context,
ModifyRequest request,
RequestHandler next)
Forwards the request to the next handler in the chain.
|
protected Flowable<Response> |
TypedRequestFilter.filterModifyDn(org.forgerock.services.context.Context context,
ModifyDnRequest request,
RequestHandler next)
Filters modify-dn requests and their responses.
|
protected Flowable<Response> |
TypedProtocolOpFilter.filterModifyDn(org.forgerock.services.context.Context context,
ModifyDnRequest request,
RequestHandler next)
Forwards the request to the next handler in the chain.
|
protected Flowable<Response> |
TypedRequestFilter.filterSearch(org.forgerock.services.context.Context context,
SearchRequest request,
RequestHandler next)
Filters search requests and their responses.
|
protected Flowable<Response> |
TypedProtocolOpFilter.filterSearch(org.forgerock.services.context.Context context,
SearchRequest request,
RequestHandler next)
Forwards the request to the next handler in the chain.
|
protected Flowable<Response> |
TypedRequestFilter.filterUnbind(org.forgerock.services.context.Context context,
UnbindRequest request,
RequestHandler next)
Filters unbind requests and their responses.
|
protected Flowable<Response> |
TypedProtocolOpFilter.filterUnbind(org.forgerock.services.context.Context context,
UnbindRequest request,
RequestHandler next)
Forwards the request to the next handler in the chain.
|
protected Flowable<Response> |
TypedRequestFilter.filterUnknown(org.forgerock.services.context.Context context,
UnknownRequest request,
RequestHandler next)
Filters unknown requests and their responses.
|
protected Flowable<Response> |
TypedProtocolOpFilter.filterUnknown(org.forgerock.services.context.Context context,
UnknownRequest request,
RequestHandler next)
Forwards the request to the next handler in the chain.
|
Flowable<Response> |
TypedRequestHandler.handle(org.forgerock.services.context.Context context,
Request request) |
Flowable<Response> |
RequestHandler.handle(org.forgerock.services.context.Context context,
Request request)
|
Flowable<Response> |
LocalBackend.handle(org.forgerock.services.context.Context context,
Request request)
Processes the provided request in a reactive way within this backend.
|
protected Flowable<Response> |
TypedRequestHandler.handleAbandon(org.forgerock.services.context.Context context,
AbandonRequest request)
Implements the specific behavior for all AbandonRequest.
|
protected Flowable<Response> |
TypedRequestHandler.handleAdd(org.forgerock.services.context.Context context,
AddRequest request)
Implements the specific behavior for all AddRequest.
|
protected Flowable<Response> |
TypedRequestHandler.handleAny(org.forgerock.services.context.Context context,
Request request)
Implements the common behavior for all the request types.
|
protected Flowable<Response> |
TypedRequestHandler.handleBind(org.forgerock.services.context.Context context,
BindRequest request)
Implements the specific behavior for all BindRequest.
|
protected Flowable<Response> |
TypedRequestHandler.handleCompare(org.forgerock.services.context.Context context,
CompareRequest request)
Implements the specific behavior for all CompareRequest.
|
protected Flowable<Response> |
TypedRequestHandler.handleDelete(org.forgerock.services.context.Context context,
DeleteRequest request)
Implements the specific behavior for all DeleteRequest.
|
protected Flowable<Response> |
TypedRequestHandler.handleExtended(org.forgerock.services.context.Context context,
ExtendedRequest<?> request)
Implements the specific behavior for all ExtendedRequest.
|
protected Flowable<Response> |
TypedRequestHandler.handleInvalid(org.forgerock.services.context.Context context,
InvalidRequest request)
Implements the specific behavior for all InvalidRequest.
|
protected Flowable<Response> |
TypedRequestHandler.handleModify(org.forgerock.services.context.Context context,
ModifyRequest request)
Implements the specific behavior for all ModifyRequest.
|
protected Flowable<Response> |
TypedRequestHandler.handleModifyDn(org.forgerock.services.context.Context context,
ModifyDnRequest request)
Implements the specific behavior for all ModifyDnRequest.
|
protected Flowable<Response> |
TypedRequestHandler.handleSearch(org.forgerock.services.context.Context context,
SearchRequest request)
Implements the specific behavior for all SearchRequest.
|
protected Flowable<Response> |
TypedRequestHandler.handleUnbind(org.forgerock.services.context.Context context,
UnbindRequest request)
Implements the specific behavior for all UnbindRequest.
|
protected Flowable<Response> |
TypedRequestHandler.handleUnknown(org.forgerock.services.context.Context context,
UnknownRequest request)
Implements the specific behavior for all UnknownRequest.
|
Flowable<Response> |
TypedRequestHandler.visitRequest(org.forgerock.services.context.Context context,
AbandonRequest request) |
Flowable<Response> |
TypedRequestHandler.visitRequest(org.forgerock.services.context.Context context,
AddRequest request) |
Flowable<Response> |
TypedRequestHandler.visitRequest(org.forgerock.services.context.Context context,
BindRequest request) |
Flowable<Response> |
TypedRequestHandler.visitRequest(org.forgerock.services.context.Context context,
CompareRequest request) |
Flowable<Response> |
TypedRequestHandler.visitRequest(org.forgerock.services.context.Context context,
DeleteRequest request) |
Flowable<Response> |
TypedRequestHandler.visitRequest(org.forgerock.services.context.Context context,
ExtendedRequest<?> request) |
Flowable<Response> |
TypedRequestHandler.visitRequest(org.forgerock.services.context.Context context,
InvalidRequest request) |
Flowable<Response> |
TypedRequestHandler.visitRequest(org.forgerock.services.context.Context context,
ModifyDnRequest request) |
Flowable<Response> |
TypedRequestHandler.visitRequest(org.forgerock.services.context.Context context,
ModifyRequest request) |
Flowable<Response> |
TypedRequestHandler.visitRequest(org.forgerock.services.context.Context context,
SearchRequest request) |
Flowable<Response> |
TypedRequestHandler.visitRequest(org.forgerock.services.context.Context context,
UnbindRequest request) |
Flowable<Response> |
TypedRequestHandler.visitRequest(org.forgerock.services.context.Context context,
UnknownRequest request) |
Modifier and Type | Method and Description |
---|---|
protected void |
TypedProtocolOpFilter.filterAbandonResponse(org.forgerock.services.context.Context context,
AbandonRequest request,
Response response)
Implements the behavior for all the responses of an AbandonRequest.
|
protected void |
TypedProtocolOpFilter.filterAddResponse(org.forgerock.services.context.Context context,
AddRequest request,
Response response)
Implements the behavior for all the responses of an AddRequest.
|
protected void |
TypedProtocolOpFilter.filterAnyResponse(org.forgerock.services.context.Context context,
Request request,
Response response)
Implements the common behavior for all the responses for which no specific behavior has been specified by an
overridden observe*Response() like method.
|
protected void |
TypedProtocolOpFilter.filterBindResponse(org.forgerock.services.context.Context context,
BindRequest request,
Response response)
Implements the behavior for all the responses of a BindRequest.
|
protected void |
TypedProtocolOpFilter.filterCompareResponse(org.forgerock.services.context.Context context,
CompareRequest request,
Response response)
Implements the behavior for all the responses of a CompareRequest.
|
protected void |
TypedProtocolOpFilter.filterDeleteResponse(org.forgerock.services.context.Context context,
DeleteRequest request,
Response response)
Implements the behavior for all the responses of a DeleteRequest.
|
protected void |
TypedProtocolOpFilter.filterExtendedResponse(org.forgerock.services.context.Context context,
ExtendedRequest<?> request,
Response response)
Implements the behavior for all the responses of a ExtendedRequest.
|
protected void |
TypedProtocolOpFilter.filterInvalidResponse(org.forgerock.services.context.Context context,
InvalidRequest request,
Response response)
Implements the behavior for all the responses of an InvalidRequest.
|
protected void |
TypedProtocolOpFilter.filterModifyDnResponse(org.forgerock.services.context.Context context,
ModifyDnRequest request,
Response response)
Implements the behavior for all the responses of a ModifyDnRequest.
|
protected void |
TypedProtocolOpFilter.filterModifyResponse(org.forgerock.services.context.Context context,
ModifyRequest request,
Response response)
Implements the behavior for all the responses of a ModifyRequest.
|
protected boolean |
TypedProtocolOpFilter.filterSearchResponse(org.forgerock.services.context.Context context,
SearchRequest request,
Response response)
Implements the behavior for all the responses of a SearchRequest.
|
protected void |
TypedProtocolOpFilter.filterUnknownResponse(org.forgerock.services.context.Context context,
UnknownRequest request,
Response response)
Implements the behavior for all the responses of an UnknownRequest.
|
Modifier and Type | Method and Description |
---|---|
Flowable<Response> |
PolicyBasedAccessControlHandler.filter(org.forgerock.services.context.Context context,
Request request,
RequestHandler next) |
Modifier and Type | Method and Description |
---|---|
Flowable<Response> |
ProxyBackend.handle(org.forgerock.services.context.Context context,
Request request) |
Modifier and Type | Method and Description |
---|---|
Flowable<Response> |
ReactiveFilterAccessLog.filter(org.forgerock.services.context.Context context,
Request request,
RequestHandler next) |
Modifier and Type | Method and Description |
---|---|
static FlowableEmitter<Response> |
ReactiveHandlersUtils.getFlowableEmitter(Operation operation)
Returns the reactive emitter attached to the provided operation.
|
Modifier and Type | Method and Description |
---|---|
static byte |
ReactiveHandlersUtils.toLdapResponseType(Request request,
Response response)
Returns the LDAP response type to use for the provided request and response.
|
Modifier and Type | Method and Description |
---|---|
static void |
ReactiveHandlersUtils.addAttachmentsToOperation(Operation op,
Request request,
FlowableEmitter<Response> out)
Add to operation the attachments needed for correct behavior of the reactive handlers.
|
static void |
ReactiveHandlersUtils.emitResult(Result result,
FlowableEmitter<Response> out)
Emits a result to the provided reactive emitter, to signal completion of a request.
|
Modifier and Type | Method and Description |
---|---|
Flowable<Response> |
JmxClientConnection.handle(org.forgerock.services.context.Context context,
Request request)
Processes the provided request in a reactive way, which should be either a
BindRequest or a
SearchRequest . |
Modifier and Type | Method and Description |
---|---|
Flowable<Response> |
LdapStatisticsFilter.filter(org.forgerock.services.context.Context context,
Request request,
RequestHandler next) |
Flowable<Response> |
LdapClientConnection.handle(org.forgerock.services.context.Context context,
Request request)
Processes the provided request in a reactive way.
|
Copyright 2010-2022 ForgeRock AS.