(t *testing.T)
| 183 | } |
| 184 | |
| 185 | func TestInstanceNoLimits(t *testing.T) { |
| 186 | instance, ls := instanceWithPushLimits(t, 0, 0) // no limits by default |
| 187 | |
| 188 | for range 100 { |
| 189 | id := test.ValidTraceID(nil) |
| 190 | pushTrace(t.Context(), t, instance, test.MakeTrace(1, id), id) |
| 191 | } |
| 192 | |
| 193 | assert.Equal(t, uint64(100), instance.liveTraces.Len()) |
| 194 | assert.GreaterOrEqual(t, instance.liveTraces.Size(), uint64(1000)) |
| 195 | |
| 196 | err := services.StopAndAwaitTerminated(t.Context(), ls) |
| 197 | require.NoError(t, err) |
| 198 | } |
| 199 | |
| 200 | func TestInstanceBackpressure(t *testing.T) { |
| 201 | instance, ls := defaultInstance(t) |
nothing calls this directly
no test coverage detected