change model

Author: ndakkoune

aws/logs_monitoring_go/internal/model/cloudwatchlogs.go

@@ -5,6 +5,23 @@
 
 package model
 
+type CloudwatchLogEntry struct {
+	ID        string             `json:"id"`
+	Timestamp int64              `json:"timestamp"`
+	Message   string             `json:"message"`
+	Source    string             `json:"ddsource"`
+	Service   string             `json:"service"`
+	Host      string             `json:"hostname"`
+	Tags      []string           `json:"ddtags"`
+	AWS       CloudwatchMetadata `json:"aws"`
+}
+
+type CloudwatchMetadata struct {
+	InvokedFunctionARN string                `json:"invoked_function_arn"`
+	FunctionVersion    string                `json:"function_version,omitempty"`
+	Logs               CloudwatchLogsContext `json:"awslogs"`
+}
+
 type CloudwatchLogsContext struct {
 	LogGroup  string `json:"logGroup"`
 	LogStream string `json:"logStream"`

aws/logs_monitoring_go/internal/model/log.go

@@ -21,7 +21,7 @@ const (
 	invocationSourceCloudwatchLogs
 )
 
-func Parse(ctx context.Context, event json.RawMessage, cfg *config.Config, out chan<- model.LogEntry) {
+func Parse(ctx context.Context, event json.RawMessage, cfg *config.Config, out chan<- model.CloudwatchLogEntry) {
 	switch detectInvocationSource(event) {
 	case invocationSourceCloudwatchLogs:
 		parseCloudwatchLogs(ctx, event, cfg, out)
@@ -47,6 +47,6 @@ func detectInvocationSource(event json.RawMessage) invocationSource {
 	return invocationSourceUnknown
 }
 
-func parseCloudwatchLogs(ctx context.Context, event json.RawMessage, cfg *config.Config, out chan<- model.LogEntry) {
+func parseCloudwatchLogs(ctx context.Context, event json.RawMessage, cfg *config.Config, out chan<- model.CloudwatchLogEntry) {
 
 }