Skip to content

Commit ef9e875

Browse files
cchenggitvm-001
authored andcommitted
fix(tests): make otel collector to export data to files faster
1 parent 2940e62 commit ef9e875

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

test/otel-collector-config.yml

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,9 @@ receivers:
77
endpoint: 0.0.0.0:4318
88

99
processors:
10+
batch:
11+
timeout: 200ms
12+
send_batch_size: 1
1013

1114
exporters:
1215
debug:

test/tracing/admin_test.go

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ var _ = Describe("tracing admin", Ordered, func() {
8989
n++
9090

9191
// make more tracing data
92-
for i := 0; i < 20; i++ {
92+
for i := 0; i < 3; i++ {
9393
resp, err := proxyClient.R().
9494
SetBody(`{"event_type": "foo.bar","data": {"key": "value"}}`).
9595
Post("/")
@@ -103,11 +103,9 @@ var _ = Describe("tracing admin", Ordered, func() {
103103
SetResult(api.Pagination[*entities.Attempt]{}).
104104
Get("/workspaces/default/attempts?page_no=1")
105105
result := resp.Result().(*api.Pagination[*entities.Attempt])
106-
return err == nil && resp.StatusCode() == 200 && len(result.Data) == 20
106+
return err == nil && resp.StatusCode() == 200 && len(result.Data) == 3
107107
}, time.Second*5, time.Second)
108108

109-
time.Sleep(time.Second * 10)
110-
111109
assert.Eventually(GinkgoT(), func() bool {
112110
line, err := helper.FileLine(helper.OtelCollectorTracesFile, n)
113111
if err != nil || line == "" {

test/tracing/proxy_test.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -108,8 +108,7 @@ var _ = Describe("tracing proxy", Ordered, func() {
108108
}
109109
assert.Eventually(GinkgoT(), proxyFunc, time.Second*5, time.Second)
110110

111-
// make more tracing data
112-
time.Sleep(time.Second * 3)
111+
time.Sleep(time.Second)
113112
gotScopeNames := make(map[string]bool)
114113
gotSpanAttributes := make(map[string]map[string]string)
115114
assert.Eventually(GinkgoT(), func() bool {

0 commit comments

Comments
 (0)