Struct Endpoint 

pub struct Endpoint {
    pub id: EndpointId,
    pub owner: ProcessId,
    pub queue: Mutex<MessageQueue>,
    pub active: AtomicBool,
    pub message_count: AtomicU64,
}

Endpoint structure with message queue

Fields

id: EndpointId

Endpoint ID

owner: ProcessId

Owner process

queue: Mutex<MessageQueue>

Message queue

active: AtomicBool

Active flag

message_count: AtomicU64

Message counter

Implementations

impl Endpoint

pub fn new(id: EndpointId, owner: ProcessId) -> Self

Create a new endpoint

pub fn close(&self)

Close the endpoint

pub fn is_active(&self) -> bool

Check if endpoint is active