| 287 | } |
| 288 | |
| 289 | func TestProtoMarshaler(t *testing.T) { |
| 290 | _, err := proto.Marshal(&tempopb.JobDetail{ |
| 291 | Compaction: &tempopb.CompactionDetail{ |
| 292 | Input: []string{"input1", "input2"}, |
| 293 | }, |
| 294 | }) |
| 295 | require.NoError(t, err) |
| 296 | |
| 297 | detail := tempopb.JobDetail{ |
| 298 | Tenant: "test", |
| 299 | Compaction: &tempopb.CompactionDetail{ |
| 300 | Input: []string{"input1", "input2"}, |
| 301 | }, |
| 302 | } |
| 303 | |
| 304 | _, err = proto.Marshal(&tempopb.NextJobResponse{ |
| 305 | JobId: uuid.New().String(), |
| 306 | Type: tempopb.JobType_JOB_TYPE_COMPACTION, |
| 307 | Detail: detail, |
| 308 | }) |
| 309 | require.NoError(t, err) |
| 310 | } |
| 311 | |
| 312 | func writeTenantBlocks(ctx context.Context, t *testing.T, w backend.Writer, tenant string, count int) []backend.UUID { |
| 313 | var ( |