🥮 mooncakes.io

    mokomoking2501/lockwire/core does not have a README file

    Endpoint

    source
    pub(open) trait Endpoint {
      fn on_rx(Self, RxEvent) -> Unit
      fn on_tick(Self, VTime) -> Unit
    }

    Medium

    source
    pub(open) trait Medium {
      fn submit(Self, TxEvent) -> Array[RxEvent] raise TransportError
      fn lookahead(Self) -> Duration
    }

    PointToPointMedium

    source
    pub(open) trait PointToPointMedium : Medium {
      fn bind(Self, EndpointId, EndpointId) -> Unit
    }

    Reactor

    source
    pub(open) trait Reactor {
      fn now(Self) -> VTime
      fn schedule(Self, TxEvent) -> Unit raise TransportError
      fn run(Self) -> SimDigest raise TransportError
    }

    TransportError

    source
    pub(all) suberror TransportError {
      LinkDown
      InvalidFrame(String)
      UnboundEndpoint(EndpointId)
    } derive(
    Debug    )

    BackendProfile

    source
    pub(all) enum BackendProfile {
      SimNative
      SimWasm
      Replay
      RealLinux
      RealEmbedded
    } derive(Eq, 
    Debug    )

    BackendProfile::is_deterministic

    source
    fn BackendProfile::is_deterministic(profile : BackendProfile) -> Bool

    Channel

    source
    pub(all) struct Channel {
      id : ChannelId
      next_seq : Int
    } derive(Eq, 
    Debug    )

    Channel::new

    source
    fn Channel::new(id~ : ChannelId) -> Channel

    Channel::reserve

    source
    fn Channel::reserve(self : Channel) -> (Channel, Int)

    ChannelId

    source
    pub(all) enum ChannelId {
      ChannelId(Int)
    } derive(Compare, Eq, 
    Debug    )

    ChannelId::value

    source
    fn ChannelId::value(self : ChannelId) -> Int

    Duration

    source
    pub(all) enum Duration {
      Duration(Int64)
    } derive(Compare, Eq, 
    Debug    )

    Duration::from_ns

    source
    fn Duration::from_ns(ns : Int64) -> Duration

    Duration::ns

    source
    fn Duration::ns(self : Duration) -> Int64

    EndpointId

    source
    pub(all) enum EndpointId {
      EndpointId(Int)
    } derive(Compare, Eq, 
    Debug    )

    EndpointId::value

    source
    fn EndpointId::value(self : EndpointId) -> Int

    Frame

    source
    pub(all) struct Frame {
      id : Int
      payload : Bytes
      state : FrameState
    } derive(Eq, 
    Debug    )

    Frame::acquire

    source
    fn Frame::acquire(id~ : Int) -> Frame

    Frame::filled

    source
    fn Frame::filled(self : Frame, payload~ : Bytes) -> Frame

    Frame::received

    source
    fn Frame::received(self : Frame) -> Frame

    Frame::receiving

    source
    fn Frame::receiving(self : Frame) -> Frame

    Frame::released

    source
    fn Frame::released(self : Frame) -> Frame

    Frame::sending

    source
    fn Frame::sending(self : Frame) -> Frame

    Frame::sent

    source
    fn Frame::sent(self : Frame) -> Frame

    FrameState

    source
    pub(all) enum FrameState {
      Free
      Acquired
      Filled
      Sending
      Sent
      Receiving
      Received
      Released
    } derive(Eq, 
    Debug    )

    LinearizationKey

    source
    pub(all) struct LinearizationKey {
      vtime : VTime
      channel_id : ChannelId
      seq : Int
      parent_sort : Int
      event_id : Int
    } derive(Compare, Eq, 
    Debug    )

    MvpStage

    source
    pub(all) enum MvpStage {
      M0Skeleton
      M1CoreP2p
      M2ScenarioEvent
      M3TraceReplay
      M4FaultResource
      M5NativeWasmDiff
      M6SegmentToy
      M7Packaging
    } derive(Eq, 
    Debug    )

    PortId

    source
    pub(all) enum PortId {
      PortId(Int)
    } derive(Compare, Eq, 
    Debug    )

    RxEvent

    source
    pub(all) struct RxEvent {
      id : Int
      parent_id : Int
      vtime : VTime
      channel_id : ChannelId
      seq : Int
      source : EndpointId
      target : EndpointId
      frame : Frame
    } derive(Eq, 
    Debug    )

    SimDigest

    source
    pub(all) struct SimDigest {
      state_digest : Int64
      rng_steps : Int
      event_count : Int
    } derive(Eq, 
    Debug    )

    SimDigest::empty

    source
    fn SimDigest::empty(seed~ : Int) -> SimDigest

    SimDigest::mix

    source
    fn SimDigest::mix(self : SimDigest, value : Int) -> SimDigest

    SimDigest::step_rng

    source
    fn SimDigest::step_rng(self : SimDigest) -> SimDigest

    TxEvent

    source
    pub(all) struct TxEvent {
      id : Int
      parent_id : Int?
      vtime : VTime
      channel_id : ChannelId
      seq : Int
      source : EndpointId
      target : EndpointId
      frame : Frame
    } derive(Eq, 
    Debug    )

    TxEvent::linearization_key

    source
    fn TxEvent::linearization_key(self : TxEvent) -> LinearizationKey

    TxEvent::make

    source
    fn TxEvent::make(id~ : Int, parent_id? : Int, vtime~ : VTime, channel_id~ : ChannelId, seq~ : Int, source~ : EndpointId, target~ : EndpointId, frame~ : Frame) -> TxEvent

    VTime

    source
    pub(all) enum VTime {
      VTime(Int64)
    } derive(Compare, Eq, 
    Debug    )

    VTime::add

    source
    fn VTime::add(self : VTime, delta : Duration) -> VTime

    VTime::from_ns

    source
    fn VTime::from_ns(ns : Int64) -> VTime

    VTime::ns

    source
    fn VTime::ns(self : VTime) -> Int64

    backend_profile_label

    source
    fn backend_profile_label(profile : BackendProfile) -> String

    backend_profiles

    source
    fn backend_profiles() -> Array[BackendProfile]

    check_rx_invariants

    source
    fn check_rx_invariants(events : ArrayView[RxEvent]) -> Bool

    mvp_stage_label

    source
    fn mvp_stage_label(stage : MvpStage) -> String

    mvp_stages

    source
    fn mvp_stages() -> Array[MvpStage]

    package_id

    source
    fn package_id() -> String

    rx_event_precedes

    source
    fn rx_event_precedes(left : RxEvent, right : RxEvent) -> Bool

    tx_event_precedes

    source
    fn tx_event_precedes(left : TxEvent, right : TxEvent) -> Bool

    Source Files

    Powered by MoonBit

    Site sourceReport issueModulesSkillsBuild queueStatistics

    © 2026 mooncakes.io