conn.Do("HMSET", key, "Field1", value1, "Field2", value2)

https://godoc.org/github.com/go-redis/redis#Client.HMSet

https://godoc.org/github.com/go-redis/redis#Client.HMSet

спасибо, но у меня другой клиент

https://godoc.org/github.com/gomodule/redigo/redis

используйте этот)))

да вроде разобрался уже

А нет такого, что "прочесть-обновить-записать"?

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

Во что она сериализована?

Коллеги, есть приглашение на Хакатон на Go в Европе, можно запостить сюда? возможно тут кто-то будет в соответствующих городах

Что за хакатон? Засылай.

Засылайте, да

Админы, обратите внимание - я согласовал

Во что она сериализована?

я ее засылаю туда через AddFlat(), там простые поля

в роттердаме и делфте красиво )

Registration links: https://lnkd.in/gsEVkRq https://www.neo.camp/ https://lnkd.in/gydWJAN

так вот, обычно эта констркуция не применима и не нужна обычно как: где-то на чтении из t.C висит горутина вы делаете t.Stop(), в t.C уезжает значение которое та, висящая горутина, и вычитывает и когда запускается ваше чтение из t.C - он уже пуст, и в нем точно ничего не появится использовать эту конструкцию - и об этом есть в доке - надо ТОЛЬКО если вы точно знаете, что читать из t.C некому

У меня как раз некому выбрать было, происходило в одной горутине. И эта конструкция фризила рутину.

Нет, так не бывает.

Добрый день var result []anyModelStruct findAll(&result) а внутри findAll условно цикл по источнику, вот думаю как заполнить такой слайс

по идеи мы должны делать { result := append(result, anyModelStruct{ any: value }) } но если функция "универсальная" тогда не получится ?

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

можно конечно вернуть какой нить map[string]interface{}

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

Где вы такие задачи находите?!

по идеи мы должны делать { result := append(result, anyModelStruct{ any: value }) } но если функция "универсальная" тогда не получится ?

ну только через interface{} и reflect

Где вы такие задачи находите?!

ну я сделал DAO обертку, внутри кастомн реализацию couchdb

Где вы такие задачи находите?!

+

думал что реализацию можно отделить от моделей как то

тоесть как это обычно бывает, слоеный пирог

ну я сделал DAO обертку, внутри кастомн реализацию couchdb

это называется activce record и для го он вообще никак не лепится обычно

это не актив рекорд

это репозиторий получается

тогда ты хочешь сделать generic repository, что тоже считается вредным

ранее использовал для запросов https://github.com/leesper/couchdb-golang

там на https://github.com/leesper/couchdb-golang/blob/master/database.go просто возращают map[string]interface{}

на любой запрос

а кто-нибудь использует клиент к реббиту? Я как-то не очень понял. Поверх него надо пул коннектов наворачивать?

можно конечно и так сделать

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

ну хз как делать ?

а кто-нибудь использует клиент к реббиту? Я как-то не очень понял. Поверх него надо пул коннектов наворачивать?

Йа. У меня без пула. Один коннект и несколько сессий, ЕМНИП. После обрыва связи просто реконнект. Но у меня довольно тривиальный кейс и этого хватает :)

пул коннектов раббиту не нужен

асинхронно диспатчить сообщения надо

ну вот я тоже думаю. Накидать данных потом confirmation ждать

ну вот я тоже думаю. Накидать данных потом confirmation ждать

У меня так и сделано %)

а что такое “несколько сессий” ?

топовый ник

а что такое “несколько сессий” ?

Глянул в код. Не сессий. Каналов :) Давно это было ...

Глянул в код. Не сессий. Каналов :) Давно это было ...

Огонь, спасибо)

Огонь, спасибо)

сук, где такие ники раздают?)

сук, где такие ники раздают?)

При советской власти по блату. В комитете никнеймов. Было дело в москву за никами ездили. А у меня у знакомого дядя ездил заграницу. Такие классные ники привозил, чехословацкие

При советской власти по блату. В комитете никнеймов. Было дело в москву за никами ездили. А у меня у знакомого дядя ездил заграницу. Такие классные ники привозил, чехословацкие

?

При советской власти по блату. В комитете никнеймов. Было дело в москву за никами ездили. А у меня у знакомого дядя ездил заграницу. Такие классные ники привозил, чехословацкие

??

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

все за никами ездили

использовать sync.Pool в качестве стека - это вообще норм?

Вроде, нет

использовать sync.Pool в качестве стека - это вообще норм?

Оо Каким образом?

Оо Каким образом?

+

При советской власти по блату. В комитете никнеймов. Было дело в москву за никами ездили. А у меня у знакомого дядя ездил заграницу. Такие классные ники привозил, чехословацкие

