rayrust 0.1.0

Rust SDK for Ray distributed computing — wraps the Ray C++ SDK via FFI
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

//! Error types for rayrust.

use std::ffi::NulError;
use std::str::Utf8Error;

use thiserror::Error;

#[derive(Error, Debug)]
pub enum RayError {
    #[error("Ray runtime error: {0}")]
    Runtime(String),

    #[error("Serialization error: {0}")]
    Serialization(String),

    #[error("FFI error: {0}")]
    Ffi(String),

    #[error("Object not found: {0}")]
    ObjectNotFound(String),

    #[error("Null byte in string")]
    NullByte(#[from] NulError),

    #[error("UTF-8 conversion error")]
    Utf8(#[from] Utf8Error),
}

impl From<rmp_serde::encode::Error> for RayError {
    fn from(e: rmp_serde::encode::Error) -> Self {
        RayError::Serialization(e.to_string())
    }
}

impl From<rmp_serde::decode::Error> for RayError {
    fn from(e: rmp_serde::decode::Error) -> Self {
        RayError::Serialization(e.to_string())
    }
}