Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

v1alpha2

package

Go to main page

Versions in this module

v3

v3.4.0

May 9, 2025

Changes in this version

type CollectorSpec

+ Replicas *int32

type Service

+ EnableChunkTrace *bool

v3.3.0

Mar 6, 2025

Changes in this version

+ const CollectorFinalizerName

+ const FluentBitFinalizerName

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var SchemeBuilder = &scheme.Builder

+ var SchemeGroupVersion = schema.GroupVersion

+ type ByName []Script

+ func (a ByName) Len() int

+ func (a ByName) Less(i, j int) bool

+ func (a ByName) Swap(i, j int)

+ type ClusterFilter struct

+ Spec FilterSpec

+ func (in *ClusterFilter) DeepCopy() *ClusterFilter

+ func (in *ClusterFilter) DeepCopyInto(out *ClusterFilter)

+ func (in *ClusterFilter) DeepCopyObject() runtime.Object

+ type ClusterFilterList struct

+ Items []ClusterFilter

+ func (in *ClusterFilterList) DeepCopy() *ClusterFilterList

+ func (in *ClusterFilterList) DeepCopyInto(out *ClusterFilterList)

+ func (in *ClusterFilterList) DeepCopyObject() runtime.Object

+ func (list ClusterFilterList) Load(sl plugins.SecretLoader) (string, error)

+ func (list ClusterFilterList) LoadAsYaml(sl plugins.SecretLoader, depth int) (string, error)

+ type ClusterFluentBitConfig struct

+ Spec FluentBitConfigSpec

+ func (cfg ClusterFluentBitConfig) RenderLuaScript(cl plugins.ConfigMapLoader, filters ClusterFilterList, namespace string) ([]Script, error)

+ func (cfg ClusterFluentBitConfig) RenderMainConfig(sl plugins.SecretLoader, inputs ClusterInputList, filters ClusterFilterList, ...) (string, error)

+ func (cfg ClusterFluentBitConfig) RenderMainConfigInYaml(sl plugins.SecretLoader, inputs ClusterInputList, filters ClusterFilterList, ...) (string, error)

+ func (cfg ClusterFluentBitConfig) RenderMainConfigWithTargetFormat(sl plugins.SecretLoader, inputs ClusterInputList, filters ClusterFilterList, ...) (string, error)

+ func (cfg ClusterFluentBitConfig) RenderMultilineParserConfig(sl plugins.SecretLoader, multilineParsers ClusterMultilineParserList, ...) (string, error)

+ func (cfg ClusterFluentBitConfig) RenderNamespacedLuaScript(cl plugins.ConfigMapLoader, nsfiltersLists []FilterList) ([]Script, error)

+ func (cfg ClusterFluentBitConfig) RenderParserConfig(sl plugins.SecretLoader, parsers ClusterParserList, nsParserLists []ParserList, ...) (string, error)

+ func (in *ClusterFluentBitConfig) DeepCopy() *ClusterFluentBitConfig

+ func (in *ClusterFluentBitConfig) DeepCopyInto(out *ClusterFluentBitConfig)

+ func (in *ClusterFluentBitConfig) DeepCopyObject() runtime.Object

+ type ClusterFluentBitConfigList struct

+ Items []ClusterFluentBitConfig

+ func (in *ClusterFluentBitConfigList) DeepCopy() *ClusterFluentBitConfigList

+ func (in *ClusterFluentBitConfigList) DeepCopyInto(out *ClusterFluentBitConfigList)

+ func (in *ClusterFluentBitConfigList) DeepCopyObject() runtime.Object

+ type ClusterInput struct

+ Spec InputSpec

+ func (in *ClusterInput) DeepCopy() *ClusterInput

+ func (in *ClusterInput) DeepCopyInto(out *ClusterInput)

+ func (in *ClusterInput) DeepCopyObject() runtime.Object

+ type ClusterInputList struct

+ Items []ClusterInput

+ func (in *ClusterInputList) DeepCopy() *ClusterInputList

+ func (in *ClusterInputList) DeepCopyInto(out *ClusterInputList)

+ func (in *ClusterInputList) DeepCopyObject() runtime.Object

