Skip to content

Commit e73aeae

Browse files
committed
remove otelbeat Inspect tests
1 parent 2e3be35 commit e73aeae

File tree

2 files changed

+0
-221
lines changed

2 files changed

+0
-221
lines changed

x-pack/filebeat/tests/integration/otel_test.go

Lines changed: 0 additions & 109 deletions
Original file line numberDiff line numberDiff line change
@@ -270,115 +270,6 @@ func assertMonitoring(t *testing.T, port int) {
270270
require.Equal(t, http.StatusNotFound, r.StatusCode, "incorrect status code")
271271
}
272272

273-
func TestFilebeatOTelInspect(t *testing.T) {
274-
filebeatOTel := integration.NewBeat(
275-
t,
276-
"filebeat-otel",
277-
"../../filebeat.test",
278-
"otel",
279-
)
280-
281-
var beatsCfgFile = `
282-
filebeat.inputs:
283-
- type: filestream
284-
id: filestream-input-id
285-
enabled: true
286-
file_identity.native: ~
287-
prospector.scanner.fingerprint.enabled: false
288-
paths:
289-
- /tmp/log.log
290-
output:
291-
elasticsearch:
292-
hosts:
293-
- localhost:9200
294-
username: admin
295-
password: testing
296-
index: index
297-
queue.mem.flush.timeout: 0s
298-
setup.template.enabled: false
299-
processors:
300-
- add_host_metadata: ~
301-
- add_cloud_metadata: ~
302-
- add_docker_metadata: ~
303-
- add_kubernetes_metadata: ~
304-
`
305-
expectedExporter := `exporters:
306-
elasticsearch:
307-
auth:
308-
authenticator: beatsauth
309-
compression: gzip
310-
compression_params:
311-
level: 1
312-
endpoints:
313-
- http://localhost:9200
314-
logs_index: index
315-
mapping:
316-
mode: bodymap
317-
max_conns_per_host: 1
318-
password: testing
319-
retry:
320-
enabled: true
321-
initial_interval: 1s
322-
max_interval: 1m0s
323-
max_retries: 3
324-
sending_queue:
325-
batch:
326-
flush_timeout: 10s
327-
max_size: 1600
328-
min_size: 0
329-
sizer: items
330-
block_on_overflow: true
331-
enabled: true
332-
num_consumers: 1
333-
queue_size: 3200
334-
wait_for_result: true
335-
user: admin
336-
extensions:
337-
beatsauth:
338-
idle_connection_timeout: 3s
339-
proxy_disable: false
340-
timeout: 1m30s
341-
`
342-
343-
expectedReceiver := `receivers:
344-
filebeatreceiver:
345-
filebeat:
346-
inputs:
347-
- enabled: true
348-
file_identity:
349-
native: null
350-
id: filestream-input-id
351-
paths:
352-
- /tmp/log.log
353-
prospector:
354-
scanner:
355-
fingerprint:
356-
enabled: false
357-
type: filestream`
358-
expectedService := `service:
359-
extensions:
360-
- beatsauth
361-
pipelines:
362-
logs:
363-
exporters:
364-
- elasticsearch
365-
receivers:
366-
- filebeatreceiver
367-
`
368-
filebeatOTel.WriteConfigFile(beatsCfgFile)
369-
370-
filebeatOTel.Start("inspect")
371-
defer filebeatOTel.Stop()
372-
373-
require.EventuallyWithT(t, func(collect *assert.CollectT) {
374-
out, err := filebeatOTel.ReadStdout()
375-
require.NoError(collect, err)
376-
require.Contains(collect, out, expectedExporter)
377-
require.Contains(collect, out, expectedReceiver)
378-
require.Contains(collect, out, expectedService)
379-
}, 10*time.Second, 500*time.Millisecond, "failed to get output of inspect command")
380-
}
381-
382273
func TestFilebeatOTelDocumentLevelRetries(t *testing.T) {
383274
tests := []struct {
384275
name string

x-pack/metricbeat/tests/integration/otel_test.go

Lines changed: 0 additions & 112 deletions
Original file line numberDiff line numberDiff line change
@@ -577,115 +577,3 @@ func assertMapstrKeysEqual(t *testing.T, m1, m2 mapstr.M, ignoredFields []string
577577

578578
require.Zero(t, cmp.Diff(flatM1, flatM2), msg)
579579
}
580-
581-
func TestMetricbeatOTelInspect(t *testing.T) {
582-
mbOTel := integration.NewBeat(
583-
t,
584-
"metricbeat-otel",
585-
"../../metricbeat.test",
586-
"otel",
587-
)
588-
589-
var beatsCfgFile = `
590-
metricbeat:
591-
modules:
592-
- module: system
593-
enabled: true
594-
period: 1s
595-
processes:
596-
- '.*'
597-
metricsets:
598-
- cpu
599-
output:
600-
elasticsearch:
601-
hosts:
602-
- localhost:9200
603-
username: admin
604-
password: testing
605-
index: index
606-
queue.mem.flush.timeout: 0s
607-
setup.template.enabled: false
608-
processors:
609-
- add_host_metadata: ~
610-
- add_cloud_metadata: ~
611-
- add_docker_metadata: ~
612-
- add_kubernetes_metadata: ~
613-
`
614-
expectedExporter := `exporters:
615-
elasticsearch:
616-
auth:
617-
authenticator: beatsauth
618-
compression: gzip
619-
compression_params:
620-
level: 1
621-
endpoints:
622-
- http://localhost:9200
623-
logs_index: index
624-
mapping:
625-
mode: bodymap
626-
max_conns_per_host: 1
627-
password: testing
628-
retry:
629-
enabled: true
630-
initial_interval: 1s
631-
max_interval: 1m0s
632-
max_retries: 3
633-
sending_queue:
634-
batch:
635-
flush_timeout: 10s
636-
max_size: 1600
637-
min_size: 0
638-
sizer: items
639-
block_on_overflow: true
640-
enabled: true
641-
num_consumers: 1
642-
queue_size: 3200
643-
wait_for_result: true
644-
user: admin
645-
extensions:
646-
beatsauth:
647-
idle_connection_timeout: 3s
648-
proxy_disable: false
649-
timeout: 1m30s
650-
`
651-
expectedReceiver := `receivers:
652-
metricbeatreceiver:
653-
logging:
654-
files:
655-
rotateeverybytes: 104857600
656-
rotateonstartup: false
657-
to_files: true
658-
metricbeat:
659-
modules:
660-
- enabled: true
661-
metricsets:
662-
- cpu
663-
module: system
664-
period: 1s
665-
processes:
666-
- .*
667-
`
668-
669-
expectedService := `service:
670-
extensions:
671-
- beatsauth
672-
pipelines:
673-
logs:
674-
exporters:
675-
- elasticsearch
676-
receivers:
677-
- metricbeatreceiver
678-
`
679-
mbOTel.WriteConfigFile(beatsCfgFile)
680-
681-
mbOTel.Start("inspect")
682-
defer mbOTel.Stop()
683-
684-
require.EventuallyWithT(t, func(collect *assert.CollectT) {
685-
out, err := mbOTel.ReadStdout()
686-
require.NoError(collect, err)
687-
require.Contains(collect, out, expectedExporter)
688-
require.Contains(collect, out, expectedReceiver)
689-
require.Contains(collect, out, expectedService)
690-
}, 10*time.Second, 500*time.Millisecond, "failed to get output of inspect command")
691-
}

0 commit comments

Comments
 (0)