Skip to content

feat(fluentbit): add text_payload_key to stackdriver #1669

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
wants to merge 2 commits into
base: master
Choose a base branch
from
Open

feat(fluentbit): add text_payload_key to stackdriver #1669

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
115b9a9
add textPayloadKey
cw-Guo Aug 8, 2025
80cd66b
add generated manifests
cw-Guo Aug 8, 2025
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
5 changes: 5 additions & 0 deletions apis/fluentbit/v1alpha2/plugins/output/stackdriver_types.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,8 @@ type Stackdriver struct {
CustomK8sRegex string `json:"customK8sRegex,omitempty"`
// Optional list of comma seperated strings. Setting these fields overrides the Stackdriver monitored resource API values
ResourceLabels []string `json:"resourceLabels,omitempty"`
// the key to used to select the text payload from the record
TextPayloadKey string `json:"textPayloadKey,omitempty"`
}

// Name implement Section() method
Expand Down Expand Up @@ -141,5 +143,8 @@ func (o *Stackdriver) Params(sl plugins.SecretLoader) (*params.KVs, error) {
if o.ResourceLabels != nil && len(o.ResourceLabels) > 0 {
kvs.Insert("resource_labels", strings.Join(o.ResourceLabels, ","))
}
if o.TextPayloadKey != "" {
kvs.Insert("text_payload_key", o.TextPayloadKey)
}
return kvs, nil
}
4 changes: 4 additions & 0 deletions charts/fluent-operator/charts/fluent-bit-crds/crds/fluentbit.fluent.io_clusteroutputs.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4063,6 +4063,10 @@ spec:
description: Identifier for a task within a namespace. Required
if Resource is generic_task
type: string
textPayloadKey:
description: the key to used to select the text payload from the
record
type: string
workers:
description: Number of dedicated threads for the Stackdriver Output
Plugin
Expand Down
4 changes: 4 additions & 0 deletions charts/fluent-operator/charts/fluent-bit-crds/crds/fluentbit.fluent.io_outputs.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4063,6 +4063,10 @@ spec:
description: Identifier for a task within a namespace. Required
if Resource is generic_task
type: string
textPayloadKey:
description: the key to used to select the text payload from the
record
type: string
workers:
description: Number of dedicated threads for the Stackdriver Output
Plugin
Expand Down
4 changes: 4 additions & 0 deletions config/crd/bases/fluentbit.fluent.io_clusteroutputs.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4063,6 +4063,10 @@ spec:
description: Identifier for a task within a namespace. Required
if Resource is generic_task
type: string
textPayloadKey:
description: the key to used to select the text payload from the
record
type: string
workers:
description: Number of dedicated threads for the Stackdriver Output
Plugin
Expand Down
4 changes: 4 additions & 0 deletions config/crd/bases/fluentbit.fluent.io_outputs.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4063,6 +4063,10 @@ spec:
description: Identifier for a task within a namespace. Required
if Resource is generic_task
type: string
textPayloadKey:
description: the key to used to select the text payload from the
record
type: string
workers:
description: Number of dedicated threads for the Stackdriver Output
Plugin
Expand Down
1 change: 1 addition & 0 deletions docs/plugins/fluentbit/output/stackdriver.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -27,3 +27,4 @@ Stackdriver is the Stackdriver output plugin, allows you to ingest your records
| workers | Number of dedicated threads for the Stackdriver Output Plugin | *int32 |
| customK8sRegex | A custom regex to extract fields from the local_resource_id of the logs | string |
| resourceLabels | Optional list of comma seperated strings. Setting these fields overrides the Stackdriver monitored resource API values | []string |
| textPayloadKey | the key to used to select the text payload from the record | string |
8 changes: 8 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 @@ -8199,6 +8199,10 @@ spec:
description: Identifier for a task within a namespace. Required
if Resource is generic_task
type: string
textPayloadKey:
description: the key to used to select the text payload from the
record
type: string
workers:
description: Number of dedicated threads for the Stackdriver Output
Plugin
Expand Down Expand Up @@ -37103,6 +37107,10 @@ spec:
description: Identifier for a task within a namespace. Required
if Resource is generic_task
type: string
textPayloadKey:
description: the key to used to select the text payload from the
record
type: string
workers:
description: Number of dedicated threads for the Stackdriver Output
Plugin
Expand Down
8 changes: 8 additions & 0 deletions manifests/setup/setup.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8199,6 +8199,10 @@ spec:
description: Identifier for a task within a namespace. Required
if Resource is generic_task
type: string
textPayloadKey:
description: the key to used to select the text payload from the
record
type: string
workers:
description: Number of dedicated threads for the Stackdriver Output
Plugin
Expand Down Expand Up @@ -37103,6 +37107,10 @@ spec:
description: Identifier for a task within a namespace. Required
if Resource is generic_task
type: string
textPayloadKey:
description: the key to used to select the text payload from the
record
type: string
workers:
description: Number of dedicated threads for the Stackdriver Output
Plugin
Expand Down
Loading