Struct RestartCoordinationSocket 

pub struct RestartCoordinationSocket { /* private fields */ }

Represents the restart coordination socket, used for communicating with a running oxy process. This is used to trigger a restart and receive notification of its completion or failure.

Implementations

impl RestartCoordinationSocket

pub fn new(socket: UnixStream) -> Self

Create a new RestartCoordinationSocket wrapping a unix socket.

pub async fn send_restart_command(&mut self) -> RestartResult<u32>

Sends a restart command through the socket. Returns Ok(child_pid) on success or an error if the restart failed for any reason.

pub async fn send_message(&mut self, msg: RestartMessage) -> RestartResult<()>

Send a message over the socket

pub async fn receive_message(&mut self) -> RestartResult<RestartMessage>

Receive a message from the socket.