-
Notifications
You must be signed in to change notification settings - Fork 638
LOGBROKER-8783 propose api #537
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
LOGBROKER-8783 propose api #537
Conversation
ildar-khisambeev
commented
Dec 18, 2023
•
edited
Loading
edited
- Propose read policy settings for fed sdk api
Note This is an automated comment that will be appended during run. 🔴 linux-x86_64-release-asan: some tests FAILED for commit d9a994f.
🔴 linux-x86_64-relwithdebinfo: some tests FAILED for commit d9a994f.
|
ydb/public/sdk/cpp/client/ydb_federated_topic/federated_topic.h
Outdated
Show resolved
Hide resolved
ydb/public/sdk/cpp/client/ydb_federated_topic/impl/federated_read_session.cpp
Outdated
Show resolved
Hide resolved
ydb/public/sdk/cpp/client/ydb_federated_topic/impl/federated_read_session.cpp
Outdated
Show resolved
Hide resolved
// 2) OpenSubSessionsImpl, CloseSubSessionsImpl | ||
OpenSubSessionsImpl(); | ||
// 3) TODO LATER reschedule OnFederatedStateUpdate | ||
if (Settings.ReadMirroredEnabled) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Рекомендация: выделить всю ветку ReadMirroredEnabled от и до, для более понятной логики
} | ||
} | ||
|
||
if (databases.empty()) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Обязательно выдать ошибку!
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
EXception в пользователя (если пустой список, то это значит пользователь дал плохой запрос)
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
TODO - возвращать unavailable, чтобы поретраиться
Разделить причину на bad_request и unavailable
ydb/public/sdk/cpp/client/ydb_federated_topic/impl/federated_topic.cpp
Outdated
Show resolved
Hide resolved
fbdd3f2
to
d9a994f
Compare
ydb/public/sdk/cpp/client/ydb_federated_topic/federated_topic.h
Outdated
Show resolved
Hide resolved
ydb/public/sdk/cpp/client/ydb_federated_topic/impl/federated_read_session.h
Show resolved
Hide resolved
⚪
|
⚪
|