Interface ReactiveLdaptiveOperations
-
- All Known Implementing Classes:
ReactiveLdaptiveTemplate
@Validated public interface ReactiveLdaptiveOperations
The reactive ldaptive operations.- Author:
- Christian Bremer
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description reactor.core.publisher.Mono<org.ldaptive.Result>
add(@NotNull org.ldaptive.AddRequest addRequest)
Executes add operation.reactor.core.publisher.Mono<Boolean>
bind(@NotNull org.ldaptive.BindRequest bindRequest)
Executes bind operation.reactor.core.publisher.Mono<Boolean>
compare(@NotNull org.ldaptive.CompareRequest compareRequest)
Executes compare operation.reactor.core.publisher.Mono<org.ldaptive.Result>
delete(@NotNull org.ldaptive.DeleteRequest deleteRequest)
Executes delete operation.reactor.core.publisher.Mono<org.ldaptive.extended.ExtendedResponse>
executeExtension(@NotNull org.ldaptive.extended.ExtendedRequest request)
Executes extended request.default reactor.core.publisher.Mono<Boolean>
exists(@NotNull String dn)
Exists.default <T> reactor.core.publisher.Mono<Boolean>
exists(T domainObject, @NotNull LdaptiveEntryMapper<T> entryMapper)
Exists.reactor.core.publisher.Flux<org.ldaptive.LdapEntry>
findAll(@NotNull org.ldaptive.SearchRequest searchRequest)
Find all.default <T> reactor.core.publisher.Flux<T>
findAll(@NotNull org.ldaptive.SearchRequest searchRequest, @NotNull LdaptiveEntryMapper<T> entryMapper)
Find all.reactor.core.publisher.Mono<org.ldaptive.LdapEntry>
findOne(@NotNull org.ldaptive.SearchRequest searchRequest)
Find one.default <T> reactor.core.publisher.Mono<T>
findOne(@NotNull org.ldaptive.SearchRequest searchRequest, @NotNull LdaptiveEntryMapper<T> entryMapper)
Find one.default reactor.core.publisher.Mono<String>
generateUserPassword(@NotNull String dn)
Generate user password.@NotNull org.ldaptive.ConnectionFactory
getConnectionFactory()
Gets connection factory.reactor.core.publisher.Mono<org.ldaptive.Result>
modify(@NotNull org.ldaptive.ModifyRequest modifyRequest)
Executes modify operation.reactor.core.publisher.Mono<org.ldaptive.Result>
modifyDn(@NotNull org.ldaptive.ModifyDnRequest modifyDnRequest)
Executes modify DN operation.default reactor.core.publisher.Mono<org.ldaptive.extended.ExtendedResponse>
modifyUserPassword(@NotNull String dn, String oldPass, String newPass)
Modify user password.default <T> reactor.core.publisher.Mono<org.ldaptive.Result>
remove(T domainObject, @NotNull LdaptiveEntryMapper<T> entryMapper)
Remove.default <T> reactor.core.publisher.Mono<Long>
removeAll(Collection<T> domainObjects, @NotNull LdaptiveEntryMapper<T> entryMapper)
Remove all.<T> reactor.core.publisher.Mono<T>
save(T domainObject, @NotNull LdaptiveEntryMapper<T> entryMapper)
Save.default <T> reactor.core.publisher.Flux<T>
saveAll(Collection<T> domainObjects, @NotNull LdaptiveEntryMapper<T> entryMapper)
Save all.
-
-
-
Method Detail
-
getConnectionFactory
@NotNull @NotNull org.ldaptive.ConnectionFactory getConnectionFactory()
Gets connection factory.- Returns:
- the connection factory
-
add
reactor.core.publisher.Mono<org.ldaptive.Result> add(@NotNull @NotNull org.ldaptive.AddRequest addRequest)
Executes add operation.- Parameters:
addRequest
- the add request- Returns:
- the mono
-
bind
reactor.core.publisher.Mono<Boolean> bind(@NotNull @NotNull org.ldaptive.BindRequest bindRequest)
Executes bind operation.- Parameters:
bindRequest
- the bind request- Returns:
- the mono
-
compare
reactor.core.publisher.Mono<Boolean> compare(@NotNull @NotNull org.ldaptive.CompareRequest compareRequest)
Executes compare operation.- Parameters:
compareRequest
- the compare request- Returns:
- the mono
-
delete
reactor.core.publisher.Mono<org.ldaptive.Result> delete(@NotNull @NotNull 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(@NotNull @NotNull org.ldaptive.extended.ExtendedRequest request)
Executes extended request.- Parameters:
request
- the request- Returns:
- the mono
-
generateUserPassword
default reactor.core.publisher.Mono<String> generateUserPassword(@NotNull @NotNull String dn)
Generate user password.- Parameters:
dn
- the dn- Returns:
- the mono
-
modify
reactor.core.publisher.Mono<org.ldaptive.Result> modify(@NotNull @NotNull org.ldaptive.ModifyRequest modifyRequest)
Executes modify operation.- Parameters:
modifyRequest
- the modify request- Returns:
- the mono
-
modifyDn
reactor.core.publisher.Mono<org.ldaptive.Result> modifyDn(@NotNull @NotNull 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(@NotNull @NotNull String dn, @Nullable String oldPass, @Nullable String newPass)
Modify user password.- Parameters:
dn
- the dnoldPass
- the old passnewPass
- the new pass- Returns:
- the mono
-
findOne
reactor.core.publisher.Mono<org.ldaptive.LdapEntry> findOne(@NotNull @NotNull org.ldaptive.SearchRequest searchRequest)
Find one.- Parameters:
searchRequest
- the search request- Returns:
- the mono
-
findOne
default <T> reactor.core.publisher.Mono<T> findOne(@NotNull @NotNull org.ldaptive.SearchRequest searchRequest, @NotNull @NotNull LdaptiveEntryMapper<T> entryMapper)
Find one.- Type Parameters:
T
- the type parameter- Parameters:
searchRequest
- the search requestentryMapper
- the entry mapper- Returns:
- the mono
-
findAll
reactor.core.publisher.Flux<org.ldaptive.LdapEntry> findAll(@NotNull @NotNull org.ldaptive.SearchRequest searchRequest)
Find all.- Parameters:
searchRequest
- the search request- Returns:
- the flux
-
findAll
default <T> reactor.core.publisher.Flux<T> findAll(@NotNull @NotNull org.ldaptive.SearchRequest searchRequest, @NotNull @NotNull LdaptiveEntryMapper<T> entryMapper)
Find all.- Type Parameters:
T
- the type parameter- Parameters:
searchRequest
- the search requestentryMapper
- the entry mapper- Returns:
- the flux
-
exists
default reactor.core.publisher.Mono<Boolean> exists(@NotNull @NotNull String dn)
Exists.- Parameters:
dn
- the dn- Returns:
- the mono
-
exists
default <T> reactor.core.publisher.Mono<Boolean> exists(@NotNull T domainObject, @NotNull @NotNull LdaptiveEntryMapper<T> entryMapper)
Exists.- Type Parameters:
T
- the type parameter- Parameters:
domainObject
- the domain objectentryMapper
- the entry mapper- Returns:
- the mono
-
save
<T> reactor.core.publisher.Mono<T> save(@NotNull T domainObject, @NotNull @NotNull LdaptiveEntryMapper<T> entryMapper)
Save.- Type Parameters:
T
- the type parameter- Parameters:
domainObject
- the domain objectentryMapper
- the entry mapper- Returns:
- the mono
-
saveAll
default <T> reactor.core.publisher.Flux<T> saveAll(@Nullable Collection<T> domainObjects, @NotNull @NotNull LdaptiveEntryMapper<T> entryMapper)
Save all.- Type Parameters:
T
- the type parameter- Parameters:
domainObjects
- the domain objectsentryMapper
- the entry mapper- Returns:
- the flux
-
remove
default <T> reactor.core.publisher.Mono<org.ldaptive.Result> remove(@NotNull T domainObject, @NotNull @NotNull LdaptiveEntryMapper<T> entryMapper)
Remove.- Type Parameters:
T
- the type parameter- Parameters:
domainObject
- the domain objectentryMapper
- the entry mapper- Returns:
- the mono
-
removeAll
default <T> reactor.core.publisher.Mono<Long> removeAll(@Nullable Collection<T> domainObjects, @NotNull @NotNull LdaptiveEntryMapper<T> entryMapper)
Remove all.- Type Parameters:
T
- the type parameter- Parameters:
domainObjects
- the domain objectsentryMapper
- the entry mapper- Returns:
- the mono
-
-