ищи как в маке переменные окружения на постоянку прописывать

Спс

Всем привет! Такая ситуация: получаю метаданные по GRPC, затем надо эти данные пробросить в бизнес-логику. Как лучше сделать? - вытащить данные на уровне транспорта и передавать, как аргументы в методы (по идее избыточно, т.к. контекст и так всегда передается первым аргументом); - вытаскивать данные из контекста через пакет metadata там, где они нужны; - сделать derived контекст с WithValue, чтобы не таскать в бизнес-логику зависимости в виде пакета metadata; - другой вариант. Есть ли какие-то best practices на этот счет?

Всем привет! Такая ситуация: получаю метаданные по GRPC, затем надо эти данные пробросить в бизнес-логику. Как лучше сделать? - вытащить данные на уровне транспорта и передавать, как аргументы в методы (по идее избыточно, т.к. контекст и так всегда передается первым аргументом); - вытаскивать данные из контекста через пакет metadata там, где они нужны; - сделать derived контекст с WithValue, чтобы не таскать в бизнес-логику зависимости в виде пакета metadata; - другой вариант. Есть ли какие-то best practices на этот счет?

Я вторым пользуюсь.

thnx

Всем привет! Кто нибудь знает как подружить BindQuery в джин с URLSearchParameters в js чтоб нормально парсило слайс, сейчас отправляю так ?test=t1,t2,t3, а в го вот это как одна строка считывается.

Не знаю как в джине, но канонично массивы так в query оформлять ?test[]=1&test[]=2&test[]=3

Может джин распарсит такое как слайс

Хотелось бы чтоб сама бинд функция все делала. Сейчас попробывал ?test[]=t1&test[]=t2&test[]=t3 все считал в слайс как надо, но URLSearchParameters так не умеет вот и думаю как можно сделать чтоб с зяпятыми работало или как urlsearchparameters кастомизировать.

Ну я туда подал объект с массивом и текстовым полем, получил результат с запятыми let data = { test: [ "t1", "t2", "t3" ], text: "test-text" }

new URLSearchParams(data).toString()

Коллеги подскажите почему так происходит. Решил сделать флаг, для файла логов и столкнулся с тем, что при --help у меня крашится программа, не могу понять в чём проблема. package main import ( "flag" "fmt" "log" "os" ) type errorsFileFlag struct{ os.File } func (f *errorsFileFlag) String() string { fmt.Println("String", *f) return f.Name() } func (f *errorsFileFlag) Set(s string) error { fmt.Println("Set", *f) if logFile, err := os.OpenFile(s, os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0644); err != nil { return fmt.Errorf("open file %q: %v", s, err) } else { f.File = *logFile return nil } } func ErrorsFileFlag(name string, value *os.File, usage string) *os.File { fmt.Println("ErrorsFileFlag Func") f := errorsFileFlag{*value} flag.CommandLine.Var(&f, name, usage) return &f.File } var errorsFileName = ErrorsFileFlag("e", os.Stderr, "Path to errors file") func main() { fmt.Println("before flag parse") flag.Parse() fmt.Println("after flag parse") fmt.Println("MAIN", errorsFileName.Name()) errorLogger := log.New(errorsFileName, "", log.LstdFlags) errorLogger.Println("test") }

просто так крашится и ни одной ошибки не выдает?

Вообщем разобрался

https://pkg.go.dev/flag#Value

The flag package may call the String method with a zero-valued receiver, such as a nil pointer.

package main import ( "flag" "fmt" "log" "os" ) type errorsFileFlag struct{ *os.File } func (f *errorsFileFlag) String() string { if f.File != nil { return f.File.Name() } else { return "" } } func (f *errorsFileFlag) Set(s string) error { if logFile, err := os.OpenFile(s, os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0644); err != nil { return fmt.Errorf("open file %q: %v", s, err) } else { *f.File = *logFile return nil } } func ErrorsFileFlag(name string, value *os.File, usage string) *os.File { f := errorsFileFlag{value} flag.CommandLine.Var(&f, name, usage) return f.File } var errorsFileName = ErrorsFileFlag("e", os.Stderr, "Path to errors file") func main() { flag.Parse() errorLogger := log.New(errorsFileName, "", log.LstdFlags) errorLogger.Println("test") }

а почему ты так странно пользуешься пакетом flag? обычно объявляют флаги, flag.Parse и уже потом передают результаты куда надо

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

поищи примеры использования flag - быстро найдешь и поймешь все

а почему ты так странно пользуешься пакетом flag? обычно объявляют флаги, flag.Parse и уже потом передают результаты куда надо

