|
|
@@ -90,7 +90,7 @@ func TestFrameQueueHealthIndicator(t *testing.T) { |
|
|
t.Fatalf("expected initial health critical, got %s", stats.Health) |
|
|
t.Fatalf("expected initial health critical, got %s", stats.Health) |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
push := func(seq int) { |
|
|
|
|
|
|
|
|
push := func(seq uint64) { |
|
|
frame := &CompositeFrame{Sequence: seq} |
|
|
frame := &CompositeFrame{Sequence: seq} |
|
|
if err := q.Push(ctx, frame); err != nil { |
|
|
if err := q.Push(ctx, frame); err != nil { |
|
|
t.Fatalf("push %d failed: %v", seq, err) |
|
|
t.Fatalf("push %d failed: %v", seq, err) |
|
|
|