[JBoss JIRA] (ISPN-9625) Make clustered locks configuration possible by XML
by Katia Aresti (Jira)
[ https://issues.jboss.org/browse/ISPN-9625?page=com.atlassian.jira.plugin.... ]
Katia Aresti updated ISPN-9625:
-------------------------------
Description:
Today it's not possible to configure clustered locks on xml, and there are some parameters that should be configurables.
The container can be either very consistent or available regarding split brains.
Every node can be owner of the lock state for the highest consistency, or we can define a limited number of owners
was:Today it's not possible to configure clustered locks on xml, and there are some parameters that should ne configurables
> Make clustered locks configuration possible by XML
> --------------------------------------------------
>
> Key: ISPN-9625
> URL: https://issues.jboss.org/browse/ISPN-9625
> Project: Infinispan
> Issue Type: Feature Request
> Components: Clustered Locks
> Affects Versions: 9.4.0.Final
> Reporter: Katia Aresti
> Assignee: Katia Aresti
> Priority: Major
>
> Today it's not possible to configure clustered locks on xml, and there are some parameters that should be configurables.
> The container can be either very consistent or available regarding split brains.
> Every node can be owner of the lock state for the highest consistency, or we can define a limited number of owners
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 11 months
[JBoss JIRA] (ISPN-9811) Implement single response publisher methods
by William Burns (Jira)
[ https://issues.jboss.org/browse/ISPN-9811?page=com.atlassian.jira.plugin.... ]
William Burns updated ISPN-9811:
--------------------------------
Status: Resolved (was: Pull Request Sent)
Resolution: Done
> Implement single response publisher methods
> -------------------------------------------
>
> Key: ISPN-9811
> URL: https://issues.jboss.org/browse/ISPN-9811
> Project: Infinispan
> Issue Type: Sub-task
> Components: Publisher
> Reporter: William Burns
> Assignee: William Burns
> Priority: Major
> Fix For: 10.0.0.Beta1, 10.0.0.Final
>
>
> We need to implement the backend for a method like
> {code}
> <R> CompletionStage<R> compose(Function<? super Publisher<T>, ? extends CompletionStage<R>> transformer,
> Function<? super Publisher<R>, ? extends CompletionStage<R>> finalizer);
> {code}
> This would allow for all methods that don't require streaming results to be done very easily.
> For example a count method can then just be implemented by doing:
> {code}
> java.util.function.Function<Publisher<?>, CompletionStage<Long>> transformer = cp ->
> Flowable.fromPublisher(cp)
> .count()
> .to(RxJavaInterop.singleToCompletionStage());
> java.util.function.Function<Publisher<Long>, CompletionStage<Long>> finalizer = results ->
> Flowable.fromPublisher(results)
> .reduce((long) 0, Long::sum)
> .to(RxJavaInterop.singleToCompletionStage());
> return infinispanPublisher.compose(transformer, finalizer);
> {code}
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 11 months
[JBoss JIRA] (ISPN-9811) Implement single response publisher methods
by William Burns (Jira)
[ https://issues.jboss.org/browse/ISPN-9811?page=com.atlassian.jira.plugin.... ]
William Burns updated ISPN-9811:
--------------------------------
Fix Version/s: 10.0.0.Beta1
> Implement single response publisher methods
> -------------------------------------------
>
> Key: ISPN-9811
> URL: https://issues.jboss.org/browse/ISPN-9811
> Project: Infinispan
> Issue Type: Sub-task
> Components: Publisher
> Reporter: William Burns
> Assignee: William Burns
> Priority: Major
> Fix For: 10.0.0.Beta1, 10.0.0.Final
>
>
> We need to implement the backend for a method like
> {code}
> <R> CompletionStage<R> compose(Function<? super Publisher<T>, ? extends CompletionStage<R>> transformer,
> Function<? super Publisher<R>, ? extends CompletionStage<R>> finalizer);
> {code}
> This would allow for all methods that don't require streaming results to be done very easily.
> For example a count method can then just be implemented by doing:
> {code}
> java.util.function.Function<Publisher<?>, CompletionStage<Long>> transformer = cp ->
> Flowable.fromPublisher(cp)
> .count()
> .to(RxJavaInterop.singleToCompletionStage());
> java.util.function.Function<Publisher<Long>, CompletionStage<Long>> finalizer = results ->
> Flowable.fromPublisher(results)
> .reduce((long) 0, Long::sum)
> .to(RxJavaInterop.singleToCompletionStage());
> return infinispanPublisher.compose(transformer, finalizer);
> {code}
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 11 months