[akka-user][deprecated] Does it fit to CRDT ?

2018-04-06 Thread Hsnamed 
We have domain : 
- 10.000 long lived "*event*" objects , i think about to create an actor 
for each of them.
- Each "*event*" contains < 250 entities like "*factgroup*" .
- Each factgroup contains < 6 *fact *entities : *fact *entity has 2 - long 
counters and boolean *state *that has changed in any direction.
- Payload - message that change the counters in *fact *entity.

*FactGroup* must has changed atomically : 
- each payload usually affects all *facts*
- *state *of each *fact* depedns on calculation result of 2 *fact* counters.

State of fact and counters of fact is the most important thing, so i left 
idea about LWWMap.

Also thinked about extending 
AbstractReplicatedData, AbstractDeltaReplicatedData as a chance to make 
crdt Map of FactGroup

Does it fit to CRDT ?
Could someone suggest the right way to implement crdt ?

-- 
*
** New discussion forum: https://discuss.akka.io/ replacing akka-user 
google-group soon.
** This group will soon be put into read-only mode, and replaced by 
discuss.akka.io
** More details: https://akka.io/blog/news/2018/03/13/discuss.akka.io-announced
*
>> 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Re: [akka-user][deprecated] What is the reason for that : "resolve of path sequence [/system/ddataReplicator/$PYi#-1343927577] failed"

2018-04-06 Thread Hsnamed 
Sure

