Вопрос отпал)

А что про property based testing рассказывал? Какие-нибудь примеры как оно в Elixir 1.7 будет выглядить?

У Андреа только что был доклад Property-based testing is a mindset, если будет запись, советую посмотреть. Примерно так это будет выглядеть https://github.com/whatyouhide/stream_data . Одной из крутых фич предлагается сделать генерацию данных на основе type spec.

@avfomin Да уж, до proper-а пока далеко

А кто-нибудь заморачивался с иерархическими структурами? (хранение данных с реализацией nested set/closure table/...)

блээээээээ

ни у кого случайно нет скрипта для переноса arc из s3 в local storage?

до моего проекта доехал РКН

А кто-нибудь заморачивался с иерархическими структурами? (хранение данных с реализацией nested set/closure table/...)

ltree храню цепочки айдишек дерева

ltree храню цепочки айдишек дерева

А без привязки к Postgres?

А без привязки к Postgres?

наверное, так же, только составный ключик в ets/dets ( еее... тут надо будет заморочиться... и почему без постгреса? )

Можно ли дать имя воркеру, созданному через Task? worker(Task, [Module, :function, [args]])

Можно ли дать имя воркеру, созданному через Task? worker(Task, [Module, :function, [args]])

https://hexdocs.pm/elixir/Supervisor.Spec.html#worker/3 можно id указывать, подойдет?

https://hexdocs.pm/elixir/Supervisor.Spec.html#worker/3 можно id указывать, подойдет?

Спасибо

Подскажите а есть возможность получить стейт в генсервере, когда выполняються другие handle_cast ?

Получить где?

Ну грубо говоря у меня в фоне handle_cast делает запросы на сторонние API, получает данные и пишет в стейт, хочеться не ждать завершения всех запросов, а получить в любой момент стейт

Вообще gen_server реагирует на всё строго последовательно, как любой процесс в beam. Пока на одно сообщение реагирует, остальные копятся в инбоксе.

вот, те. тут без вариантов

если он вдруг в сторонние апи пишет как-то асинхронно, то можно

Ну грубо говоря у меня в фоне handle_cast делает запросы на сторонние API, получает данные и пишет в стейт, хочеться не ждать завершения всех запросов, а получить в любой момент стейт

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

точняк, можно асинхронность сделать отдельным процессом.

мммм а данные хранить тогда не в стейте

а в ets

я просто хотел данные в стейте хранить, но он ждет очереди

server1 -> call server2: а дай ка мне ответ от внешнего API server2 отдаёт какой-то уникальный id server2 идёт во внешний api server2 -> cast server1 {уникальный id, ответ от внешнего API}

немного не понял )

мммм а данные хранить тогда не в стейте

в стейте. из таска шли сообщение обратно генсерверу, пускай кладёт в стейт

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

а он обычно для этого и используется

генсервер для реализации поведения

query_id = :erlang.make_ref() parent = self() spawn fn -> result = ExternalAPI.long_call() send parent, {query_id, result} end

а потом где-то handle_info({query_id, result}, state) do ...

это если таймаут не нужен и прочие понты.

и в любой момент можно получить состояние :sys.get_state, поскольку вся тяжёлая долгая работа — отдельно, и твой gen_server в любой момент может ответить на запрос состояния

спасибо, ща попробую

но лучше как-то более нормально ) чтобы был таймаут и всё такое

да вот тоже думаю, что такое получается, либо ets уже использовать

query_id = :erlang.make_ref() parent = self() spawn fn -> result = ExternalAPI.long_call() send parent, {query_id, result} end

а как здесь получать текущий стейт?

а как здесь получать текущий стейт?

в любой момент? Для дебага или для жизни? Для дебага — :sys.get_state(pid или registered name) Для жизни — def handle_call(:get_state, _from, state), do: {:reply, state, state} и call его

ааа понял, спасибо

А как дочерним процессом Task.Supervisor сделать другой Task.Supervisor

и в любой момент можно получить состояние :sys.get_state, поскольку вся тяжёлая долгая работа — отдельно, и твой gen_server в любой момент может ответить на запрос состояния

бред: https://github.com/erlang/otp/blob/716ef17d2a00c7f4a5a5cf92fffd18adb94c542d/lib/stdlib/src/sys.erl#L113 https://github.com/erlang/otp/blob/716ef17d2a00c7f4a5a5cf92fffd18adb94c542d/lib/stdlib/src/sys.erl#L302 https://github.com/erlang/otp/blob/716ef17d2a00c7f4a5a5cf92fffd18adb94c542d/lib/stdlib/src/gen.erl#L148 https://github.com/erlang/otp/blob/716ef17d2a00c7f4a5a5cf92fffd18adb94c542d/lib/stdlib/src/gen.erl#L172

точно такой же вызов к genserver'у как и остальное

мы это поведение в тестах handle_cast юзаем, когда нужно дождаться когда handle_cast выполнится

Вообще-то, gen_server это такой же процесс как другие

С заранее запрограммированным поведением

Которым я предложил воспользоваться

ага

А бред тут только ты.

вопрос был: Подскажите а есть возможность получить стейт в генсервере, когда выполняються другие handle_cast ? твой ответ некорректен, в любой момент ты не получишь его стейт, только когда дойдет очередь.

хотя да сорян. tldr

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

А теперь как дебил защищаю репутацию в интернете. Доктора мне.

?

Так очередь на системные сообщения доходит сразу, или только в самом конце?

Я жду завтрашнего дня, хецнер и овш блокнули и кучу других хостеров, будет весело похоже...

Так очередь на системные сообщения доходит сразу, или только в самом конце?

Как все, по порядку

А почему?

Ну, всмысле, по коду то понятно что вс] по порядку

Они такие же как все остальные, отп - надстройка над логикой, которая говорит что все по порядку

Но почему нельзя было сделать 2 ресива

Чтоб не ломать наверное

То что и так работает

Впринципе в ОТП почему так не сделали

Везде 2 ресива

Сперва выгребаем системные

А потом - любые

Если системных нет, а любых много - будет дорого

И бесполезно

ну вот какраз чтобы не было ситуаций, когда ты послал 3 эвента в процесс 2 обычных и 1 системный, ожидаешь что они по порядку обработаются, а выполнятся не по порядку, будет сюрприз

Так а если у тебя загруженный под орех мэилбокс

То как обзервер смотрит на генсервер

висит неопредел]нное время?

обсервер висит да

Таймаутит

у загруженного процесса cложно стейт посмотреть, таймауты летят

Точно, таймаутит...

окей, а как увеличить тогда таймаут ?

окей, а как увеличить тогда таймаут ?

В коде - легко

В обзервре - хз

в init ?

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

В api

def get_state(pid), do: GenServer.call(pid, :get_state, 1000000)

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

другому генсерверу, разумеется, это отдавать нельзя

только таскам

Сходил пообщался с ребятами из AEON кстати. Напрасно их тут обосрали, более чем адекватные ребята. И проект в принципе получше и уж точно поинтереснее многих. Стэк опять таки огонь, все хайп слова собрали. Но конечно стартапчик. Был бы лет на 5 помоложе, да денег бы побольше давали, может и сам пошёл бы. Сори за рекламу, но чувствую себя причастным к необоснованному скептицизму в их адрес (типа извинился).