Function newTestBridgeWithRPC

internal/bridge/mockserver_test.go:331–348

--------------------------------------------------------------------------- newTestBridgeWithRPC creates a Bridge connected to a real gRPC client, bypassing NewBridge (which requires mTLS auth files). ---------------------------------------------------------------------------

(t *testing.T, rpcClient listenerrpc.ListenerRPCClient)

// ---------------------------------------------------------------------------

func newTestBridgeWithRPC(t *testing.T, rpcClient listenerrpc.ListenerRPCClient) *Bridge {
	t.Helper()
	ctx, cancel := context.WithCancel(context.Background())
	return &Bridge{
		cfg: &cfgpkg.C2BridgeConfig{
			ListenerName: "test-listener",
			ListenerIP:   "127.0.0.1",
			PipelineName: "test-pipeline",
		},
		rpc:         rpcClient,
		listenerID:  "test-listener",
		pipelineID:  "test-pipeline",
		registry:    buildDefaultRegistry(),
		taskManager: NewTaskManager(),
		ctx:         ctx,
		cancel:      cancel,
	}
}