Struct SpoolId

pub struct SpoolId(/* private fields */);

Identifies a message within the spool of its host node.

Implementations

impl SpoolId

pub fn new() -> Self

pub fn compute_path(&self, in_dir: &Path) -> PathBuf

pub fn as_bytes(&self) -> &[u8; 16]

pub fn from_slice(s: &[u8]) -> Option<Self>

pub fn from_ascii_bytes(s: &[u8]) -> Option<Self>

pub fn from_str(s: &str) -> Option<Self>

pub fn from_path(path: &Path) -> Option<Self>

pub fn age(&self, now: DateTime<Utc>) -> Duration

Returns time elapsed since the id was created, given the current timestamp

pub fn created(&self) -> DateTime<Utc>

pub fn derive_new_with_cloned_timestamp(&self) -> Self

Assuming that self is a SpoolId received from some other node, this method produces a new SpoolId with the information from the local node, but with the timestamp from the source spool id. The intent is to reduces the chances of having multiple messages with the same spool id live on a system in the case of a misconfiguration that produces a loop.

Trait Implementations

impl Clone for SpoolId

fn clone(&self) -> SpoolId

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ComposeSchema for SpoolId

fn compose(generics: Vec<RefOr<Schema>>) -> RefOr<Schema>

impl Debug for SpoolId

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SpoolId

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SpoolId

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for SpoolId

fn fmt(&self, fmt: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<SpoolId> for String

fn from(id: SpoolId) -> String

Converts to this type from the input type.

impl From<Uuid> for SpoolId

fn from(uuid: Uuid) -> Self

Converts to this type from the input type.

impl Hash for SpoolId

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for SpoolId

fn eq(&self, other: &SpoolId) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for SpoolId

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ToSchema for SpoolId

fn name() -> Cow<'static, str>

Return name of the schema.

fn schemas(schemas: &mut Vec<(String, RefOr<Schema>)>)

Implement reference [utoipa::openapi::schema::Schema]s for this type.

impl TryFrom<String> for SpoolId

type Error = Error

The type returned in the event of a conversion error.

fn try_from(s: String) -> Result<Self, Self::Error>

Performs the conversion.

impl Copy for SpoolId

impl Eq for SpoolId

impl StructuralPartialEq for SpoolId