replicate

type Ack struct {
	LastFrame uint64 `json:"last_ack_frame"`
}

type CatchUpBatch struct {
	From      uint64  `json:"from"`
	To        uint64  `json:"to"`
	Deltas    []Delta `json:"deltas"`
	Truncated bool    `json:"truncated,omitempty"` // journal 深度不足,补发不完整
}

type Config struct {
	// BaselineRatio 当 enter+leave 占当前可见集比例超过此值时发 baseline(默认 0.3)。
	BaselineRatio float64
}

type Delta struct {
	Frame    uint64        `json:"frame"`
	Baseline bool          `json:"baseline,omitempty"`
	Spawn    []EntityState `json:"spawn,omitempty"`
	Update   []EntityState `json:"update,omitempty"`
	Despawn  []string      `json:"despawn,omitempty"`
}

type DirtySet[ID comparable] struct {
	// contains filtered or unexported fields
}

type EntityState struct {
	ID      string  `json:"id"`
	X       float64 `json:"x"`
	Y       float64 `json:"y"`
	Version uint64  `json:"version"`
	Payload any     `json:"payload,omitempty"`
}

type Journal struct {
	// contains filtered or unexported fields
}

type Lookup[ID comparable] func(id ID) (EntityState, bool)

type Projector[ID comparable] struct {
	// contains filtered or unexported fields
}

type Versions[ID comparable] struct {
	// contains filtered or unexported fields
}

type ViewerTrack struct {
	// contains filtered or unexported fields
}