aboutsummaryrefslogtreecommitdiffstats
path: root/client/go/internal/vespa/document/dispatcher.go
diff options
context:
space:
mode:
authorMartin Polden <mpolden@mpolden.no>2023-04-26 15:49:41 +0200
committerMartin Polden <mpolden@mpolden.no>2023-04-26 15:49:41 +0200
commitf47188b7b2de589ffee511e90759f36bfb0335c1 (patch)
tree02bf4f06d6db2b113473d441fb6f2e90672c9614 /client/go/internal/vespa/document/dispatcher.go
parent374c6b2ceaa45c2afead03f683ba10eafac39e9c (diff)
Print trace when present
Diffstat (limited to 'client/go/internal/vespa/document/dispatcher.go')
-rw-r--r--client/go/internal/vespa/document/dispatcher.go5
1 files changed, 4 insertions, 1 deletions
diff --git a/client/go/internal/vespa/document/dispatcher.go b/client/go/internal/vespa/document/dispatcher.go
index d16a2118e90..51963ff86c7 100644
--- a/client/go/internal/vespa/document/dispatcher.go
+++ b/client/go/internal/vespa/document/dispatcher.go
@@ -64,9 +64,12 @@ func NewDispatcher(feeder Feeder, throttler Throttler, breaker CircuitBreaker, o
}
func (d *Dispatcher) shouldRetry(op documentOp, result Result) bool {
+ if result.Trace != "" {
+ d.msgs <- fmt.Sprintf("feed: trace for %s:\n%s", op.document, result.Trace)
+ }
if result.Success() {
if d.verbose {
- d.msgs <- fmt.Sprintf("feed: successfully fed %s with status %d", op.document.Id, result.HTTPStatus)
+ d.msgs <- fmt.Sprintf("feed: %s succeeded with status %d", op.document, result.HTTPStatus)
}
d.throttler.Success()
d.circuitBreaker.Success()