List of all items

Structs

• input::bin::mem::btree::BinSource
• input::bin::mem::btree::RangeII
• input::conv::gzip::gz_tokio::GzipDecodedSrc
• input::conv::lines::ReadSrc
• input::conv::source::ConvSource
• input::group::paste::PasteStream
• input::join::mem::btree::MergedSource
• input::merge::simple::MergedSvc
• input::rpc::SelectClient
• input::source::BucketMerge
• input::source::BucketSrcMapd
• rpc::fs2db::proto::source::v1::AllRequest
• rpc::fs2db::proto::source::v1::AllResponse
• rpc::fs2db::proto::source::v1::DropSvc
• rpc::fs2db::proto::source::v1::InputBucket
• rpc::fs2db::proto::source::v1::drop_service_client::DropServiceClient
• rpc::fs2db::proto::source::v1::drop_service_server::DropServiceServer
• rpc::fs2db::proto::source::v1::drop_svc::CheckedRequest
• rpc::fs2db::proto::source::v1::drop_svc::CheckedResponse
• rpc::fs2db::proto::source::v1::select_service_client::SelectServiceClient
• rpc::fs2db::proto::source::v1::select_service_server::SelectServiceServer
• rpc::fs2db::proto::target::v1::OutputBucket
• rpc::fs2db::proto::target::v1::SelSvc
• rpc::fs2db::proto::target::v1::UpstSvc
• rpc::fs2db::proto::target::v1::sel_svc::AllRequest
• rpc::fs2db::proto::target::v1::sel_svc::AllResponse
• rpc::fs2db::proto::target::v1::select_service_client::SelectServiceClient
• rpc::fs2db::proto::target::v1::select_service_server::SelectServiceServer
• rpc::fs2db::proto::target::v1::upsert_service_client::UpsertServiceClient
• rpc::fs2db::proto::target::v1::upsert_service_server::UpsertServiceServer
• rpc::fs2db::proto::target::v1::upst_svc::ManyRequest
• rpc::fs2db::proto::target::v1::upst_svc::ManyResponse

Traits

• Stream
• StreamExt
• TryStreamExt
• input::bin::mem::btree::ComputeDiff
• input::bin::mem::btree::ComputeNearest
• input::bin::mem::btree::Nearest
• input::bin::mem::btree::Range
• input::conv::lines::FsSource
• input::conv::lines::ReadSource
• input::conv::source::Converter
• input::join::mem::btree::Grouper
• input::join::mem::btree::MemSource
• input::join::mem::btree::Merger
• input::merge::svc::Merge
• input::merge::svc::MergeSource
• input::select::Select
• input::source::BucketSource
• input::source::Mapper
• input::source::Merge
• input::source::Source
• output::async_tokio::Transaction
• output::upsert::Upsert
• rpc::fs2db::proto::source::v1::drop_service_server::DropService
• rpc::fs2db::proto::source::v1::select_service_server::SelectService
• rpc::fs2db::proto::target::v1::select_service_server::SelectService
• rpc::fs2db::proto::target::v1::upsert_service_server::UpsertService

Functions

• conv::rpc::src2tgt::drop_all_if_verified
• conv::rpc::src2tgt::upsert_selected
• conv::s2t::upsert_selected
• input::bin::mem::btree::mem_src_bin_new
• input::conv::gzip::gz_tokio::read_src_gzip_decoded_new
• input::conv::lines::bytes_src_new
• input::conv::source::conv_source_new
• input::group::paste::buckets2stream
• input::group::paste::streams2stream
• input::join::mem::btree::grouped_src_new
• input::join::mem::btree::mem_src_new
• input::join::mem::btree::merged_src_new
• input::lines::json::async_tokio::from_slices
• input::lines::json::async_tokio::from_strings
• input::lines::json::sync::from_slices
• input::lines::json::sync::from_strings
• input::lines::plain::async_tokio::path2slices
• input::lines::plain::async_tokio::path2strings
• input::lines::plain::sync::path2slices
• input::lines::plain::sync::path2strings
• input::merge::simple::source_new_merged
• input::source::bkt_src_merged_new
• input::source::mapd_bkt_src_new
• output::async_tokio::save_many
• output::sync::save_many