Struct ValkeyStreamIngress 

pub struct ValkeyStreamIngress { /* private fields */ }

Implementations

impl ValkeyStreamIngress

pub fn new(config: ValkeyStreamConfig) -> Result<Self, IngressError>

pub async fn publish( &self, event: &IngressEventEnvelope, ) -> Result<String, IngressError>

pub async fn ensure_group(&self) -> Result<(), IngressError>

pub async fn run_once(&self, engine: &AgentEngine) -> Result<bool, IngressError>

Trait Implementations

impl Clone for ValkeyStreamIngress

fn clone(&self) -> ValkeyStreamIngress

Returns a duplicate of the value.

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

Performs copy-assignment from source.