{"action":"opened","issue":{"url":"https://api.github.com/repos/akkadotnet/akka.net/issues/2321","repository_url":"https://api.github.com/repos/akkadotnet/akka.net","labels_url":"https://api.github.com/repos/akkadotnet/akka.net/issues/2321/labels{/name}","comments_url":"https://api.github.com/repos/akkadotnet/akka.net/issues/2321/comments","events_url":"https://api.github.com/repos/akkadotnet/akka.net/issues/2321/events","html_url":"https://github.com/akkadotnet/akka.net/issues/2321","id":178923278,"number":2321,"title":"Persistence query improvement: live stream of persisted messages  ","user":{"login":"andreyleskov","id":2056093,"avatar_url":"https://avatars.githubusercontent.com/u/2056093?v=3","gravatar_id":"","url":"https://api.github.com/users/andreyleskov","html_url":"https://github.com/andreyleskov","followers_url":"https://api.github.com/users/andreyleskov/followers","following_url":"https://api.github.com/users/andreyleskov/following{/other_user}","gists_url":"https://api.github.com/users/andreyleskov/gists{/gist_id}","starred_url":"https://api.github.com/users/andreyleskov/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/andreyleskov/subscriptions","organizations_url":"https://api.github.com/users/andreyleskov/orgs","repos_url":"https://api.github.com/users/andreyleskov/repos","events_url":"https://api.github.com/users/andreyleskov/events{/privacy}","received_events_url":"https://api.github.com/users/andreyleskov/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":0,"created_at":"2016-09-23T16:45:03Z","updated_at":"2016-09-23T16:45:03Z","closed_at":null,"body":"Read journal has two types of queries out-of the box: \r\n\r\n 1) Live stream of events by some filter (persistence i or tag)  (EventsByPersistenceIdQuery and CurrentEventsByPersistenceIdQuery & EventsByTag and CurrentEventsByTag)\r\n\r\n 2) Live stream of added \\ changed persistence Ids (AllPersistenceIdsQuery and CurrentPersistenceIdsQuery)\r\n\r\ntaken from http://getakka.net/docs/persistence/persistence-query\r\n\r\nI suggest to add a new default query :\r\nEventsQuery - it will return all current \r\nRecentEventsQuery - it will return stream of events persisted after query start and will push new events with time. \r\n\r\nUse case is to create a different views for akka.persistence journal. \r\n\r\nFor example wire serializer is set as default serializer for akka.net, and it stores binary content in DB\r\nFor debug view it is very helpful to have human-readable representation of events, for example flatten to columns and grouped by aggregate root to tables, or just JSON view of serialized content. \r\n\r\nAll is need is to extend write journals to allow publish of newly created events & extend read journal.\r\n\r\nPlease tell if this idea will fit, I will create a PR. \r\n\r\n \r\n"}}
{"actor":{"display_login":"andreyleskov"}}