RFC: TSessionSynced

[asmyasnikov]

Предлагается дописать рядом с TSession класс TSessionSynced, оборачивающий асинхронную (возвращающую TFuture<Some>) сессию TSession с теми же самыми методами, что есть у TSession.

class TSessionSynced {
    NYdb::NTable::TSession *asyncSession;
    
public:
    //! The following methods perform corresponding calls.
    //! Results are NThreading::TFuture<T> where T is corresponding result.
    void CreateTable(const std::string& path, TTableDescription&& tableDesc,
        const TCreateTableSettings& settings = TCreateTableSettings());

    void DropTable(const std::string& path, const TDropTableSettings& settings = TDropTableSettings());

    void AlterTable(const std::string& path, const TAlterTableSettings& settings = TAlterTableSettings());

    // Same as AlterTable but may return operation in case of long running
    void AlterTableLong(const std::string& path, const TAlterTableSettings& settings = TAlterTableSettings());

    void CopyTable(const std::string& src, const std::string& dst,
        const TCopyTableSettings& settings = TCopyTableSettings());

    void CopyTables(const std::vector<TCopyItem>& copyItems,
        const TCopyTablesSettings& settings = TCopyTablesSettings());

    void RenameTables(const std::vector<TRenameItem>& renameItems,
        const TRenameTablesSettings& settings = TRenameTablesSettings());

    TTableDescription DescribeTable(const std::string& path,
        const TDescribeTableSettings& settings = TDescribeTableSettings());

    const TTransaction& BeginTransaction(const TTxSettings& txSettings = TTxSettings(),
        const TBeginTxSettings& settings = TBeginTxSettings());

    TExplainQueryResult ExplainDataQuery(const std::string& query,
        const TExplainDataQuerySettings& settings = TExplainDataQuerySettings());

    TPrepareQueryResult PrepareDataQuery(const std::string& query,
        const TPrepareDataQuerySettings& settings = TPrepareDataQuerySettings());

    TDataQueryResult ExecuteDataQuery(const std::string& query, const TTxControl& txControl,
        const TExecDataQuerySettings& settings = TExecDataQuerySettings());

    DataQueryResult ExecuteDataQuery(const std::string& query, const TTxControl& txControl,
        const TParams& params, const TExecDataQuerySettings& settings = TExecDataQuerySettings());

    DataQueryResult ExecuteDataQuery(const std::string& query, const TTxControl& txControl,
        TParams&& params, const TExecDataQuerySettings& settings = TExecDataQuerySettings());

    Status ExecuteSchemeQuery(const std::string& query,
        const TExecSchemeQuerySettings& settings = TExecSchemeQuerySettings());

    TablePartIterator ReadTable(const std::string& path,
        const TReadTableSettings& settings = TReadTableSettings());

    void Close(const TCloseSessionSettings& settings = TCloseSessionSettings());

    KeepAliveResult KeepAlive(const TKeepAliveSettings& settings = TKeepAliveSettings());

    void InvalidateQueryCache();

    //! Returns new table builder
    TTableBuilder GetTableBuilder();
    //! Returns new params builder
    TParamsBuilder GetParamsBuilder();
    //! Returns new type builder
    TTypeBuilder GetTypeBuilder();
    //! Returns session id
    const std::string& GetId() const;

    TSessionSynced(const TSession& asyncSession);
};

Тогда на клиенте можно будет использовать старые retryOperation с асинхронной сессией

tableClient.RetryOperationSync([](NYdb::NTable::TSession tableSession){
    auto syncedSession = NYdb::NTable::TSessionSynced(tableSession);

    auto transaction = syncedSession.BeginTransaction();
    
    auto resultSet = driver.Table().ExecuteDataQuery("SELECT a, b, c from `example_table`");
        // parse result

    return transaction.Commit();
});