observed timestamp removed

This commit is contained in:
nityanandagohain 2022-07-20 14:52:16 +05:30
parent a527c33c7d
commit 5912d3a4a0
2 changed files with 2 additions and 3 deletions

View File

@ -2862,7 +2862,7 @@ func (r *ClickHouseReader) GetLogs(ctx context.Context, params *model.LogsFilter
}
query := fmt.Sprintf("SELECT "+
"timestamp, observed_timestamp, id, trace_id, span_id, trace_flags, severity_text, severity_number, body,"+
"timestamp, id, trace_id, span_id, trace_flags, severity_text, severity_number, body,"+
"CAST((attributes_string_key, attributes_string_value), 'Map(String, String)') as attributes_string,"+
"CAST((attributes_int64_key, attributes_int64_value), 'Map(String, Int64)') as attributes_int64,"+
"CAST((attributes_float64_key, attributes_float64_value), 'Map(String, Float64)') as attributes_float64,"+
@ -2901,7 +2901,7 @@ func (r *ClickHouseReader) TailLogs(ctx context.Context, client *model.LogsTailC
}
query := fmt.Sprintf("SELECT "+
"timestamp, observed_timestamp, id, trace_id, span_id, trace_flags, severity_text, severity_number, body,"+
"timestamp, id, trace_id, span_id, trace_flags, severity_text, severity_number, body,"+
"CAST((attributes_string_key, attributes_string_value), 'Map(String, String)') as attributes_string,"+
"CAST((attributes_int64_key, attributes_int64_value), 'Map(String, Int64)') as attributes_int64,"+
"CAST((attributes_float64_key, attributes_float64_value), 'Map(String, Float64)') as attributes_float64,"+

View File

@ -422,7 +422,6 @@ type GetFieldsResponse struct {
type GetLogsResponse struct {
Timestamp uint64 `json:"timestamp" ch:"timestamp"`
ObservedTimestamp uint64 `json:"observedTimestamp" ch:"observed_timestamp"`
ID string `json:"id" ch:"id"`
TraceID string `json:"traceId" ch:"trace_id"`
SpanID string `json:"spanId" ch:"span_id"`