Function startMockServer

internal/nodeagent/agent_test.go:118–130

startMockServer 在 bufconn 上启动 mock，返回 hub + dialer + server stop。

(t *testing.T)

// startMockServer 在 bufconn 上启动 mock，返回 hub + dialer + server stop。
func startMockServer(t *testing.T) (*mockHub, func(context.Context, string) (net.Conn, error), func()) {
	t.Helper()
	lis := bufconn.Listen(bufSize)
	srv := grpc.NewServer()
	hub := newMockHub()
	nodev1.RegisterNodeAgentServer(srv, hub)
	go func() { _ = srv.Serve(lis) }()
	dialer := func(ctx context.Context, _ string) (net.Conn, error) {
		return lis.DialContext(ctx)
	}
	stop := func() { srv.Stop() }
	return hub, dialer, stop
}

// helloProvider 返回一个固定的 hello body。
func helloProvider() (json.RawMessage, error) {