Add another missing case to the google cloud output

observIQ · Jul 17, 2020 · 89dbd2e · 89dbd2e
1 parent a6d3f1c
commit 89dbd2e
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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)
 	}