Struct dbcrossbarlib::drivers::postgres::PostgresLocator

pub struct PostgresLocator { /* fields omitted */ }

A Postgres database URL and a table name.

This is the central point of access for talking to a running PostgreSQL database.

Trait Implementations

impl Clone for PostgresLocator

fn clone(&self) -> PostgresLocator

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PostgresLocator

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for PostgresLocator

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl FromStr for PostgresLocator

type Err = Error

The associated error which can be returned from parsing.

fn from_str(s: &str) -> Result<Self>

Parses a string s to return a value of this type.

impl Locator for PostgresLocator

fn as_any(&self) -> &dyn Any

Provide a mechanism for casting a dyn Locator back to the underlying, concrete locator type using Rust’s Any type.

fn schema(&self, ctx: Context) -> BoxFuture<Option<Schema>>

Return a table schema, if available.

fn count(
    &self,
    ctx: Context,
    shared_args: SharedArguments<Unverified>,
    source_args: SourceArguments<Unverified>
) -> BoxFuture<usize>

Count the records specified by this locator.

fn local_data(
    &self,
    ctx: Context,
    shared_args: SharedArguments<Unverified>,
    source_args: SourceArguments<Unverified>
) -> BoxFuture<Option<BoxStream<CsvStream>>>

If this locator can be used as a local data source, return a stream of CSV streams. This function type is bit hairy:

fn write_local_data(
    &self,
    ctx: Context,
    data: BoxStream<CsvStream>,
    shared_args: SharedArguments<Unverified>,
    dest_args: DestinationArguments<Unverified>
) -> BoxFuture<BoxStream<BoxFuture<BoxLocator>>>

If this locator can be used as a local data sink, write data to it.

fn write_schema(
    &self,
    _ctx: Context,
    _schema: Schema,
    _if_exists: IfExists
) -> BoxFuture<()>

Write a table schema to this locator, if that’s the sort of thing that we can do.

fn display_output_locators(&self) -> DisplayOutputLocators

Should we display the individual output locations?

fn supports_write_remote_data(&self, _source: &dyn Locator) -> bool

Can we access the data at source directly using write_remote_data?

fn write_remote_data(
    &self,
    _ctx: Context,
    source: BoxLocator,
    _shared_args: SharedArguments<Unverified>,
    _source_args: SourceArguments<Unverified>,
    _dest_args: DestinationArguments<Unverified>
) -> BoxFuture<Vec<BoxLocator>>

Take the data at source, and write to this locator directly, without passing it through the local system.