mirror of
https://github.com/pomerium/pomerium.git
synced 2025-05-01 03:16:31 +02:00
parent
4c9398e95b
commit
8c6955dbe2
1 changed files with 3 additions and 3 deletions
|
@ -74,7 +74,7 @@ func TestSpanObserver(t *testing.T) {
|
||||||
|
|
||||||
waitOkToExit.Store(true)
|
waitOkToExit.Store(true)
|
||||||
obs.Observe(Span(5).ID())
|
obs.Observe(Span(5).ID())
|
||||||
assert.Eventually(t, waitExited.Load, 10*time.Millisecond, 1*time.Millisecond)
|
assert.Eventually(t, waitExited.Load, 100*time.Millisecond, 10*time.Millisecond)
|
||||||
})
|
})
|
||||||
|
|
||||||
t.Run("new references observed during wait", func(t *testing.T) {
|
t.Run("new references observed during wait", func(t *testing.T) {
|
||||||
|
@ -122,7 +122,7 @@ func TestSpanObserver(t *testing.T) {
|
||||||
waitOkToExit.Store(true)
|
waitOkToExit.Store(true)
|
||||||
obs.Observe(Span(7).ID())
|
obs.Observe(Span(7).ID())
|
||||||
assert.Equal(t, []oteltrace.SpanID{}, obs.XUnobservedIDs())
|
assert.Equal(t, []oteltrace.SpanID{}, obs.XUnobservedIDs())
|
||||||
assert.Eventually(t, waitExited.Load, 10*time.Millisecond, 1*time.Millisecond)
|
assert.Eventually(t, waitExited.Load, 100*time.Millisecond, 10*time.Millisecond)
|
||||||
})
|
})
|
||||||
|
|
||||||
t.Run("multiple waiters", func(t *testing.T) {
|
t.Run("multiple waiters", func(t *testing.T) {
|
||||||
|
@ -147,7 +147,7 @@ func TestSpanObserver(t *testing.T) {
|
||||||
|
|
||||||
assert.Eventually(t, func() bool {
|
assert.Eventually(t, func() bool {
|
||||||
return waitersExited.Load() == 10
|
return waitersExited.Load() == 10
|
||||||
}, 10*time.Millisecond, 1*time.Millisecond)
|
}, 100*time.Millisecond, 10*time.Millisecond)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue