Struct S3Connector 

pub struct S3Connector {
    name: String,
    config: S3ConnectorConfig,
}

An S3 connector instance that implements the Connector trait.

Wraps the scan_s3 function, allowing S3 connectors to be used through the unified trait-based dispatch.

Fields

name: String

Instance name (e.g. "runbooks").

config: S3ConnectorConfig

Configuration for this S3 connector instance.

Implementations

impl S3Connector

pub fn new(name: String, config: S3ConnectorConfig) -> Self

Create a new S3 connector instance.

Trait Implementations

impl Connector for S3Connector

fn name(&self) -> &str

Returns the connector instance name (e.g. "docs", "platform").

fn description(&self) -> &str

Returns a one-line description of what this connector does.

fn connector_type(&self) -> &str

Returns the connector type identifier (e.g. "filesystem", "git", "s3", "custom").

fn scan<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<SourceItem>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Scan the data source and return all items to ingest.

fn source_label(&self) -> String

Returns the source label used to tag documents from this connector.