Skip to content

Commit 8a2fb2d

Browse files
authored
[chore][testbed]: add options for retry/storage for filelog (#36781)
This options can be useful for test cases with retry/storage options enabled.
1 parent f72ef07 commit 8a2fb2d

File tree

2 files changed

+43
-2
lines changed

2 files changed

+43
-2
lines changed
+27
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
# Use this changelog template to create an entry for release notes.
2+
3+
# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
4+
change_type: enhancement
5+
6+
# The name of the component, or a single word describing the area of concern, (e.g. filelogreceiver)
7+
component: tesbed
8+
9+
# A brief description of the change. Surround your text with quotes ("") if it needs to start with a backtick (`).
10+
note: add options for retry/storage for filelog sender
11+
12+
# Mandatory: One or more tracking issues related to the change. You can use the PR number here if no issue exists.
13+
issues: [36781]
14+
15+
# (Optional) One or more lines of additional information to render under the primary note.
16+
# These lines will be padded with 2 spaces and then inserted directly into the document.
17+
# Use pipe (|) for multiline entries.
18+
subtext:
19+
20+
# If your change doesn't affect end users or the exported elements of any package,
21+
# you should instead start your pull request title with [chore] or use the "Skip Changelog" label.
22+
# Optional: The change log or logs in which this entry should be included.
23+
# e.g. '[user]' or '[user, api]'
24+
# Include 'user' if the change is relevant to end users.
25+
# Include 'api' if there is a change to a library API.
26+
# Default: '[user]'
27+
change_logs: []

testbed/datasenders/stanza.go

+16-2
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,9 @@ import (
2020
)
2121

2222
type FileLogWriter struct {
23-
file *os.File
23+
file *os.File
24+
retry string
25+
storage string
2426
}
2527

2628
// Ensure FileLogWriter implements LogDataSender.
@@ -41,6 +43,16 @@ func NewFileLogWriter() *FileLogWriter {
4143
return f
4244
}
4345

46+
func (f *FileLogWriter) WithRetry(retry string) *FileLogWriter {
47+
f.retry = retry
48+
return f
49+
}
50+
51+
func (f *FileLogWriter) WithStorage(storage string) *FileLogWriter {
52+
f.storage = storage
53+
return f
54+
}
55+
4456
func (f *FileLogWriter) Capabilities() consumer.Capabilities {
4557
return consumer.Capabilities{MutatesData: false}
4658
}
@@ -120,7 +132,9 @@ func (f *FileLogWriter) GenConfigYAMLStr() string {
120132
layout: '%%Y-%%m-%%d'
121133
severity:
122134
parse_from: attributes.sev
123-
`, f.file.Name())
135+
%s
136+
%s
137+
`, f.file.Name(), f.retry, f.storage)
124138
}
125139

126140
func (f *FileLogWriter) ProtocolName() string {

0 commit comments

Comments
 (0)