Struct HistorySinkConfig 

pub struct HistorySinkConfig {
    pub endpoint: String,
    pub access_key: String,
    pub secret_key: String,
    pub bucket: String,
    pub prefix: String,
}

Durable history-sink configuration.

Intentionally owned (not borrowed) so the config can be handed to a tokio::spawn fire-and-forget upload without tying its lifetime to the Session.

Examples

use codetether_agent::session::history_sink::HistorySinkConfig;

let cfg = HistorySinkConfig {
    endpoint: "http://localhost:9000".to_string(),
    access_key: "minioadmin".to_string(),
    secret_key: "minioadmin".to_string(),
    bucket: "codetether".to_string(),
    prefix: "history/".to_string(),
};
assert_eq!(cfg.bucket, "codetether");

Fields

endpoint: String

MinIO / S3 endpoint URL, e.g. http://localhost:9000.

access_key: String

S3 access key.

secret_key: String

S3 secret key.

bucket: String

Destination bucket.

prefix: String

Key prefix under the bucket. Always ends with /.

Implementations

impl HistorySinkConfig

pub fn from_env() -> Result<Option<Self>>

Load the config from environment variables.

Returns Ok(None) when any required variable is unset — callers treat that as sink disabled and skip the upload. Returns Err(_) only when an env variable is present but malformed.

Errors

Never in the current implementation; reserved for future URL / region validation.

pub fn object_key(&self, session_id: &str) -> String

Object key for the full transcript of session_id.

Example: history/1234-abcd/history.jsonl.

Trait Implementations

impl Clone for HistorySinkConfig

fn clone(&self) -> HistorySinkConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HistorySinkConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for HistorySinkConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for HistorySinkConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.