Открыть боковую панель
Баринов Сергей Владимирович
Unofficial Ydb client library written on rust
Коммиты
4820b282
Коммит
4820b282
создал
Апр 23, 2023
по автору
Баринов Сергей Владимирович
Просмотр файлов
fix some issues
владелец
3aa94c82
Изменения
2
Скрыть пробелы
Построчно
Рядом
src/client.rs
Просмотр файла @
4820b282
use
std
::
error
::
Error
;
use
std
::
future
::
Future
;
use
async_trait
::
async_trait
;
use
prost
::
Message
;
use
table
::
*
;
use
tonic
::
codegen
::
{
InterceptedService
,
http
}
;
use
tonic
::
codegen
::
InterceptedService
;
use
tonic
::
service
::
Interceptor
;
use
tonic
::
transport
::{
Endpoint
,
Channel
,
Uri
};
use
crate
::
exper
::
YdbResponse
;
use
crate
::
generated
::
ydb
::
discovery
::
v1
::
DiscoveryServiceClient
;
use
crate
::
generated
::
ydb
::
discovery
::{
ListEndpointsResult
,
ListEndpointsRequest
};
use
crate
::
generated
::
ydb
::
table
::
query
::
Query
;
use
crate
::
generated
::
ydb
::
table
::
transaction_control
::
TxSelector
;
use
crate
::
generated
::
ydb
::
table
::{
TransactionSettings
,
OnlineModeSettings
,
ExecuteDataQueryRequest
,
TransactionControl
,
self
,
CreateSessionRequest
,
DeleteSessionRequest
};
use
crate
::
generated
::
ydb
::
table
::
transaction_settings
::
TxMode
;
use
crate
::
generated
::
ydb
::
table
::
v1
::
table_service_client
::
TableServiceClient
;
//use ydb_grpc::ydb_proto::discovery::{v1::discovery_service_client::DiscoveryServiceClient, WhoAmIRequest, WhoAmIResponse, ListEndpointsRequest, WhoAmIResult, ListEndpointsResult};
pub
type
AsciiValue
=
tonic
::
metadata
::
MetadataValue
<
tonic
::
metadata
::
Ascii
>
;
...
...
src/main.rs
Просмотр файла @
4820b282
use
std
::{
future
::
Future
,
env
,
time
::
Duration
};
#![allow(dead_code)]
use
std
::{
env
,
time
::
Duration
};
use
tonic
::{
transport
::{
Certificate
,
ClientTlsConfig
,
Channel
},
codegen
::
InterceptedService
,
service
::
Interceptor
};
//use ydb_grpc::ydb_proto::{discovery::{v1::discovery_service_client::DiscoveryServiceClient, WhoAmIRequest, ListEndpointsRequest}, table::{v1::table_service_client::TableServiceClient, CreateSessionRequest}};
use
exper
::
YdbResponse
;
use
generated
::
google
::
protobuf
::
Any
;
use
crate
::
generated
::
{
ydb
::
{
discovery
::{
ListEndpointsRequest
,
ListEndpointsResponse
,
v1
::
MyStruct
},
table
::{
v1
::
table_service_client
::
TableServiceClient
,
CreateSessionRequest
,
DeleteSessionRequest
,
ExecuteDataQueryRequest
,
query
::
Query
,
self
,
TransactionControl
,
TransactionSettings
,
transaction_settings
::
TxMode
,
OnlineModeSettings
,
transaction_control
::
TxSelector
,
CreateSessionResponse
}},
DiscoveryServiceClient
};
use
crate
::
generated
::
ydb
::
table
::{
ExecuteDataQueryRequest
,
query
::
Query
,
self
,
TransactionControl
,
TransactionSettings
,
transaction_settings
::
TxMode
,
transaction_control
::
TxSelector
};
use
self
::
client
::
{
DBInterceptor
,
Credentials
,
YdbService
}
;
use
self
::
client
::
YdbService
;
mod
pool
;
mod
client
;
...
...
@@ -89,7 +89,7 @@ impl<T> Baz<T> where T: Foo, T::Inner: Bar,
fn
test
()
{
let
baz
=
Baz
::
new
(
1
);
let
s
=
baz
.foo
();
let
_
s
=
baz
.foo
();
}
Редактирование
Предварительный просмотр
Поддерживает Markdown
0%
Попробовать снова
или
прикрепить новый файл
.
Отмена
You are about to add
0
people
to the discussion. Proceed with caution.
Сначала завершите редактирование этого сообщения!
Отмена
Пожалуйста,
зарегистрируйтесь
или
войдите
чтобы прокомментировать