Struct BusS3Sink 

pub struct BusS3Sink { /* private fields */ }

S3 sink that archives all bus messages as JSONL training records

Implementations

impl BusS3Sink

pub async fn new( bus: Arc<AgentBus>, endpoint: &str, access_key: &str, secret_key: &str, bucket: &str, prefix: &str, ) -> Result<Self>

Create a new bus S3 sink

pub async fn from_config( bus: Arc<AgentBus>, config: BusS3SinkConfig, ) -> Result<Self>

Create sink from configuration

pub async fn from_env(bus: Arc<AgentBus>) -> Result<Self>

Create sink from environment variables

pub async fn ensure_bucket(&self) -> Result<()>

Ensure the bucket exists, creating it if necessary

pub async fn run(self) -> Result<()>

Run the sink loop - subscribes to bus and uploads batches to S3

pub fn bucket(&self) -> &str

Get the bucket name

pub fn prefix(&self) -> &str

Get the prefix