Struct BusS3SinkConfig 

pub struct BusS3SinkConfig {
    pub endpoint: String,
    pub access_key: String,
    pub secret_key: String,
    pub bucket: String,
    pub prefix: String,
    pub batch_size: usize,
    pub flush_interval_secs: u64,
    pub secure: bool,
    pub ignore_cert: bool,
}

Configuration for the bus S3 sink

Fields

endpoint: String

MinIO/S3 endpoint URL (e.g., “http://localhost:9000”)

access_key: String

Access key

secret_key: String

Secret key

bucket: String

Bucket name for bus logs

prefix: String

Path prefix within the bucket

batch_size: usize

Batch size before flushing to S3

flush_interval_secs: u64

Max batch age in seconds before flushing

secure: bool

Whether to use SSL/TLS

ignore_cert: bool

Whether to ignore certificate errors (for self-signed certs)

Implementations

impl BusS3SinkConfig

pub fn from_env() -> Result<Self>

Create config from environment variables

Required:

• MINIO_ENDPOINT or CODETETHER_BUS_S3_ENDPOINT
• MINIO_ACCESS_KEY or CODETETHER_BUS_S3_ACCESS_KEY
• MINIO_SECRET_KEY or CODETETHER_BUS_S3_SECRET_KEY

Optional:

• CODETETHER_BUS_S3_BUCKET (default: “codetether-training”)
• CODETETHER_BUS_S3_PREFIX (default: “bus/”)

pub async fn from_env_or_vault() -> Result<Self>

Create config by trying multiple credential sources in order:

1. Bus-specific env vars (MINIO_ENDPOINT, CODETETHER_BUS_S3_ENDPOINT)
2. Chat-sync env vars (CODETETHER_CHAT_SYNC_MINIO_ENDPOINT)
3. Vault secrets at secret/codetether/providers/chat-sync-minio

Trait Implementations

impl Clone for BusS3SinkConfig

fn clone(&self) -> BusS3SinkConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BusS3SinkConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BusS3SinkConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for BusS3SinkConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.