И чет как-то все равно не совсем понял)

искажает/портит - но как?

нолики на единички меняет. и наоборот

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

badger вот такой еще нагуглился

badger это последователь leveldb

Что бы вы посоветовали выбрать по опыту? вроде как оба стораджа подходят в целом для изучения

Что бы вы посоветовали выбрать по опыту? вроде как оба стораджа подходят в целом для изучения

мы используем болт в проде как и бунд https://github.com/tidwall/buntdb

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

Спасибо!

Спасибо!

есть один нюанс: надо понимать что все embedded решения не масштабируются от слова совсем

Это ок, для этой задачи подходит

А в rabbitmq mnesia вроде как хранилище?

mnesia - это ж otp фреймворк

привет эрланг)))

Разве это Фреймворк? Помнится 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?

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

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

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

Ноду

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

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

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