Так у меня так и сделано, объявлены глобальные флаги, первая строчка в main flag.parse и потом он в инициализацию логера уходит) Код сверху уже исправленный не хватало проверки на nil в методе string флага

сори, кажется понял, что ты пытаешься сделать. мозг не тригерит слово new в названии ErrorsFileFlag

сори, кажется понял, что ты пытаешься сделать. мозг не тригерит слово new в названии ErrorsFileFlag

https://pkg.go.dev/flag#Value

Я просто честно говоря не знаю другого способа объявления кастомных флагов с помощью стандартного пакета)

я бы просто объявил обычный стринговый флаг, и если он пустой вместо создания файла передал бы os.StdErr

ты указываешь на указатель

у тебя тип будет не *int, а **int

Всем привет, нужен совет У меня есть небольшие "сессии" юзеров (по 10-15 минут) во время которых сыпятся ивенты в сервис, мне нужно их накопить и при дисконнекте юзера засунуть все накопленные ивенты юзера в clickhouse Что можно взять под быстрый сторадж ивентов перед батч инзертом в кликхаус? Думаю просто в map по айди юзера записывать массив обьектов (пейлоад ивентов), но может тут что-то другое нужно юзать Важна скорость записи, тк ивентов много будет

а нельзя раз в n секунд или когда строк со всех юзеров накопилось больше m писать?

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

Всем привет, нужен совет У меня есть небольшие "сессии" юзеров (по 10-15 минут) во время которых сыпятся ивенты в сервис, мне нужно их накопить и при дисконнекте юзера засунуть все накопленные ивенты юзера в clickhouse Что можно взять под быстрый сторадж ивентов перед батч инзертом в кликхаус? Думаю просто в map по айди юзера записывать массив обьектов (пейлоад ивентов), но может тут что-то другое нужно юзать Важна скорость записи, тк ивентов много будет

Это не сокет?

опять же если юзеров тысяча в секунду выходит, а строк они по 100 сбрасывают, то кликхаусу будет больно

Почему не взять инмеморибд какой нить.

Для хранения

зачем?

У меня NATS, но персистенс нужен только по одному сабжекту Юзеров не будем много, максимум 20 в час

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

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

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

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

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

Записей будет около 60 в сек

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

А как ты понимаешь что юзер вышел? Сессии они сокетные?

А как ты понимаешь что юзер вышел? Сессии они сокетные?

Брокер мне сообщит доп ивентом о дисконнекте

ну окей, чем тебе схема не нравится: 1. Заводишь слайс. 2. Пишешь туда по всем юзерам. 3. Сбрасываешь накопив n строк или спустя m секунд (что раньше) 4. Дополнительно еще можно пытаться прочитать из канала, куда будут писать выходящие юзеры. сигналить, что вышли и нужно их данные сбросить (сбросятся конечно все, которые были в слайсе)

Ну просто когда там не соккет то тебе нет гарантии такого сообщения. Только по таймауту

что плохого в схеме?

ну окей, чем тебе схема не нравится: 1. Заводишь слайс. 2. Пишешь туда по всем юзерам. 3. Сбрасываешь накопив n строк или спустя m секунд (что раньше) 4. Дополнительно еще можно пытаться прочитать из канала, куда будут писать выходящие юзеры. сигналить, что вышли и нужно их данные сбросить (сбросятся конечно все, которые были в слайсе)

Можно же сделать мапу со слайсами

накуя?

)

Что бы можно было скинуть только одного пользователя

Из стека

зачем?

Ну мало ли)

почему не скинуть и данные других*

?:

Зависит от задачи)

почему не скинуть и данные других*

Потому что нужны все данеые по сессии юзера, либо никакие)

а если сервер упадет?

а если сервер упадет?

Инфа не релевантная будет, можно выкинуть

ну ок, мапа слайсов)

Всем спасибо, просто хотел чекнуть что в правильном направлении думаю

подожди, а зачем мапа? просто слайс, каждый юзер пишет и все по концу свой слайс

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

Указатель не может ссылаться. Он указывает. Ссылается ссылка.

Это фактически стандарт для сбора информации о состоянии программ. Тебе пока не надо.

тут есть любители плюсов?

@reijo1337

ты же на плюсах пишешь, верно?

как тебе?

гит чекал

почему перестал?

Го -- это С++ здорового человека.

go не С++ ни в каком варианте

@maks_vesnin, добрый вечер. Как успехи с озоном. Я про их задания с cup mail

ну мне некогда было решать. Я решил 2 задачи, но во второй тайм лимит вылетел

я вот щас фикс делаю

Оке.

я сделал Поиск n-го самого большого числа в массиве и склад

А погодите. Вы про общие?