async fn[T] Dataset::collect(self : Dataset[Array[T]], ctx : MoonlightContext) -> ImmediateData[Array[T]]

async fn MoonlightClusterConfig::start(self : MoonlightClusterConfig, f : async (MoonlightContext) -> Unit) -> Unit

async fn[T] MoonlightContext::immediate(self : MoonlightContext, data : T) -> ImmediateData[T]

async fn[In : 
@Milky2018/moonchor.Message
Message + ToJson + 
@moonbitlang/core/json.FromJson
FromJson, Out : 
@Milky2018/moonchor.Message
Message + ToJson + 
@moonbitlang/core/json.FromJson
FromJson] MoonlightContext::remote_run(self : MoonlightContext, task : (In) -> Out, arg : ImmediateData[In]) -> ImmediateData[Out]