пятница, 6 апреля 2018 г., 9:55:43 UTC+3 пользователь Patrik Nordwall 
написал:
>
> That's a great question. Could you move it to our new forum at 
> https://discuss.akka.io/
>
> Thanks,
> Patrik
>
> On Fri, Apr 6, 2018 at 8:12 AM, Hsnamed > 
> wrote:
>
>> Hi all.
>> I made cluster of two nodes on the same host with role "*ddtest*" with 
>> following configuration :
>>
>> akka {
>>   actor {
>> provider = "cluster"
>>   serializers {
>> java = "akka.serialization.JavaSerializer"
>> proto = "akka.remote.serialization.ProtobufSerializer"
>>   }
>>   serialization-bindings {
>> "java.lang.String" = java
>> "java.io.Serializable" = java
>>   }
>>   }
>>   remote {
>> log-remote-lifecycle-events = off
>> log-frame-size-exceeding = 1000b
>> netty.tcp {
>>   hostname = "127.0.0.1"
>>   port = 0
>> }
>>   }
>>
>>   cluster {
>> seed-nodes = [
>>   "akka.tcp://Demo@127.0.0.1:2551",
>>   "akka.tcp://Demo@127.0.0.1:2552"]
>>   }
>>
>>   loglevel = "DEBUG"
>>
>> }
>>
>> akka.cluster.distributed-data {
>>   name = ddataReplicator
>>   role = "competition"
>>   gossip-interval = 5000 ms
>>   notify-subscribers-interval = 500 ms
>>   max-delta-elements = 1000
>>   use-dispatcher = ""
>>   pruning-interval = 120 s
>>   max-pruning-dissemination = 300 s
>>   pruning-marker-time-to-live = 6 h
>>   serializer-cache-time-to-live = 10s
>>   delta-crdt {
>> enabled = on
>> max-delta-size = 200
>>   }
>> }
>>
>>
>> Then i create another actor node with role - "client" , which must 
>> perform payload to random node with delay in 1 ms . Each payload modifies 
>> one entity from LWWMap. 
>>  
>> Each actor of *ddtest *role contains *250 *entities in *LWWMap  *and 
>> uses consistency level : *WriteMajority *, *ReadMajority *with 3 seconds
>>
>> I ran "client" that sended 2 payloads and it completed but in logs i 
>> have many messages : 
>> [DEBUG] [04/05/2018 16:58:57.202] 
>> [Demo-akka.remote.default-remote-dispatcher-8] 
>> [akka.actor.LocalActorRefProvider(akka://Demo)] resolve of path sequence 
>> [/system/ddataReplicator/$Tqi#598357737] failed
>>
>> Could you explain what does it means ?
>>
>>
>>
>>  
>>
>>
>>
>>
>>
>>
>> -- 
>>
>> *
>> ** New discussion forum: https://discuss.akka.io/ replacing akka-user 
>> google-group soon.
>> ** This group will soon be put into read-only mode, and replaced by 
>> discuss.akka.io
>> ** More details: 
>> https://akka.io/blog/news/2018/03/13/discuss.akka.io-announced
>>
>> *
>> >> 
>> >> Read the docs: http://akka.io/docs/
>> >> Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> >> Search the archives: https://groups.google.com/group/akka-user
>> --- 
>> You received this message because you are subscribed to the Google Groups 
>> "Akka User List" group.
>> To unsubscribe from this group and stop receiving emails from it, send an 
>> email to akka-user+...@googlegroups.com .
>> To post to this group, send email to akka...@googlegroups.com 
>> .
>> Visit this group at https://groups.google.com/group/akka-user.
>> For more options, visit https://groups.google.com/d/optout.
>>
>
>
>
> -- 
>
> Patrik Nordwall
> Akka Tech Lead
> Lightbend  -  Reactive apps on the JVM
> Twitter: @patriknw
>
>

-- 
*
** New discussion forum: https://discuss.akka.io/ replacing akka-user 
google-group soon.
** This group will soon be put into read-only mode, and replaced by 
discuss.akka.io
** More details: https://akka.io/blog/news/2018/03/13/discuss.akka.io-announced
*
>> 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Re: [akka-user][deprecated] Does it fit to CRDT ?

2018-04-06 Thread Patrik Nordwall 
Interesting question, could you move it to our new forum at
https://discuss.akka.io/

Thanks,
Patrik

On Fri, Apr 6, 2018 at 9:21 AM, Hsnamed  wrote:

> We have domain :
> - 10.000 long lived "*event*" objects , i think about to create an actor
> for each of them.
> - Each "*event*" contains < 250 entities like "*factgroup*" .
> - Each factgroup contains < 6 *fact *entities : *fact *entity has 2 -
> long counters and boolean *state *that has changed in any direction.
> - Payload - message that change the counters in *fact *entity.
>
> *FactGroup* must has changed atomically :
> - each payload usually affects all *facts*
> - *state *of each *fact* depedns on calculation result of 2 *fact*
> counters.
>
> State of fact and counters of fact is the most important thing, so i left
> idea about LWWMap.
>
> Also thinked about extending AbstractReplicatedData, 
> AbstractDeltaReplicatedData
> as a chance to make crdt Map of FactGroup
>
> Does it fit to CRDT ?
> Could someone suggest the right way to implement crdt ?
>
> --
> 
> *
> ** New discussion forum: https://discuss.akka.io/ replacing akka-user
> google-group soon.
> ** This group will soon be put into read-only mode, and replaced by
> discuss.akka.io
> ** More details: https://akka.io/blog/news/2018/03/13/discuss.akka.io-
> announced
> 
> *
> >>
> >> Read the docs: http://akka.io/docs/
> >> Check the FAQ: http://doc.akka.io/docs/akka/
> current/additional/faq.html
> >> Search the archives: https://groups.google.com/group/akka-user
> ---
> You received this message because you are subscribed to the Google Groups
> "Akka User List" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to akka-user+unsubscr...@googlegroups.com.
> To post to this group, send email to akka-user@googlegroups.com.
> Visit this group at https://groups.google.com/group/akka-user.
> For more options, visit https://groups.google.com/d/optout.
>



-- 

Patrik Nordwall
Akka Tech Lead
Lightbend  -  Reactive apps on the JVM
Twitter: @patriknw

-- 
*
** New discussion forum: https://discuss.akka.io/ replacing akka-user 
google-group soon.
** This group will soon be put into read-only mode, and replaced by 
discuss.akka.io
** More details: https://akka.io/blog/news/2018/03/13/discuss.akka.io-announced
*
>> 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

Re: [akka-user][deprecated] Does it fit to CRDT ?

2018-04-06 Thread Alan Burlison 

On 06/04/18 16:55, Patrik Nordwall wrote:


Interesting question, could you move it to our new forum at
https://discuss.akka.io/


Interesting to see people being pushed across onto the forum, bearing in 
mind that the earlier question that was asked about the functionality of 
Discourse's email support hasn't yet been answered...


--
Alan Burlison
--

--
*
** New discussion forum: https://discuss.akka.io/ replacing akka-user 
google-group soon.
** This group will soon be put into read-only mode, and replaced by 
discuss.akka.io
** More details: https://akka.io/blog/news/2018/03/13/discuss.akka.io-announced
*


 Read the docs: http://akka.io/docs/
 Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html
 Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka User List" group.

To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.