pub trait LogStreamProxyInterface: Send + Sync { // Required method fn connect( &self, socket: Socket, opts: &LogStreamOptions, ) -> Result<(), Error>; }