Function TestRunValidation

cmd/tempo-vulture/validation_test.go:225–384

func TestValidateTraceSearch(t *testing.T) { tests := []struct { name string traces []traceInfo searchError error searchResponse []*tempopb.TraceSearchMetadata expectedFailures int }{ { name: "successful search", traces: []traceInfo{ {id: "trace-1

(t *testing.T)

// }

func TestRunValidation(t *testing.T) {
	tests := []struct {
		name                string
		config              ValidationConfig
		writeError          error
		retrievalError      error
		retrievalTrace      *tempopb.Trace
		expectedFailures    int
		expectedExitCode    int
		expectedTotalTraces int
		expectEarlyReturn   bool // For write failures
	}{
		{
			name: "complete success - no search",
			config: ValidationConfig{
				Cycles:                2,
				TempoOrgID:            "test-org",
				WriteBackoffDuration:  time.Millisecond, // Fast for testing
				SearchBackoffDuration: 0,                // Disable search
			},
			retrievalTrace: &tempopb.Trace{
				ResourceSpans: []*v1.ResourceSpans{
					{
						ScopeSpans: []*v1.ScopeSpans{
							{
								Spans: []*v1.Span{
									{Name: "test-span"},
								},
							},
						},
					},
				},
			},
			expectedFailures:    0,
			expectedExitCode:    0,
			expectedTotalTraces: 2,
		},
		{
			name: "write failure - early return",
			config: ValidationConfig{
				Cycles:                3,
				TempoOrgID:            "test-org",
				WriteBackoffDuration:  time.Millisecond,
				SearchBackoffDuration: 0,
			},
			writeError:          errors.New("write failed"),
			expectedFailures:    1,
			expectedExitCode:    1,
			expectedTotalTraces: 3,
			expectEarlyReturn:   true,
		},
		{
			name: "retrieval failure - continues processing",
			config: ValidationConfig{
				Cycles:                2,
				TempoOrgID:            "test-org",
				WriteBackoffDuration:  time.Millisecond,
				SearchBackoffDuration: 0,