+ func (list ClusterInputList) Load(sl plugins.SecretLoader) (string, error)

+ func (list ClusterInputList) LoadAsYaml(sl plugins.SecretLoader, depth int) (string, error)

+ type ClusterMultilineParser struct

+ Spec MultilineParserSpec

+ func (in *ClusterMultilineParser) DeepCopy() *ClusterMultilineParser

+ func (in *ClusterMultilineParser) DeepCopyInto(out *ClusterMultilineParser)

+ func (in *ClusterMultilineParser) DeepCopyObject() runtime.Object

+ type ClusterMultilineParserByName []ClusterMultilineParser

+ func (a ClusterMultilineParserByName) Len() int

+ func (a ClusterMultilineParserByName) Less(i, j int) bool

+ func (a ClusterMultilineParserByName) Swap(i, j int)

+ type ClusterMultilineParserList struct

+ Items []ClusterMultilineParser

+ func (in *ClusterMultilineParserList) DeepCopy() *ClusterMultilineParserList

+ func (in *ClusterMultilineParserList) DeepCopyInto(out *ClusterMultilineParserList)

+ func (in *ClusterMultilineParserList) DeepCopyObject() runtime.Object

+ func (list ClusterMultilineParserList) Load(sl plugins.SecretLoader) (string, error)

+ type ClusterOutput struct

+ Spec OutputSpec

+ func (in *ClusterOutput) DeepCopy() *ClusterOutput

+ func (in *ClusterOutput) DeepCopyInto(out *ClusterOutput)

+ func (in *ClusterOutput) DeepCopyObject() runtime.Object

+ type ClusterOutputList struct

+ Items []ClusterOutput

+ func (in *ClusterOutputList) DeepCopy() *ClusterOutputList

+ func (in *ClusterOutputList) DeepCopyInto(out *ClusterOutputList)

+ func (in *ClusterOutputList) DeepCopyObject() runtime.Object

+ func (list ClusterOutputList) Load(sl plugins.SecretLoader) (string, error)

+ func (list ClusterOutputList) LoadAsYaml(sl plugins.SecretLoader, depth int) (string, error)

+ type ClusterParser struct

+ Spec ParserSpec

+ func (in *ClusterParser) DeepCopy() *ClusterParser

+ func (in *ClusterParser) DeepCopyInto(out *ClusterParser)

+ func (in *ClusterParser) DeepCopyObject() runtime.Object

+ type ClusterParserList struct

+ Items []ClusterParser

+ func (in *ClusterParserList) DeepCopy() *ClusterParserList

+ func (in *ClusterParserList) DeepCopyInto(out *ClusterParserList)

+ func (in *ClusterParserList) DeepCopyObject() runtime.Object

+ func (list ClusterParserList) Load(sl plugins.SecretLoader, existingParsers map[string]bool) (string, error)

+ type Collector struct

+ Spec CollectorSpec

+ Status CollectorStatus

+ func (co *Collector) AddFinalizer(finalizerName string)

+ func (co *Collector) HasFinalizer(finalizerName string) bool

+ func (co *Collector) IsBeingDeleted() bool

+ func (co *Collector) RemoveFinalizer(finalizerName string)

+ func (in *Collector) DeepCopy() *Collector

+ func (in *Collector) DeepCopyInto(out *Collector)

+ func (in *Collector) DeepCopyObject() runtime.Object

+ type CollectorList struct

+ Items []Collector

+ func (in *CollectorList) DeepCopy() *CollectorList

+ func (in *CollectorList) DeepCopyInto(out *CollectorList)

+ func (in *CollectorList) DeepCopyObject() runtime.Object

+ type CollectorService struct

+ Annotations map[string]string

+ Labels map[string]string

+ Name string

+ func (in *CollectorService) DeepCopy() *CollectorService

+ func (in *CollectorService) DeepCopyInto(out *CollectorService)

+ type CollectorSpec struct

+ Affinity *corev1.Affinity

+ Annotations map[string]string

+ Args []string

+ BufferPath *string

+ DisableService bool

+ FluentBitConfigName string

