IG
Пиши в очередь, читай из очереди.
Size: a a a
2020 June 18
E
Andrei Grazhdankov
Всем привет, нужна помощь по grpc) help!!! Возможно ли регулировать buffer size в grpc server stream на стороне сервера, чтоб при достижении максимум буффера он стопался и ждал освобождения места и после уменьшения переделывал далее. Клиент не успевает быстро обрабатывать сообщения и боюсь что в этом случае произойдёт коллапс в один прекрасный момент.
Освобождалось место где?
IG
У тебя коллапс все равно случится, если клиент тупить будет. Либо память на сервере кончится в буфере, либо дропать данные придётся
AG
Пиши в очередь, читай из очереди.
А-ля из rabbit?
AG
У меня клиент на Python , сервер на go - уточнение
IG
Andrei Grazhdankov
А-ля из rabbit?
Аля кафка
IG
Ну или что там у вас для этого используется в компании
с
эх, такой облом... в go2go
не валидно (ругается с methods cannot have type parameters)
хотя в пропозале про это ничего не сказано (но мб я не увидел)
Upd: про это там таки написано, но буквально пара предложений
type Stream(T) interface {
...
Map(type V)(f func(T)V) Stream(V)
}не валидно (ругается с methods cannot have type parameters)
хотя в пропозале про это ничего не сказано (но мб я не увидел)
Upd: про это там таки написано, но буквально пара предложений
func Map(type From, To)(s Stream(From), f func(From)To) Stream(To) {
}ВС
ну видимо только так, да
ВС
кстати в пропозале так и предлагали делать
с
ну там много интересных предложений
ВС
выходит правда не так красиво, цепочка теряется
хотелось бы x.Filter(...).Order(...).Map(...).Reduce(...)
а получится Map(x.Filter(...).Order(...), ...).Reduce(...)
хотелось бы x.Filter(...).Order(...).Map(...).Reduce(...)
а получится Map(x.Filter(...).Order(...), ...).Reduce(...)
C
func Map(type From, To)(s Stream(From), f func(From)To) Stream(To) {
}блин вот эти (())())((()()
с
блин вот эти (())())((()()
нам нужен where clause)
C
нам нужен where clause)
да
с
выходит правда не так красиво, цепочка теряется
хотелось бы x.Filter(...).Order(...).Map(...).Reduce(...)
а получится Map(x.Filter(...).Order(...), ...).Reduce(...)
хотелось бы x.Filter(...).Order(...).Map(...).Reduce(...)
а получится Map(x.Filter(...).Order(...), ...).Reduce(...)
как в питоне
с
только там еще gen expr есть