R
кажется я понял (нет)
такая же ситуация) . вроде да ,а нет
Size: a a a
2020 May 29
AK
я тоже понял, но не советую:) Реализовав протокол
R
в синхронном триггере нельзя йилдить же
а я про винил говорю, асинхронный )
DS
а я про винил говорю, асинхронный )
страшно то как
R
страшно то как
тоже , но это же таранутл, тут все возможно )
MA
я, конечно, за то чтобы втащить vshard router (с оговоркой про новую схему для бакетов выше) в ипрото тред двумя руками.
Костя, может быть тикет и написан не очень ясно
Сейчас нет возможности в Lua перехватить и обработать по своему IPROTO_(SELECT|DELETE|INSERT)
Эта возможность нужна (всплывало нсколько раз в нескольких сценариях)
В том числ это позволяет реализовать прозрачную прокси, конвертирующую обращение с single-ноде в старом формате на вшард
Сейчас нет возможности в Lua перехватить и обработать по своему IPROTO_(SELECT|DELETE|INSERT)
Эта возможность нужна (всплывало нсколько раз в нескольких сценариях)
В том числ это позволяет реализовать прозрачную прокси, конвертирующую обращение с single-ноде в старом формате на вшард
KO
Я уже написал выше, что в теории выглядит красиво, но на практике получается надо как-то научиться различать "клиентские" запросы на insert-select-update-delete и точно такие же запросы от репликации и подсистемы восстановления.
KO
Можно, конечно, сделать всё что угодно.
MA
Репликация делает IPROTO_SELECT?
AK
Не, там свои же хедера
KO
iproto_insert/update/delete от репликации обрабатываются через box-process1
KO
как и iproto_insert/update/delete от iproto
KO
всё проходит через box_process1
AK
А call?
AK
или eval
MA
Костя, не надо говорить как нельзя сделать. Говори, как можно :)
AK
я посмотрел в iproto.cc и кажется там есть возможность вызывать box_process_call из tx_process_select напрмиер
AK
Просто ещё одну роутинговую табличку сделать, сейчас все IPROTO_{SELECT,INSERT,DELTE...} идут в select_route и dml_route
AK
И заполнять эту табличку при вызове спец функции типа register_callback(space_id, IPROTO_SELECT, f)
AK
То же самое для функции tx_process1, там space_id есть в запросе, можно не роутить в box_process1 по умолчанию, а сначала проверять колбэк и роутить в box_process_call