Skip to content

feat(fluentbit): Add db.compare_filename support to Tail input plugin #1961

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
fumblehool wants to merge 2 commits into
base: master
Choose a base branch
from
Open

feat(fluentbit): Add db.compare_filename support to Tail input plugin #1961

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
e93d0a6
Add db.compare_filename support to Tail input plugin
fumblehool May 19, 2026
68551d6
Merge branch 'master' into master
joshuabaird May 21, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions apis/fluentbit/v1alpha2/plugins/input/tail_types.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -61,6 +61,8 @@ type Tail struct {
DBSync string `json:"dbSync,omitempty"`
// Specify that the database will be accessed only by Fluent Bit.
DBLocking *bool `json:"dbLocking,omitempty"`
// Whether to compare filenames. When enabled, the database uses the filename for comparison.
DBCompareFilename *bool `json:"dbCompareFilename,omitempty"`
// Set a limit of memory that Tail plugin can use when appending data to the Engine.
// If the limit is reach, it will be paused; when the data is flushed it resumes.
MemBufLimit string `json:"memBufLimit,omitempty"`
Expand Down Expand Up @@ -148,6 +150,7 @@ func (t *Tail) Params(_ plugins.SecretLoader) (*params.KVs, error) {
plugins.InsertKVField(kvs, "Read_from_Head", t.ReadFromHead)
plugins.InsertKVField(kvs, "Rotate_Wait", t.RotateWaitSeconds)
plugins.InsertKVField(kvs, "DB.locking", t.DBLocking)
plugins.InsertKVField(kvs, "DB.compare_filename", t.DBCompareFilename)
plugins.InsertKVField(kvs, "Multiline", t.Multiline)
plugins.InsertKVField(kvs, "Multiline_Flush", t.MultilineFlushSeconds)
plugins.InsertKVField(kvs, "Skip_Empty_Lines", t.SkipEmptyLines)
Expand Down
5 changes: 5 additions & 0 deletions apis/fluentbit/v1alpha2/plugins/input/zz_generated.deepcopy.go
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

4 changes: 4 additions & 0 deletions charts/fluent-operator-fluent-bit-crds/templates/fluentbit.fluent.io_clusterinputs.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -789,6 +789,10 @@ spec:
description: Specify that the database will be accessed only by
Fluent Bit.
type: boolean
dbCompareFilename:
description: Whether to compare filenames. When enabled, the database
uses the filename for comparison.
type: boolean
dbSync:
description: 'Set a default synchronization (I/O) method. Values:
Extra, Full, Normal, Off.'
Expand Down
4 changes: 4 additions & 0 deletions charts/fluent-operator/crds/fluentbit.fluent.io_clusterinputs.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -787,6 +787,10 @@ spec:
description: Specify that the database will be accessed only by
Fluent Bit.
type: boolean
dbCompareFilename:
description: Whether to compare filenames. When enabled, the database
uses the filename for comparison.
type: boolean
dbSync:
description: 'Set a default synchronization (I/O) method. Values:
Extra, Full, Normal, Off.'
Expand Down
4 changes: 4 additions & 0 deletions config/crd/bases/fluentbit.fluent.io_clusterinputs.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -788,6 +788,10 @@ spec:
description: Specify that the database will be accessed only by
Fluent Bit.
type: boolean
dbCompareFilename:
description: Whether to compare filenames. When enabled, the database
uses the filename for comparison.
type: boolean
dbSync:
description: 'Set a default synchronization (I/O) method. Values:
Extra, Full, Normal, Off.'
Expand Down
1 change: 1 addition & 0 deletions docs/plugins/fluentbit/input/tail.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@ The Tail input plugin allows to monitor one or several text files. <br /> It has
| db | Specify the database file to keep track of monitored files and offsets. | string |
| dbSync | Set a default synchronization (I/O) method. Values: Extra, Full, Normal, Off. | string |
| dbLocking | Specify that the database will be accessed only by Fluent Bit. | *bool |
| dbCompareFilename | Whether to compare filenames. When enabled, the database uses the filename for comparison. | *bool |
| memBufLimit | Set a limit of memory that Tail plugin can use when appending data to the Engine. If the limit is reach, it will be paused; when the data is flushed it resumes. | string |
| parser | Specify the name of a parser to interpret the entry as a structured message. | string |
| key | When a message is unstructured (no parser applied), it's appended as a string under the key name log. This option allows to define an alternative name for that key. | string |
Expand Down
4 changes: 4 additions & 0 deletions manifests/setup/fluent-operator-crd.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2964,6 +2964,10 @@ spec:
description: Specify that the database will be accessed only by
Fluent Bit.
type: boolean
dbCompareFilename:
description: Whether to compare filenames. When enabled, the database
uses the filename for comparison.
type: boolean
dbSync:
description: 'Set a default synchronization (I/O) method. Values:
Extra, Full, Normal, Off.'
Expand Down
4 changes: 4 additions & 0 deletions manifests/setup/setup.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2964,6 +2964,10 @@ spec:
description: Specify that the database will be accessed only by
Fluent Bit.
type: boolean
dbCompareFilename:
description: Whether to compare filenames. When enabled, the database
uses the filename for comparison.
type: boolean
dbSync:
description: 'Set a default synchronization (I/O) method. Values:
Extra, Full, Normal, Off.'
Expand Down
Loading