need resultsObserver when cloning

systay · systay · commit 55b951a76d2c · 2024-08-29T08:18:51.000+02:00
Signed-off-by: Andres Taylor &lt;andres@planetscale.com&gt;
diff --git a/go/vt/vtgate/vcursor_impl.go b/go/vt/vtgate/vcursor_impl.go
@@ -1328,6 +1328,7 @@ func (vc *vcursorImpl) cloneWithAutocommitSession() *vcursorImpl {
 		topoServer:      vc.topoServer,
 		warnShardedOnly: vc.warnShardedOnly,
 		pv:              vc.pv,
+		resultsObserver: vc.resultsObserver,
 	}
 }
 
@@ -1432,6 +1433,7 @@ func (vc *vcursorImpl) CloneForMirroring(ctx context.Context) engine.VCursor {
 		warnShardedOnly:     vc.warnShardedOnly,
 		warnings:            vc.warnings,
 		pv:                  vc.pv,
+		resultsObserver:     vc.resultsObserver,
 	}
 
 	v.marginComments.Trailing += "/* mirror query */"

Original file line number	Diff line number	Diff line change
`@@ -1328,6 +1328,7 @@ func (vc vcursorImpl) cloneWithAutocommitSession() vcursorImpl {`
`1328`	`1328`	`topoServer: vc.topoServer,`
`1329`	`1329`	`warnShardedOnly: vc.warnShardedOnly,`
`1330`	`1330`	`pv: vc.pv,`
	`1331`	`+ resultsObserver: vc.resultsObserver,`
`1331`	`1332`	`}`
`1332`	`1333`	`}`
`1333`	`1334`
`@@ -1432,6 +1433,7 @@ func (vc *vcursorImpl) CloneForMirroring(ctx context.Context) engine.VCursor {`
`1432`	`1433`	`warnShardedOnly: vc.warnShardedOnly,`
`1433`	`1434`	`warnings: vc.warnings,`
`1434`	`1435`	`pv: vc.pv,`
	`1436`	`+ resultsObserver: vc.resultsObserver,`
`1435`	`1437`	`}`
`1436`	`1438`
`1437`	`1439`	`v.marginComments.Trailing += "/* mirror query */"`