Package org.bremersee.ldaptive.reactive

Interface ReactiveLdaptiveOperations

All Known Implementing Classes:
ReactiveLdaptiveTemplate
public interface ReactiveLdaptiveOperations
The reactive ldaptive operations.
Author:
Christian Bremer

  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Mono<org.ldaptive.Result>
    add(org.ldaptive.AddRequest addRequest)
    Executes add operation.
    reactor.core.publisher.Mono<Boolean>
    bind(org.ldaptive.BindRequest bindRequest)
    Executes bind operation.
    reactor.core.publisher.Mono<Boolean>
    compare(org.ldaptive.CompareRequest compareRequest)
    Executes compare operation.
    ReactiveLdaptiveOperations
    copy()
    Returns a new instance of this ldap operations with the same connection factory and error handler.
    ReactiveLdaptiveOperations
    copy(LdaptiveErrorHandler errorHandler)
    Returns a new instance of this ldap operations with the same connection factory and the given error handler.
    reactor.core.publisher.Mono<org.ldaptive.Result>
    delete(org.ldaptive.DeleteRequest deleteRequest)
    Executes delete operation.
    reactor.core.publisher.Mono<org.ldaptive.extended.ExtendedResponse>
    executeExtension(org.ldaptive.extended.ExtendedRequest request)
    Executes extended request.
    default reactor.core.publisher.Mono<Boolean>
    exists(String dn)
    Exists.
    default <T> reactor.core.publisher.Mono<Boolean>
    exists(T domainObject, LdaptiveEntryMapper<T> entryMapper)
    Exists.
    reactor.core.publisher.Flux<org.ldaptive.LdapEntry>
    findAll(org.ldaptive.SearchRequest searchRequest)
    Find all.
    default <T> reactor.core.publisher.Flux<T>
    findAll(org.ldaptive.SearchRequest searchRequest, LdaptiveEntryMapper<T> entryMapper)
    Find all.
    reactor.core.publisher.Mono<org.ldaptive.LdapEntry>
    findOne(org.ldaptive.SearchRequest searchRequest)
    Find one.
    default <T> reactor.core.publisher.Mono<T>
    findOne(org.ldaptive.SearchRequest searchRequest, LdaptiveEntryMapper<T> entryMapper)
    Find one.
    default reactor.core.publisher.Mono<String>
    generateUserPassword(String dn)
    Generate user password.
    org.ldaptive.ConnectionFactory
    getConnectionFactory()
    Gets connection factory.
    reactor.core.publisher.Mono<org.ldaptive.Result>
    modify(org.ldaptive.ModifyRequest modifyRequest)
    Executes modify operation.
    reactor.core.publisher.Mono<org.ldaptive.Result>
    modifyDn(org.ldaptive.ModifyDnRequest modifyDnRequest)
    Executes modify DN operation.
    default reactor.core.publisher.Mono<org.ldaptive.extended.ExtendedResponse>
    modifyUserPassword(String dn, String oldPass, String newPass)
    Modify user password.
    default <T> reactor.core.publisher.Mono<org.ldaptive.Result>
    remove(T domainObject, LdaptiveEntryMapper<T> entryMapper)
    Remove.
    default <T> reactor.core.publisher.Mono<Long>
    removeAll(Collection<T> domainObjects, LdaptiveEntryMapper<T> entryMapper)
    Remove all.
    <T> reactor.core.publisher.Mono<T>
    save(T domainObject, LdaptiveEntryMapper<T> entryMapper)
    Save.
    default <T> reactor.core.publisher.Flux<T>
    saveAll(Collection<T> domainObjects, LdaptiveEntryMapper<T> entryMapper)
    Save all.

  • Method Details

    • copy

      ReactiveLdaptiveOperations copy()
      Returns a new instance of this ldap operations with the same connection factory and error handler.
      Returns:
      a new instance of this ldap operations

    • copy

      ReactiveLdaptiveOperations copy(LdaptiveErrorHandler errorHandler)
      Returns a new instance of this ldap operations with the same connection factory and the given error handler.
      Parameters:
      errorHandler - the new error handler
      Returns:
      the new instance of this ldap operations

    • getConnectionFactory

      org.ldaptive.ConnectionFactory getConnectionFactory()
      Gets connection factory.
      Returns:
      the connection factory

    • add

      reactor.core.publisher.Mono<org.ldaptive.Result> add(org.ldaptive.AddRequest addRequest)
      Executes add operation.
      Parameters:
      addRequest - the add request
      Returns:
      the mono

    • bind

      reactor.core.publisher.Mono<Boolean> bind(org.ldaptive.BindRequest bindRequest)
      Executes bind operation.
      Parameters:
      bindRequest - the bind request
      Returns:
      the mono

    • compare

      reactor.core.publisher.Mono<Boolean> compare(org.ldaptive.CompareRequest compareRequest)
      Executes compare operation.
      Parameters:
      compareRequest - the compare request
      Returns:
      the mono

    • delete

      reactor.core.publisher.Mono<org.ldaptive.Result> delete(org.ldaptive.DeleteRequest deleteRequest)
      Executes delete operation.
      Parameters:
      deleteRequest - the delete request
      Returns:
      the mono

    • executeExtension

      reactor.core.publisher.Mono<org.ldaptive.extended.ExtendedResponse> executeExtension(org.ldaptive.extended.ExtendedRequest request)
      Executes extended request.
      Parameters:
      request - the request
      Returns:
      the mono

    • generateUserPassword

      default reactor.core.publisher.Mono<String> generateUserPassword(String dn)
      Generate user password.
      Parameters:
      dn - the dn
      Returns:
      the mono

    • modify

      reactor.core.publisher.Mono<org.ldaptive.Result> modify(org.ldaptive.ModifyRequest modifyRequest)
      Executes modify operation.
      Parameters:
      modifyRequest - the modify request
      Returns:
      the mono

    • modifyDn

      reactor.core.publisher.Mono<org.ldaptive.Result> modifyDn(org.ldaptive.ModifyDnRequest modifyDnRequest)
      Executes modify DN operation.
      Parameters:
      modifyDnRequest - the modify dn request
      Returns:
      the mono

    • modifyUserPassword

      default reactor.core.publisher.Mono<org.ldaptive.extended.ExtendedResponse> modifyUserPassword(String dn, String oldPass, String newPass)
      Modify user password.
      Parameters:
      dn - the dn
      oldPass - the old pass
      newPass - the new pass
      Returns:
      the mono

    • findOne

      reactor.core.publisher.Mono<org.ldaptive.LdapEntry> findOne(org.ldaptive.SearchRequest searchRequest)
      Find one.
      Parameters:
      searchRequest - the search request
      Returns:
      the mono

    • findOne

      default <T> reactor.core.publisher.Mono<T> findOne(org.ldaptive.SearchRequest searchRequest, LdaptiveEntryMapper<T> entryMapper)
      Find one.
      Type Parameters:
      T - the type parameter
      Parameters:
      searchRequest - the search request
      entryMapper - the entry mapper
      Returns:
      the mono

    • findAll

      reactor.core.publisher.Flux<org.ldaptive.LdapEntry> findAll(org.ldaptive.SearchRequest searchRequest)
      Find all.
      Parameters:
      searchRequest - the search request
      Returns:
      the flux

    • findAll

      default <T> reactor.core.publisher.Flux<T> findAll(org.ldaptive.SearchRequest searchRequest, LdaptiveEntryMapper<T> entryMapper)
      Find all.
      Type Parameters:
      T - the type parameter
      Parameters:
      searchRequest - the search request
      entryMapper - the entry mapper
      Returns:
      the flux

    • exists

      default reactor.core.publisher.Mono<Boolean> exists(String dn)
      Exists.
      Parameters:
      dn - the dn
      Returns:
      the mono

    • exists

      default <T> reactor.core.publisher.Mono<Boolean> exists(T domainObject, LdaptiveEntryMapper<T> entryMapper)
      Exists.
      Type Parameters:
      T - the type parameter
      Parameters:
      domainObject - the domain object
      entryMapper - the entry mapper
      Returns:
      the mono

    • save

      <T> reactor.core.publisher.Mono<T> save(T domainObject, LdaptiveEntryMapper<T> entryMapper)
      Save.
      Type Parameters:
      T - the type parameter
      Parameters:
      domainObject - the domain object
      entryMapper - the entry mapper
      Returns:
      the mono

    • saveAll

      default <T> reactor.core.publisher.Flux<T> saveAll(Collection<T> domainObjects, LdaptiveEntryMapper<T> entryMapper)
      Save all.
      Type Parameters:
      T - the type parameter
      Parameters:
      domainObjects - the domain objects
      entryMapper - the entry mapper
      Returns:
      the flux

    • remove

      default <T> reactor.core.publisher.Mono<org.ldaptive.Result> remove(T domainObject, LdaptiveEntryMapper<T> entryMapper)
      Remove.
      Type Parameters:
      T - the type parameter
      Parameters:
      domainObject - the domain object
      entryMapper - the entry mapper
      Returns:
      the mono

    • removeAll

      default <T> reactor.core.publisher.Mono<Long> removeAll(Collection<T> domainObjects, LdaptiveEntryMapper<T> entryMapper)
      Remove all.
      Type Parameters:
      T - the type parameter
      Parameters:
      domainObjects - the domain objects
      entryMapper - the entry mapper
      Returns:
      the mono