Crate dbcrossbarlib

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 Definitions

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