From 3d183037f6489a39a01701475c768490f60dc794 Mon Sep 17 00:00:00 2001 From: Peter Wilson Date: Tue, 10 Oct 2023 15:50:54 +0100 Subject: [PATCH] Capture errors emitted from all nodes during proccessing of audit pipelines --- vault/audit_broker.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/vault/audit_broker.go b/vault/audit_broker.go index c10f0b4736c5..7fcce78e29f7 100644 --- a/vault/audit_broker.go +++ b/vault/audit_broker.go @@ -216,9 +216,9 @@ func (a *AuditBroker) LogRequest(ctx context.Context, in *logical.LogInput, head e.Data = in - _, err = a.broker.Send(ctx, eventlogger.EventType(event.AuditType.String()), e) + status, err := a.broker.Send(ctx, eventlogger.EventType(event.AuditType.String()), e) if err != nil { - retErr = multierror.Append(retErr, err) + retErr = multierror.Append(retErr, multierror.Append(err, status.Warnings...)) } } } @@ -297,9 +297,9 @@ func (a *AuditBroker) LogResponse(ctx context.Context, in *logical.LogInput, hea e.Data = in - _, err = a.broker.Send(ctx, eventlogger.EventType(event.AuditType.String()), e) + status, err := a.broker.Send(ctx, eventlogger.EventType(event.AuditType.String()), e) if err != nil { - retErr = multierror.Append(retErr, err) + retErr = multierror.Append(retErr, multierror.Append(err, status.Warnings...)) } } }