+ HostNetwork bool

+ Image string

+ ImagePullPolicy corev1.PullPolicy

+ ImagePullSecrets []corev1.LocalObjectReference

+ NodeSelector map[string]string

+ PersistentVolumeClaim *corev1.PersistentVolumeClaim

+ Ports []corev1.ContainerPort

+ PriorityClassName string

+ RBACRules []rbacv1.PolicyRule

+ Resources corev1.ResourceRequirements

+ RuntimeClassName string

+ SchedulerName string

+ Secrets []string

+ SecurityContext *corev1.PodSecurityContext

+ Service CollectorService

+ ServiceAccountAnnotations map[string]string

+ Tolerations []corev1.Toleration

+ Volumes []corev1.Volume

+ VolumesMounts []corev1.VolumeMount

+ func (in *CollectorSpec) DeepCopy() *CollectorSpec

+ func (in *CollectorSpec) DeepCopyInto(out *CollectorSpec)

+ type CollectorStatus struct

+ func (in *CollectorStatus) DeepCopy() *CollectorStatus

+ func (in *CollectorStatus) DeepCopyInto(out *CollectorStatus)

+ type Decorder struct

+ DecodeField string

+ DecodeFieldAs string

+ func (in *Decorder) DeepCopy() *Decorder

+ func (in *Decorder) DeepCopyInto(out *Decorder)

+ type Filter struct

+ Spec FilterSpec

+ func (in *Filter) DeepCopy() *Filter

+ func (in *Filter) DeepCopyInto(out *Filter)

+ func (in *Filter) DeepCopyObject() runtime.Object

+ type FilterByOrdinalAndName []ClusterFilter

+ func (a FilterByOrdinalAndName) Len() int

+ func (a FilterByOrdinalAndName) Less(i, j int) bool

+ func (a FilterByOrdinalAndName) Swap(i, j int)

+ type FilterItem struct

+ AWS *filter.AWS

+ CustomPlugin *custom.CustomPlugin

+ Grep *filter.Grep

+ Kubernetes *filter.Kubernetes

+ LogToMetrics *filter.LogToMetrics

+ Lua *filter.Lua

+ Modify *filter.Modify

+ Multiline *filter.Multiline

+ Nest *filter.Nest

+ Parser *filter.Parser

+ RecordModifier *filter.RecordModifier

+ RewriteTag *filter.RewriteTag

+ Throttle *filter.Throttle

+ Wasm *filter.Wasm

+ func (in *FilterItem) DeepCopy() *FilterItem

+ func (in *FilterItem) DeepCopyInto(out *FilterItem)

+ type FilterList struct

+ Items []Filter

+ func (in *FilterList) DeepCopy() *FilterList

+ func (in *FilterList) DeepCopyInto(out *FilterList)

+ func (in *FilterList) DeepCopyObject() runtime.Object

+ func (list FilterList) Load(sl plugins.SecretLoader) (string, error)

+ func (list FilterList) LoadAsYaml(sl plugins.SecretLoader, depth int) (string, error)

+ type FilterSpec struct

+ FilterItems []FilterItem

+ LogLevel string

+ Match string

+ MatchRegex string

+ Ordinal int32

+ func (in *FilterSpec) DeepCopy() *FilterSpec

+ func (in *FilterSpec) DeepCopyInto(out *FilterSpec)

+ type FluentBit struct

+ Spec FluentBitSpec

+ Status FluentBitStatus

+ func (fb *FluentBit) AddFinalizer(finalizerName string)

+ func (fb *FluentBit) HasFinalizer(finalizerName string) bool

+ func (fb *FluentBit) IsBeingDeleted() bool

+ func (fb *FluentBit) RemoveFinalizer(finalizerName string)

+ func (in *FluentBit) DeepCopy() *FluentBit

+ func (in *FluentBit) DeepCopyInto(out *FluentBit)

+ func (in *FluentBit) DeepCopyObject() runtime.Object

+ type FluentBitConfig struct

+ Spec NamespacedFluentBitCfgSpec

+ func (in *FluentBitConfig) DeepCopy() *FluentBitConfig

