Struct dbcrossbarlib::drivers::postgres_sql::PostgresSqlLocator [−][src]
pub struct PostgresSqlLocator { /* fields omitted */ }
Expand description
An SQL file containing a CREATE TABLE
statement using Postgres syntax.
Trait Implementations
Provide a mechanism for casting a dyn Locator
back to the underlying,
concrete locator type using Rust’s Any
type. Read more
Return a table schema, if available.
Write a table schema to this locator, if that’s the sort of thing that we can do. Read more
fn count(
&self,
_ctx: Context,
_shared_args: SharedArguments<Unverified>,
_source_args: SourceArguments<Unverified>
) -> BoxFuture<usize>
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>>>
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: Read more
Should we display the individual output locations?
fn write_local_data(
&self,
_ctx: Context,
_data: BoxStream<CsvStream>,
_shared_args: SharedArguments<Unverified>,
_dest_args: DestinationArguments<Unverified>
) -> BoxFuture<BoxStream<BoxFuture<BoxLocator>>>
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. Read more
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>>
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. Read more
Auto Trait Implementations
impl RefUnwindSafe for PostgresSqlLocator
impl Send for PostgresSqlLocator
impl Sync for PostgresSqlLocator
impl Unpin for PostgresSqlLocator
impl UnwindSafe for PostgresSqlLocator
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more