MCPcopy
hub / github.com/grafana/tempo / TestTraceToParquet

Function TestTraceToParquet

tempodb/encoding/vparquet5/schema_test.go:176–757  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

174}
175
176func TestTraceToParquet(t *testing.T) {
177 meta := backend.BlockMeta{DedicatedColumns: test.MakeDedicatedColumns()}
178 traceID := common.ID{0x00, 0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, 0x08, 0x09, 0x0A, 0x0B, 0x0C, 0x0D, 0x0E, 0x0F}
179
180 tsc := []struct {
181 name string
182 id common.ID
183 trace tempopb.Trace
184 expected Trace
185 }{
186 {
187 name: "span scope and resource attributes",
188 id: traceID,
189 trace: tempopb.Trace{
190 ResourceSpans: []*v1_trace.ResourceSpans{{
191 Resource: &v1_resource.Resource{
192 Attributes: []*v1.KeyValue{
193 {Key: "res.attr", Value: &v1.AnyValue{Value: &v1.AnyValue_IntValue{IntValue: 123}}},
194 {Key: "service.name", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "service-a"}}},
195 {Key: "cluster", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "cluster-a"}}},
196 {Key: "namespace", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "namespace-a"}}},
197 {Key: "pod", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "pod-a"}}},
198 {Key: "container", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "container-a"}}},
199 {Key: "k8s.cluster.name", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "k8s-cluster-a"}}},
200 {Key: "k8s.namespace.name", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "k8s-namespace-a"}}},
201 {Key: "k8s.pod.name", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "k8s-pod-a"}}},
202 {Key: "k8s.container.name", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "k8s-container-a"}}},
203 {Key: "dedicated.resource.1", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "dedicated-resource-attr-value-1"}}},
204 {Key: "dedicated.resource.2", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "dedicated-resource-attr-value-2"}}},
205 {Key: "dedicated.resource.3", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "dedicated-resource-attr-value-3"}}},
206 {Key: "dedicated.resource.4", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "dedicated-resource-attr-value-4"}}},
207 {Key: "dedicated.resource.5", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "dedicated-resource-attr-value-5"}}},
208 {Key: "res.string.array", Value: &v1.AnyValue{Value: &v1.AnyValue_ArrayValue{ArrayValue: &v1.ArrayValue{
209 Values: []*v1.AnyValue{
210 {Value: &v1.AnyValue_StringValue{StringValue: "one"}},
211 {Value: &v1.AnyValue_StringValue{StringValue: "two"}},
212 {Value: &v1.AnyValue_StringValue{StringValue: "three"}},
213 },
214 }}}},
215 {Key: "res.int.array", Value: &v1.AnyValue{Value: &v1.AnyValue_ArrayValue{ArrayValue: &v1.ArrayValue{
216 Values: []*v1.AnyValue{
217 {Value: &v1.AnyValue_IntValue{IntValue: 1}},
218 {Value: &v1.AnyValue_IntValue{IntValue: 2}},
219 },
220 }}}},
221 {Key: "res.double.array", Value: &v1.AnyValue{Value: &v1.AnyValue_ArrayValue{ArrayValue: &v1.ArrayValue{
222 Values: []*v1.AnyValue{
223 {Value: &v1.AnyValue_DoubleValue{DoubleValue: 1.1}},
224 {Value: &v1.AnyValue_DoubleValue{DoubleValue: 2.2}},
225 {Value: &v1.AnyValue_DoubleValue{DoubleValue: 3.3}},
226 },
227 }}}},
228 {Key: "res.bool.array", Value: &v1.AnyValue{Value: &v1.AnyValue_ArrayValue{ArrayValue: &v1.ArrayValue{
229 Values: []*v1.AnyValue{
230 {Value: &v1.AnyValue_BoolValue{BoolValue: true}},
231 {Value: &v1.AnyValue_BoolValue{BoolValue: false}},
232 {Value: &v1.AnyValue_BoolValue{BoolValue: true}},
233 {Value: &v1.AnyValue_BoolValue{BoolValue: true}},

Callers

nothing calls this directly

Calls 7

MakeDedicatedColumnsFunction · 0.92
DedicatedBlobTestStringFunction · 0.92
attrFunction · 0.70
ptrFunction · 0.70
traceToParquetFunction · 0.70
traceEqualFunction · 0.70
RunMethod · 0.45

Tested by

no test coverage detected