Crate dbcrossbarlib

Source
Expand description

A library for reading and writing table schemas in various formats.

At the moment, the most interesting type here is the schema module, which defines a portable SQL schema.

Re-exports§

pub use tokio_glue::ConsumeWithParallelism;

Modules§

config
Configuration file support.
drivers
Drivers for various schema sources and destinations.
rechunk
Given a stream of streams CSV data, rechunk the stream sizes.
schema
Our “interchange” format for database table schemas.
tokio_glue
Glue code for working with tokio’s async I/O.

Structs§

Context
Context shared by our various asynchronous operations.
CsvStream
A stream of CSV data, with a unique name.
DestinationArguments
Data destination arguments.
DriverArguments
Driver-specific arguments.
Error
Standard error type for this library. The Error type, a wrapper around a dynamic error type.
SharedArguments
Arguments used by both the data source and destination.
SourceArguments
Data source arguments.
TemporaryStorage
Provides different types of temporary storage.
UnparsedLocator
A locator which has not yet been parsed.

Enums§

DataFormat
The format of a stream of data.
DisplayOutputLocators
When called from the CLI, should we display a list of individual locators for each data stream?
IfExists
What to do if the destination already exists.
Unverified
This is used to mark an *Arguments structure that has not yet been verified for compatibility with a specific driver. See the type state pattern for details.
Verified
This is used to mark an *Arguments structure that has not yet been verified for compatibility with a specific driver. See the type state pattern for details.

Traits§

ArgumentState
This is a marker trait used by SharedArguments, SourceArguments and DestinationArguments. We use it to keep track whether or not the arguments have been verified against a driver’s Features list.
Locator
Specify the the location of data or a schema.

Type Aliases§

BoxLocator
A value of an unknown type implementing Locator.
Result
Standard result type for this library.