+ func (in *FluentBitConfig) DeepCopyInto(out *FluentBitConfig)

+ func (in *FluentBitConfig) DeepCopyObject() runtime.Object

+ type FluentBitConfigList struct

+ Items []FluentBitConfig

+ func (in *FluentBitConfigList) DeepCopy() *FluentBitConfigList

+ func (in *FluentBitConfigList) DeepCopyInto(out *FluentBitConfigList)

+ func (in *FluentBitConfigList) DeepCopyObject() runtime.Object

+ type FluentBitConfigSpec struct

+ ConfigFileFormat *string

+ FilterSelector metav1.LabelSelector

+ InputSelector metav1.LabelSelector

+ MultilineParserSelector metav1.LabelSelector

+ Namespace *string

+ OutputSelector metav1.LabelSelector

+ ParserSelector metav1.LabelSelector

+ Service *Service

+ func (in *FluentBitConfigSpec) DeepCopy() *FluentBitConfigSpec

+ func (in *FluentBitConfigSpec) DeepCopyInto(out *FluentBitConfigSpec)

+ type FluentBitList struct

+ Items []FluentBit

+ func (in *FluentBitList) DeepCopy() *FluentBitList

+ func (in *FluentBitList) DeepCopyInto(out *FluentBitList)

+ func (in *FluentBitList) DeepCopyObject() runtime.Object

+ type FluentBitService struct

+ Annotations map[string]string

+ Labels map[string]string

+ Name string

+ func (in *FluentBitService) DeepCopy() *FluentBitService

+ func (in *FluentBitService) DeepCopyInto(out *FluentBitService)

+ type FluentBitSpec struct

+ Affinity *corev1.Affinity

+ Annotations map[string]string

+ Args []string

+ Command []string

+ ContainerLogRealPath string

+ ContainerSecurityContext *corev1.SecurityContext

+ DNSPolicy corev1.DNSPolicy

+ DisableLogVolumes bool

+ DisableService bool

+ EnvVars []corev1.EnvVar

+ FluentBitConfigName string

+ HostAliases []corev1.HostAlias

+ HostNetwork bool

+ Image string

+ ImagePullPolicy corev1.PullPolicy

+ ImagePullSecrets []corev1.LocalObjectReference

+ InitContainers []corev1.Container

+ InternalMountPropagation *corev1.MountPropagationMode

+ Labels map[string]string

+ LivenessProbe *corev1.Probe

+ MetricsPort int32

+ NamespacedFluentBitCfgSelector metav1.LabelSelector

+ NodeSelector map[string]string

+ Ports []corev1.ContainerPort

+ PositionDB corev1.VolumeSource

+ PriorityClassName string

+ RBACRules []rbacv1.PolicyRule

+ ReadinessProbe *corev1.Probe

+ Resources corev1.ResourceRequirements

+ RuntimeClassName string

+ SchedulerName string

+ Secrets []string

+ SecurityContext *corev1.PodSecurityContext

+ Service FluentBitService

+ ServiceAccountAnnotations map[string]string

+ TerminationGracePeriodSeconds *int64

+ Tolerations []corev1.Toleration

+ Volumes []corev1.Volume

+ VolumesMounts []corev1.VolumeMount

+ func (in *FluentBitSpec) DeepCopy() *FluentBitSpec

+ func (in *FluentBitSpec) DeepCopyInto(out *FluentBitSpec)

+ type FluentBitStatus struct

+ func (in *FluentBitStatus) DeepCopy() *FluentBitStatus

+ func (in *FluentBitStatus) DeepCopyInto(out *FluentBitStatus)

+ type InputByName []ClusterInput

+ func (a InputByName) Len() int

+ func (a InputByName) Less(i, j int) bool

+ func (a InputByName) Swap(i, j int)

+ type InputSpec struct

+ Alias string

+ Collectd *input.Collectd

+ CustomPlugin *custom.CustomPlugin

+ Dummy *input.Dummy

+ ExecWasi *input.ExecWasi

+ FluentBitMetrics *input.FluentbitMetrics

+ Forward *input.Forward

+ HTTP *input.HTTP

