pub trait Egress { // Required method fn send(&mut self, payload: Payload) -> Result<(), EgressError>; }