и все по новой

зачем тебе journal ?

saveState(state) pipeTo self become saving

в saving отрабатваешь status.Failure если что

А можно юзкейс узнать? Я как раз сейчас в своей ES либе думаю запилить поддержку чисто snapshot state поведений. Писал issue и тут твой вопрос как раз :)

> думаю запилить поддержку чисто snapshot state поведений ну видишь, не такой уж безумный я значит

в смысле что хочется использовать готовое уже решение, близкое к тому что используешь

Но там не будет akka-persistence использоваться

отдельный актор

> А можно юзкейс узнать? у меня в диалогах события прочиток/получения сообщений. сохраняем даты, но по сути они никак не используются в итоге, и только занимают место в journal, восстановление практически всегда из снепшотов. снепшоты по сути тоже не особо нужны, потому что нужен только последний)

Ну если реально история не нужна, то можно намного все проще сделать и главное типобезопасней чем akka serialization.

в akka persistence не боишься потерять сообщения?

уточни

leveldb не дает гарантии записи, можно только там сообещения терять

тут есть несколько вариантов потерять данные :) 1. Косяк в акке 2. Косяк в плагине 3. Косяк в настройке хранилища

leveldb не дает гарантии записи, можно только там сообещения терять

в продакшене лучше использовать что-то вроде кассандры

leveldb не дает гарантии записи, можно только там сообещения терять

мы не используем leveldb

мы используем кассандру

они на базе этого плагина lagom пилят, так что есть уверенность некая )

насколько я помню, касандра тоже не дает гарантии

ничего не дает гарантии

этого? https://github.com/akka/akka-persistence-cassandra

хотя нет, дает

может метеорит упатсть на ДЦ или годзилла

это все tradeoffs

кассандра в этом плане хороша поддержкой multi dc

а кто использует akka-persistence-query с кассандрой, как можно быть уверенным что вызывая eventsByTag с нужным оффсетом мы не пропустим какой-нибудь ивент при рестарте?

Он же трекает внутри seqNr для каждого persistenceId

Или ты имеешь в виду что событие появится в mat view после того как мы ушли дальше?

это да, но что если мы его остановили, получили оффсет, а потом с другой ноды записался ивент "в прошлое" ввиду неочень синхронизированного времени

в итоге стрим упадет

хотя нет

не упадет

фак

нет, я про другую ситуацию. есть стрим, мы его остановили у нас есть офсет. потом записали событие в прошлое, которое по времени до офсета.

что будет если мы снова запустим стрим с данным оффсетом?

это событие будет пропущено?

ну да я про это и говорю, что если записали оффсет а событие добавилось с меньшим оффсетом

видимо да

надо код читать

видимо

надо у патрика спросить )

а то так непонятно

ну или так :)

хэй - новый выпуск подкаста http://scalalaz.ru/series-05.html

Как из List[Future[Option[Model]]] сделать List[Future[Model]] ?

collectом?

только открыть опшены*

Future.sequence(someval).map(_.collect {case Some(x) => x} )

угу

или flatMap(identity)

Сиквенс не нужен. Просто someval.map(_.collect { case Some(x) => x }) Там же не надо получить Future[List[Model]].

тогда не получится профильтровать list

или flatMap(identity)

Не прокатит.

уже понял

ERROR: S client not available

scala> Future.successful[Option[Int]](Some(1)).flatMap(identity) <console>:12: error: type mismatch; found : Option[Int] => Option[Int] required: Option[Int] => scala.concurrent.Future[?] Future.successful[Option[Int]](Some(1)).flatMap(identity)

Future.fold(a: List[Future[Option[Model]]])(List.empty){ case (list, opt) => opt.fold(list)(_ +: list) }

как-то так

рано или поздно все равно материализовать)

на выходе правда будет Future[List[Model]] все равно

ну как бэ непонятно зачем иметь List[Future[Model]] на выходе

Ага, спасибо, в конце мне в результате это и надо.

Совсем уже заблудился в футурах...

/scala object Rextester extends App {println("Shaitanama")}

/scala object Rextester extends App {println("Shaitanama")}

/scala object X extends App { println(Seq(1,2,3).map(_ + 1)) }

ну вобщем вы поняли

/scala

/scala

/php

/php

NOOOOOOOOOO

пишем так: в кавычках для кода /scala object Rextester extends App { тут код}

/scala object Rextester extends App {import scala.io.Source for(line <- Source.fromPath("/etc/passwd").getLines()) println(line)}

))

/scala object Rextester extends App { import scala.sys.process._ "uname -a".! }

врот мне ноги)

Короче вы знаете что делать.

/scala object Lol extends App { System.exit(0) }

/scala object Rextester extends App { System.exit(0) }

/scala object Rextester extends App { import scala.sys.process._ "ps -aux".! }