Struct buildsrs_builder::Connection

pub struct Connection { /* private fields */ }

WebSocket connection to receive jobs

Implementations

impl Connection

pub async fn connect( strategy: DynStrategy, private_key: PrivateKey, url: &Url ) -> Result<Self>

Connect to WebSocket endpoint.

pub fn new( strategy: DynStrategy, websocket: WebSocketStream<MaybeTlsStream<TcpStream>>, private_key: PrivateKey ) -> Self

Create new connection.

pub async fn send(&mut self, message: ClientMessage) -> Result<()>

Send a signed [ClientMessage].

pub async fn recv( websocket: &mut WebSocketStream<MaybeTlsStream<TcpStream>> ) -> Result<ServerMessage>

Receive a [ServerMessage].

pub async fn authenticate(&mut self) -> Result<()>

Authenticate to server.

pub async fn tasks_sync(&mut self) -> Result<()>

Synchronize tasks with server.

pub async fn handle_iter(&mut self) -> Result<()>

Handle a single iteration.

pub async fn handle(&mut self) -> Result<()>

Handle messages and events.