realtime

package

v0.25.0 Latest Latest Go to latest Published: Oct 11, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Package realtime provides soft real-time primitives: fixed-timestep loop generators, timing wheels, and lock-free topics.

View Source

const ID = "realtime"

View Source

var TopicKey = xctx.NewKey[interface{ Publish(any) }]("realtime.topic")

TopicKey provides the lock-free broadcast channel for the current room.

View Source

var WheelKey = xctx.NewKey[*timing.Wheel]("realtime.wheel")

WheelKey provides the game loop's timing wheel.

func Bundle(_ map[string]string) core.Bundle

func Library() action.Library

func TickerSource() action.AnyStreamAction

TickerSource wraps the kernel's fixed-timestep stream.

func TopicPublishAction() action.AnyAction

func WheelAdvanceAction() action.AnyAction

func WheelCancelAction() action.AnyAction

func WheelScheduleAction() action.AnyAction

type TicksReq struct {
	Hz           int `json:"hz"`
	MaxCatchupMs int `json:"max_catchup_ms"`
}

type WheelScheduleReq struct {
	DelayMs int64 `json:"delay_ms"`
	Payload any   `json:"payload"`
}

type WheelScheduleRes struct {
	TimerID uint64 `json:"timer_id"`
}