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

Function TestTraceToParquet

tempodb/encoding/vparquet4/schema_test.go:175–736  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

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

Callers

nothing calls this directly

Calls 7

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

Tested by

no test coverage detected