Бля, меня порвало

а так http.Handle и http.HandleFunc полностью взаимозаменемы https://play.golang.org/p/c9h4-lEn1tR

Вот посмотрел в доку, и по моему ничего не взаимозаменяемо: func main() { r := mux.NewRouter() r.HandleFunc("/", HomeHandler) r.HandleFunc("/products", ProductsHandler) r.HandleFunc("/articles", ArticlesHandler) http.Handle("/", r) } Вот в этом примере HomeHandler это: func HomeHandler (w http.ResponseWriter, r *http.Request) { ... } Напрямую сделать например так: r.Handle("/", HomeHandler(m)) func HomeHandler(m *Xwz) http.Handler { ... return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { ... }) ... } не получится. Может я чего-то не допонимаю.

Оо Каким образом?

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

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

это НЕ стек

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

любой объект из sync.Pool может быть собран в любой момент GC

ERROR: S client not available

скажем, порядок не важен

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

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

Канал?!

Канал?!

ну, их тоже можно так использовать )))

я понял

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

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

вроде как нет в общем случае

а че модно использовать? пятисотить?

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

523?

523?

это какие-то фантазии клаудфары или они таки внесли в стандарт?

а че модно использовать? пятисотить?

нормальные ошибки с текстом

а код при этом какой?

без кода ошибку не положено

Написано нестандартный

Вот посмотрел в доку, и по моему ничего не взаимозаменяемо: func main() { r := mux.NewRouter() r.HandleFunc("/", HomeHandler) r.HandleFunc("/products", ProductsHandler) r.HandleFunc("/articles", ArticlesHandler) http.Handle("/", r) } Вот в этом примере HomeHandler это: func HomeHandler (w http.ResponseWriter, r *http.Request) { ... } Напрямую сделать например так: r.Handle("/", HomeHandler(m)) func HomeHandler(m *Xwz) http.Handler { ... return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { ... }) ... } не получится. Может я чего-то не допонимаю.

почеу не получится?

а код при этом какой?

500, других вариантов нет. http коды не про прикладной уровень

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

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

500, других вариантов нет. http коды не про прикладной уровень

ну наверное таки 503. ну ок

500, других вариантов нет. http коды не про прикладной уровень

Nginx возвращает 502

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

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

почеу не получится?

Всё получилось, но это очень для меня странно, и не знаю насколько криво. import ( "net" "net/http" "time" h "MyApp/handler" "MyApp/model" "github.com/gorilla/mux" ) // Start ... func Start(m *model.Model, listener net.Listener) { r := mux.NewRouter() server := &http.Server{ Handler: r, WriteTimeout: 15 * time.Second, ReadTimeout: 15 * time.Second, } r.Handle("/", h.Index(m)) r.PathPrefix("/static/").Handler(http.StripPrefix("/static/", http.FileServer(http.Dir("static")))) http.Handle("/", r) go server.Serve(listener) }

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

и как стек тебе сделает лучше по сравнению с каналом в данном случае?

Глянул в код. Не сессий. Каналов :) Давно это было ...

я просто смотрю примеры. Там кароч сначала подключение к кролю. Потом там вызывается conn.Channel(). Судя по всему надо их несколько создавать же да?

А он размерами не ограничен. Можно OOM килера сумонить невозбранно

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

вот буфер. канал - это тема, надо попробовать

и как стек тебе сделает лучше по сравнению с каналом в данном случае?

канал не стек, это всё меняет

о! и вот тут уже можно будет навернуть пул

и как стек тебе сделает лучше по сравнению с каналом в данном случае?

мне это проще для себя прелставить - контейнер, в который одна горутина put, а другая pop

я просто смотрю примеры. Там кароч сначала подключение к кролю. Потом там вызывается conn.Channel(). Судя по всему надо их несколько создавать же да?

Да, подключение, потом открытие канала. У меня используется один канал для входящих сообщений, и потом на каждый ответ открывается еще один. Но почему сделал именно так — уже не помню :D

А он размерами не ограничен. Можно OOM килера сумонить невозбранно

если уж пошла такая пьянка, то тогда внешнее персистентное хранилище прикручивать

мне это проще для себя прелставить - контейнер, в который одна горутина put, а другая pop

ну, канал

я просто смотрю примеры. Там кароч сначала подключение к кролю. Потом там вызывается conn.Channel(). Судя по всему надо их несколько создавать же да?

Ага ... мне нужно записать ответ, в очередь которая уже существует (создана раньше), и там стоит проверка на существование данной очереди ... если её нет, то канал будет закрыт (самим кролем), вроде так