Разве это Фреймворк? Помнится storage, но с Erlang очень давно работал

это кусок open telecom platform

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

пример каждый 10 минут проверять что-то - надо что бы это выполнялось только один раз

а не одновременно на всех нодах который запущены

как правильно это с архитектурной точки зрения сделать/?

а не одновременно на всех нодах который запущены

Встречал реализацию такого через редис мьютекс (редис соответственно доступен всем нодам)

Немного теоретический топик хочу поднять: как тестировать grpc сервисы? 1. Сервер 1.1. Unary Тут все достаточно просто, даже моков не надо, просто func (s *Svc)Method(ctx context.Context, args...) (ret, error) 1.2. streaming Тут все менее красиво: мокать * StreamServer. И получаются разные вещи: возможные конфликты по импортам с vendor, если пользовать gomock, свои велосипеды-моки на стрим, и потенциально другое. И вот вопрос, как бы такой метод тестабильно написать и потестить: func (s *Svc) Stream(args *proto.StreamReq, stream proto.Svc_GetStreamServer) error { b, err := s.httpClient.Get(third-party-api) if err != nil { return err } data, err := unmarshal(b, s.SomeOpts) if err != nil { return err } for _, record := range data { result,err := s.doSmth(record) if err != nil { return err } err := stream.Send(result) if err != nil { return err } } return nil }

Можно написать или сгенерить мок на стрим, тогда тесты на этот метод получаются не очень красивые, ибо много лапши на сетап. А тестить надо по сути third party API

как правильно это с архитектурной точки зрения сделать/?

Я такое решал с помощью etcd. Там есть специализированный механизм для этого.

Я такое решал с помощью etcd. Там есть специализированный механизм для этого.

Ну суть таже. Мьютекс в разделяемом хранилище

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

Сделай один сервис-планировщик и много сервисов-воркеров которве будут получать задачи через очередь сообщений

Сделай один сервис-планировщик и много сервисов-воркеров которве будут получать задачи через очередь сообщений

как масштабировать сервис планировщик?

как масштабировать сервис планировщик?

Зависит откуда будут браться задачи и как он будут храниться

пример каждый 10 минут проверять что-то - надо что бы это выполнялось только один раз

шли воркерам задачи через канал, при этом шли через time.Ticker

ркн почти 2млн ip-адресов закинул, чтобы нас отсюда выкурить

ркн почти 2млн ip-адресов закинул, чтобы нас отсюда выкурить

"Эту песню не задушишь не убьешь"

ркн почти 2млн ip-адресов закинул, чтобы нас отсюда выкурить

Ахренеть, я про 655 352 айпишнегов слышал...

Ахренеть, я про 655 352 айпишнегов слышал...

https://2018.schors.spb.ru/ наслаждайся

вполне вероятно что утром мы будем о 5 млн говорить)

надо идти спать

завтра новый день

)))

все за ваши деньги, господа)

пол интернета работать не будет

чего переживать

В принципе я уже в i2p вылез, тут тоже мона сайтик сваять, форум.

Тут точно не достанут.

кстати, апдейты дата-центров через пуш-уведомления у телеграма была еще в 2015. может раньше. Итого мы имеем приложение, которое невозможно заблокировать, кроме как заблокировать пуш-сервера гугла/эппла либо взять измором, перебанив пол-интернета

Рушного интернета, остальные не заметят.

https://2018.schors.spb.ru/ наслаждайся

это же наш Фил Кулин делает

@schors

Рушного интернета, остальные не заметят.

нет, как раз не рушного

Не понял, россиян блочат жи... остальных-то как они осилят?

слушай, я не знаю с какой стороны ты. но с моей блочат не россиян, а для россиян

Ну да.

> взять измором, перебанив пол-интернета для россиян.

слушай, я не знаю с какой стороны ты. но с моей блочат не россиян, а для россиян

Скорее против россиян

Дурову нуно было децентрализованный мессенджер писать... меньше гемора было-бы...

Борьба с мифическим международным терроризмом - прикрытие банальной борьбы за пользователей Телеграма. Для холопов есть усмановский Там-Там, а нравится он вам или нет - да кого это волнует?

Исходники i2p есть, правда на Java... Щас даже айтупи для андроида и йоса есть... но это просто роутер, а вот как мессенджер было бы круть...

Дурову нуно было децентрализованный мессенджер писать... меньше гемора было-бы...

расскажи как это сделать)

это же наш Фил Кулин делает

Угу

расскажи как это сделать)

Ну дык, скрестить мессенджер с i2p, знал бы как в подробностях, рассказал бы.))))

i2p тоже не полностью децентрализованный

Павел Дуров пообещал, что с 22 апреля новая версия Телеграма начнет обходить блокировки по технологии domain-fronting. "Клиенты для всех платформ смогут соединяться с доменами clients4.google.com и graph.facebook.com и проксировать соединение дальше. Согласие Гугла и Фейсбука нами уже получено" - написал Дуров в своем твиттере.

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

