Method LogsChannel

internal/nodeapi/api.go:112–143

LogsChannel 返回一个把 xray 历史 + 实时日志统一推出的只读通道。 ctx 取消时通道会被关闭。底层基于 coremanager.Manager 的 Subscribe/Unsubscribe。 返回的 chan 会先发送当前缓冲区的全部历史行，然后转入实时订阅模式。

(ctx context.Context)

//
// 返回的 chan 会先发送当前缓冲区的全部历史行，然后转入实时订阅模式。
func (a *API) LogsChannel(ctx context.Context) <-chan string {
out := make(chan string, 64)
mgr := a.activeManager()
go func() {
defer close(out)
for _, line := range mgr.Logs() {
select {
case out <- line:
case <-ctx.Done():
return
}
}
id, ch := mgr.Subscribe()
defer mgr.Unsubscribe(id)
for {
select {
case <-ctx.Done():
return
case line, ok := <-ch:
if !ok {
return
}
select {
case out <- line:
case <-ctx.Done():
return
}
}
}
}()
return out
}

// DoStart 启动核心，返回最新 Status。
func (a *API) DoStart(config, core string) (coremanager.Status, error) {