From 89dbd2eb39528658ec5198cf77c6d9126a7f861c Mon Sep 17 00:00:00 2001 From: Camden Cheek Date: Fri, 17 Jul 2020 16:24:13 -0400 Subject: [PATCH] Add another missing case to the google cloud output --- plugin/builtin/output/google_cloud.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/plugin/builtin/output/google_cloud.go b/plugin/builtin/output/google_cloud.go index 7a547a8bf..7ff006bc0 100644 --- a/plugin/builtin/output/google_cloud.go +++ b/plugin/builtin/output/google_cloud.go @@ -263,6 +263,12 @@ func (p *GoogleCloudOutput) createProtobufEntry(e *entry.Entry) (newEntry *logpb case map[string]interface{}: s := jsonMapToProtoStruct(p) newEntry.Payload = &logpb.LogEntry_JsonPayload{JsonPayload: s} + case map[string]string: + fields := map[string]*structpb.Value{} + for k, v := range p { + fields[k] = jsonValueToStructValue(v) + } + newEntry.Payload = &logpb.LogEntry_JsonPayload{JsonPayload: &structpb.Struct{Fields: fields}} default: return nil, fmt.Errorf("cannot convert record of type %T to a protobuf representation", e.Record) }