Я делал редис лок. Для либы редиго была либа готовая, название не помню

Павел Дуров пообещал, что с 22 апреля новая версия Телеграма начнет обходить блокировки по технологии domain-fronting. "Клиенты для всех платформ смогут соединяться с доменами clients4.google.com и graph.facebook.com и проксировать соединение дальше. Согласие Гугла и Фейсбука нами уже получено" - написал Дуров в своем твиттере.

Ну дык, там как раз на очереди вацап, вместе с мордокнигой грохнут)))

будет как в китае

ничего недоступно, только внутренние, разрешённые ресурсы =)

подскажите, как избавится от такой конструкции User, _ := c.Get("User") User_ := User.(model.User) что бы User сразу был как .(model.User)

Павел Дуров пообещал, что с 22 апреля новая версия Телеграма начнет обходить блокировки по технологии domain-fronting. "Клиенты для всех платформ смогут соединяться с доменами clients4.google.com и graph.facebook.com и проксировать соединение дальше. Согласие Гугла и Фейсбука нами уже получено" - написал Дуров в своем твиттере.

Чет не вижу сообщения в твиттере у него такого

может он в директ написал)

Времена постправды

Возможно фейк. Вероятно. Слишком сладко казалось

Я делал редис лок. Для либы редиго была либа готовая, название не помню

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

Добрейший вечерок господа ,ребят где найти инфу по написанию функциональных тестов при помощи библиотек json, и go-resty!может кто то где то встречал ?кроме официальных ссылок на эти библиотеки! спасибо заранее

Да хоть майсиквель, хоть зукипер, любой distributed lock подойдёт

подскажите, как избавится от такой конструкции User, _ := c.Get("User") User_ := User.(model.User) что бы User сразу был как .(model.User)

Специально заложено, чтобы так не делали. Если юзера нет, тогда на второй строчке паника будет, а так как ты собственно-ручно ее замолчал — ССЗБ

Добрейший вечерок господа , где найти инфу по написанию функциональных тестов при помощи библиотек json, и go-resty!может кто то где то встречал ?кроме официальных ссылок на эти библиотеки! спасибо заранее

Специально заложено, чтобы так не делали. Если юзера нет, тогда на второй строчке паника будет, а так как ты собственно-ручно ее замолчал — ССЗБ

т.е. я правильно сделал?

Специально заложено, чтобы так не делали. Если юзера нет, тогда на второй строчке паника будет, а так как ты собственно-ручно ее замолчал — ССЗБ

Звучит как очередной костыль

т.е. я правильно сделал?

нужно проверять 2 результат

т.е. я правильно сделал?

Нет, надо смотреть, что Get() возвращает во втором значении

там exist - т.е. существует ли переменная, я понял, ее надо проверить, а то что я это использую User_ := User.(model.User) это нормально?

там exist - т.е. существует ли переменная, я понял, ее надо проверить, а то что я это использую User_ := User.(model.User) это нормально?

Ну во-первых, ты не проверяешь в касте ситуацию, если значение таки не model.User, во-вторых, название переменной должно отражать суть данных, которую содержит. Потому User_ настоятельно рекомендую переименовать в data или value (сарказм)

господа, xml умеет паковать и распаковывать map[string]interface{}? есть структура, и к ней в догонку нужно паковать всякий мусор в эту мапу. все это потом сохраняется как xml файл. нужно, чтобы и эти данные сохранялись. я тут прикуралесил уже xml.Marshaler, и все ок. А вот с распаковкой траблы, там и слайсы, и мапы, и булевы значения. Вот собственно вопрос возникает, можно ли это все не ручками декодить? Если XML это как-то запаковал, то может он умеет сам распаковывать?

<Data> <values> <string>abc</string> <slice>hello</slice> <slice>world</slice> <number>1</number> <float>1.23</float> <bool>true</bool> <nestedMap> <nestedKey>nestedValue</nestedKey> </nestedMap> </values> </Data>

xml.Unmarshal. А в чем собсна проблема? Передал xml и структуру и все распакуется

xml.Unmarshal. А в чем собсна проблема? Передал xml и структуру и все распакуется

А вы пробовали просто взять, и передать map[string]interface{} в xml.Marshal?

А, нужно interface{} распаковать? Ну тогда ручками. Я подумал что есть struct, которий нужно паковать/распаковать. Недопонял. Можно поискать какую нибуть либу для етого.

я думал, может в json запаковать, а потом в base64.

Когда стоит использовать ГО вместо node js?

Когда стоит использовать ГО вместо node js?

Когда пишешь сервис

Когда пишешь сервис

Я сервис и на ноде могу написать. Можно подробнее с примером, когда по вашему стоит использовать ГО а когда году?

Ноду

Знаешь го, не знаешь ноду, пишешь на го Знаешь ноду, но не знаешь го, пишешь на ноде

Знаешь ноду и го, пишешь на чём по кайфу

Но советчик из меня хреновый 😁