Struct session

internal/nodeagent/session.go:73–86

session 是单次 Session 的状态： - inflight：reqID -> cancelFunc，用于响应 cancel_id； - acks：seq -> chan struct{}，用于 WaitAck； - sendMu：保护 stream.Send，多 goroutine 串行写。

//   - acks：seq -> chan struct{}，用于 WaitAck；
//   - sendMu：保护 stream.Send，多 goroutine 串行写。
type session struct {
	ctx    context.Context
	cancel context.CancelFunc
	cfg    Config
	stream nodev1.NodeAgent_SessionClient

	sendMu sync.Mutex

	mu       sync.Mutex
	inflight map[string]context.CancelFunc
	acks     map[uint64]chan struct{}

	wg sync.WaitGroup
}

func newSession(ctx context.Context, cancel context.CancelFunc, cfg Config, stream nodev1.NodeAgent_SessionClient) *session {
	return &session{