+ KubernetesEvents *input.KubernetesEvents

+ LogLevel string

+ MQTT *input.MQTT

+ Nginx *input.Nginx

+ NodeExporterMetrics *input.NodeExporterMetrics

+ OpenTelemetry *input.OpenTelemetry

+ Processors *plugins.Config

+ PrometheusScrapeMetrics *input.PrometheusScrapeMetrics

+ StatsD *input.StatsD

+ Syslog *input.Syslog

+ Systemd *input.Systemd

+ TCP *input.TCP

+ Tail *input.Tail

+ UDP *input.UDP

+ func (in *InputSpec) DeepCopy() *InputSpec

+ func (in *InputSpec) DeepCopyInto(out *InputSpec)

+ type MultilineParser struct

+ Spec MultilineParserSpec

+ func (in *MultilineParser) DeepCopy() *MultilineParser

+ func (in *MultilineParser) DeepCopyInto(out *MultilineParser)

+ func (in *MultilineParser) DeepCopyObject() runtime.Object

+ type MultilineParserByName []MultilineParser

+ func (a MultilineParserByName) Len() int

+ func (a MultilineParserByName) Less(i, j int) bool

+ func (a MultilineParserByName) Swap(i, j int)

+ type MultilineParserList struct

+ Items []MultilineParser

+ func (in *MultilineParserList) DeepCopy() *MultilineParserList

+ func (in *MultilineParserList) DeepCopyInto(out *MultilineParserList)

+ func (in *MultilineParserList) DeepCopyObject() runtime.Object

+ func (list MultilineParserList) Load(sl plugins.SecretLoader) (string, error)

+ type MultilineParserSpec struct

+ func (in *MultilineParserSpec) DeepCopy() *MultilineParserSpec

+ func (in *MultilineParserSpec) DeepCopyInto(out *MultilineParserSpec)

+ type NSFilterByOrdinalAndName []Filter

+ func (a NSFilterByOrdinalAndName) Len() int

+ func (a NSFilterByOrdinalAndName) Less(i, j int) bool

+ func (a NSFilterByOrdinalAndName) Swap(i, j int)

+ func (in NSFilterByOrdinalAndName) DeepCopy() NSFilterByOrdinalAndName

+ func (in NSFilterByOrdinalAndName) DeepCopyInto(out *NSFilterByOrdinalAndName)

+ type NSOutputByName []Output

+ func (a NSOutputByName) Len() int

+ func (a NSOutputByName) Less(i, j int) bool

+ func (a NSOutputByName) Swap(i, j int)

+ func (in NSOutputByName) DeepCopy() NSOutputByName

+ func (in NSOutputByName) DeepCopyInto(out *NSOutputByName)

+ type NSParserByName []Parser

+ func (a NSParserByName) Len() int

+ func (a NSParserByName) Less(i, j int) bool

+ func (a NSParserByName) Swap(i, j int)

+ func (in NSParserByName) DeepCopy() NSParserByName

+ func (in NSParserByName) DeepCopyInto(out *NSParserByName)

+ type NamespacedFluentBitCfgSpec struct

+ ClusterMultilineParserSelector metav1.LabelSelector

+ ClusterParserSelector metav1.LabelSelector

+ FilterSelector metav1.LabelSelector

+ MultilineParserSelector metav1.LabelSelector

+ OutputSelector metav1.LabelSelector

+ ParserSelector metav1.LabelSelector

+ Service *Service

+ func (in *NamespacedFluentBitCfgSpec) DeepCopy() *NamespacedFluentBitCfgSpec

+ func (in *NamespacedFluentBitCfgSpec) DeepCopyInto(out *NamespacedFluentBitCfgSpec)

+ type Output struct

+ Spec OutputSpec

+ func (in *Output) DeepCopy() *Output

+ func (in *Output) DeepCopyInto(out *Output)

+ func (in *Output) DeepCopyObject() runtime.Object

+ type OutputByName []ClusterOutput

+ func (a OutputByName) Len() int

+ func (a OutputByName) Less(i, j int) bool

+ func (a OutputByName) Swap(i, j int)

+ type OutputList struct

+ Items []Output

