pub trait LogSinkProxyInterface: Send + Sync {
type WaitForInterestChangeResponseFut: Future<Output = Result<LogSinkWaitForInterestChangeResult, Error>> + Send;
// Required methods
fn connect(&self, socket: Socket) -> Result<(), Error>;
fn wait_for_interest_change(&self) -> Self::WaitForInterestChangeResponseFut;
fn connect_structured(&self, socket: Socket) -> Result<(), Error>;
}