mooncakes.io

benchmarks
→
cmd
→
core
→
examples
→
network
→
resource
→
scheduler
→
stats
→
trace
→
README
T
Simulation
- ::active_event_countSimulation::active_event_count
- ::clockSimulation::clock
- ::create_network_topologySimulation::create_network_topology
- ::create_percentile_trackerSimulation::create_percentile_tracker
- ::create_resourceSimulation::create_resource
- ::create_rolling_summarySimulation::create_rolling_summary
- ::create_schedulerSimulation::create_scheduler
- ::create_sla_monitorSimulation::create_sla_monitor
- ::create_summarySimulation::create_summary
- ::create_tracerSimulation::create_tracer
- ::eventsSimulation::events
- ::get_resourceSimulation::get_resource
- ::get_summarySimulation::get_summary
- ::newSimulation::new
- ::nowSimulation::now
- ::register_processSimulation::register_process
- ::resetSimulation::reset
- ::runSimulation::run
- ::run_untilSimulation::run_until
- ::scheduleSimulation::schedule
- ::schedule_atSimulation::schedule_at
- ::start_processSimulation::start_process
- ::stepSimulation::step

README

wcx789ll/moonsim/resource does not have a README file

#
ActiveHolder

pub(all) struct ActiveHolder {
  id : Int
  amount : Int
  priority : Int
  preempt_callback : () -> Unit
}

#
Container

source

pub(all) struct Container {
  name : String
  capacity : Double
  level : Double
  // private fields
}

#
Container::capacity

source

fn Container::capacity(self : Container) -> Double

#
Container::get

source

fn Container::get(self : Container, amount : Double, callback : (Bool) -> Unit) -> Unit

#
Container::level

source

fn Container::level(self : Container) -> Double

#
Container::new

source

fn Container::new(name : String, capacity : Double, initial_level : Double) -> Container

#
Container::put

source

fn Container::put(self : Container, amount : Double, callback : (Bool) -> Unit) -> Unit

#
PreemptibleResource

source

pub(all) struct PreemptibleResource {
  name : String
  capacity : Int
  available : Int
  next_req_id : Int
  next_holder_id : Int
  // private fields
}

#
PreemptibleResource::available

source

fn PreemptibleResource::available(self : PreemptibleResource) -> Int

#
PreemptibleResource::capacity

source

fn PreemptibleResource::capacity(self : PreemptibleResource) -> Int

#
PreemptibleResource::holder_count

source

fn PreemptibleResource::holder_count(self : PreemptibleResource) -> Int

#
PreemptibleResource::is_holder_active

source

fn PreemptibleResource::is_holder_active(self : PreemptibleResource, holder_id : Int) -> Bool

Return whether a holder token is still active.

A preempted holder becomes inactive immediately. Delayed completion callbacks should check this before releasing capacity or recording a successful completion, because the callback may run after preemption.

#
PreemptibleResource::new

source

fn PreemptibleResource::new(name : String, capacity : Int) -> PreemptibleResource

#
PreemptibleResource::release

source

fn PreemptibleResource::release(self : PreemptibleResource, holder_id : Int) -> Unit

#
PreemptibleResource::request

source

fn PreemptibleResource::request(self : PreemptibleResource, amount : Int, priority : Int, callback : (Int?) -> Unit, preempt_callback : () -> Unit) -> Int

#
Resource

source

pub(all) struct Resource {
  name : String
  capacity : Int
  available : Int
  next_req_id : Int
  // private fields
}

#
Resource::available

source

fn Resource::available(self : Resource) -> Int

#
Resource::cancel_request

source

fn Resource::cancel_request(self : Resource, req_id : Int) -> Bool

#
Resource::capacity

source

fn Resource::capacity(self : Resource) -> Int

#
Resource::new

source

fn Resource::new(name : String, capacity : Int) -> Resource

#
Resource::queue_length

source

fn Resource::queue_length(self : Resource) -> Int

#
Resource::release

source

fn Resource::release(self : Resource, amount : Int) -> Unit

#
Resource::request

source

fn Resource::request(self : Resource, amount : Int, priority : Int, callback : (Bool) -> Unit) -> Int

#
ResourceRequest

source

pub(all) struct ResourceRequest {
  id : Int
  amount : Int
  priority : Int
  callback : (Bool) -> Unit
  cancelled : Bool
}

#
Store

source

pub(all) struct Store[T] {
  name : String
  capacity : Int
  // private fields
}

#
Store::capacity

source

fn[T] Store::capacity(self : Store[T]) -> Int

#
Store::get

source

fn[T] Store::get(self : Store[T], callback : (T) -> Unit) -> Unit

#
Store::new

source

fn[T] Store::new(name : String, capacity : Int) -> Store[T]

#
Store::put

source

fn[T] Store::put(self : Store[T], item : T, callback : () -> Unit) -> Unit

#
Store::size

source

fn[T] Store::size(self : Store[T]) -> Int

#
StoreGetRequest

source

pub(all) struct StoreGetRequest[T] {
  callback : (T) -> Unit
}

#
StorePutRequest

source

pub(all) struct StorePutRequest[T] {
  item : T
  callback : () -> Unit
}

#
request_with_timeout

source

fn request_with_timeout(mgr : @wcx789ll/moonsim/core/event.EventManager
EventManager, res : Resource, amount : Int, priority : Int, timeout : Double, callback : (Bool) -> Unit) -> @wcx789ll/moonsim/core/clock.EventId
EventId

Source Files

Site source Report issue Packages Build queue Skills Statistics

#ActiveHolder

#Container

#Container::capacity

#Container::get

#Container::level

#Container::new

#Container::put

#PreemptibleResource

#PreemptibleResource::available

#PreemptibleResource::capacity

#PreemptibleResource::holder_count

#PreemptibleResource::is_holder_active

#PreemptibleResource::new

#PreemptibleResource::release

#PreemptibleResource::request

#Resource

#Resource::available

#Resource::cancel_request

#Resource::capacity

#Resource::new

#Resource::queue_length

#Resource::release

#Resource::request

#ResourceRequest

#Store

#Store::capacity

#Store::get

#Store::new

#Store::put

#Store::size

#StoreGetRequest

#StorePutRequest

#request_with_timeout

Source Files

#
ActiveHolder

#
Container

#
Container::capacity

#
Container::get

#
Container::level

#
Container::new

#
Container::put

#
PreemptibleResource

#
PreemptibleResource::available

#
PreemptibleResource::capacity

#
PreemptibleResource::holder_count

#
PreemptibleResource::is_holder_active

#
PreemptibleResource::new

#
PreemptibleResource::release

#
PreemptibleResource::request

#
Resource

#
Resource::available

#
Resource::cancel_request

#
Resource::capacity

#
Resource::new

#
Resource::queue_length

#
Resource::release

#
Resource::request

#
ResourceRequest

#
Store

#
Store::capacity

#
Store::get

#
Store::new

#
Store::put

#
Store::size

#
StoreGetRequest

#
StorePutRequest

#
request_with_timeout