stream

Documentation

Index

• func BroadcastDispatchCommand(req runner.Command) (sessionCount int, err error)
• func Router(root server.Router)
• func UpsertRunnerFromHeartbeat(req runner.HeartbeatReq)
• type RunnerRegistryRow
  • func ListRegisteredRunners() []RunnerRegistryRow

Functions

func BroadcastDispatchCommand

func BroadcastDispatchCommand(req runner.Command) (sessionCount int, err error)

BroadcastDispatchCommand 向当前所有 SSE Runner 连接广播一条指令；返回已连接的会话数（可能为 0）。

func Router

func Router(root server.Router)

func UpsertRunnerFromHeartbeat

func UpsertRunnerFromHeartbeat(req runner.HeartbeatReq)

UpsertRunnerFromHeartbeat 由 Runner 心跳上报更新内存注册表。

Types

type RunnerRegistryRow

type RunnerRegistryRow struct {
	Name   string `json:"name,omitempty"`
	Online int    `json:"online,omitempty"`
	Alias  string `json:"alias,omitempty"`
}

RunnerRegistryRow 控制台列表 JSON 形状（与历史字段对齐）。

func ListRegisteredRunners

func ListRegisteredRunners() []RunnerRegistryRow

ListRegisteredRunners 返回当前内存中登记的 Runner（按 name 排序）。