+ func (in *OutputList) DeepCopy() *OutputList

+ func (in *OutputList) DeepCopyInto(out *OutputList)

+ func (in *OutputList) DeepCopyObject() runtime.Object

+ func (list OutputList) Load(sl plugins.SecretLoader) (string, error)

+ func (list OutputList) LoadAsYaml(sl plugins.SecretLoader, depth int) (string, error)

+ type OutputSpec struct

+ Alias string

+ AzureBlob *output.AzureBlob

+ AzureLogAnalytics *output.AzureLogAnalytics

+ CloudWatch *output.CloudWatch

+ CustomPlugin *custom.CustomPlugin

+ DataDog *output.DataDog

+ Elasticsearch *output.Elasticsearch

+ File *output.File

+ Firehose *output.Firehose

+ Forward *output.Forward

+ Gelf *output.Gelf

+ HTTP *output.HTTP

+ InfluxDB *output.InfluxDB

+ Kafka *output.Kafka

+ Kinesis *output.Kinesis

+ LogLevel string

+ Loki *output.Loki

+ Match string

+ MatchRegex string

+ Null *output.Null

+ OpenSearch *output.OpenSearch

+ OpenTelemetry *output.OpenTelemetry

+ Processors *plugins.Config

+ PrometheusExporter *output.PrometheusExporter

+ PrometheusRemoteWrite *output.PrometheusRemoteWrite

+ RetryLimit string

+ S3 *output.S3

+ Splunk *output.Splunk

+ Stackdriver *output.Stackdriver

+ Stdout *output.Stdout

+ Syslog *output.Syslog

+ TCP *output.TCP

+ func (in *OutputSpec) DeepCopy() *OutputSpec

+ func (in *OutputSpec) DeepCopyInto(out *OutputSpec)

+ type Parser struct

+ Spec ParserSpec

+ func (in *Parser) DeepCopy() *Parser

+ func (in *Parser) DeepCopyInto(out *Parser)

+ func (in *Parser) DeepCopyObject() runtime.Object

+ type ParserByName []ClusterParser

+ func (a ParserByName) Len() int

+ func (a ParserByName) Less(i, j int) bool

+ func (a ParserByName) Swap(i, j int)

+ type ParserList struct

+ Items []Parser

+ func (in *ParserList) DeepCopy() *ParserList

+ func (in *ParserList) DeepCopyInto(out *ParserList)

+ func (in *ParserList) DeepCopyObject() runtime.Object

+ func (list ParserList) Load(sl plugins.SecretLoader) (string, error)

+ type ParserSpec struct

+ Decoders []Decorder

+ JSON *parser.JSON

+ LTSV *parser.LSTV

+ Logfmt *parser.Logfmt

+ Regex *parser.Regex

+ func (in *ParserSpec) DeepCopy() *ParserSpec

+ func (in *ParserSpec) DeepCopyInto(out *ParserSpec)

+ type Script struct

+ Content string

+ Name string

+ type Service struct

+ Daemon *bool

+ EmitterMemBufLimit string

+ EmitterName string

+ EmitterStorageType string

+ FlushSeconds *float64

+ GraceSeconds *int64

+ HcErrorsCount *int64

+ HcPeriod *int64

+ HcRetryFailureCount *int64

+ HealthCheck *bool

+ HotReload *bool

+ HttpListen string

+ HttpPort *int32

+ HttpServer *bool

+ LogFile string

+ LogLevel string

+ ParsersFile string

+ ParsersFiles []string

+ Storage *Storage

+ func (in *Service) DeepCopy() *Service

+ func (in *Service) DeepCopyInto(out *Service)

+ func (s *Service) Params() *params.KVs

+ type Storage struct

+ BacklogMemLimit string

+ Checksum string

+ DeleteIrrecoverableChunks string

+ MaxChunksUp *int64

+ Metrics string

+ Path string

+ Sync string

+ func (in *Storage) DeepCopy() *Storage

+ func (in *Storage) DeepCopyInto(out *Storage)

Other modules containing this package

github.com/fluent/fluent-operator

github.com/fluent/fluent-operator/v2