pub trait InspectSinkProxyInterface: Send + Sync { // Required method fn publish(&self, payload: InspectSinkPublishRequest) -> Result<(), Error>; }