Versions in this module Expand all Collapse all v3 v3.5.0 Oct 24, 2025 v3.4.0 May 9, 2025 Changes in this version type Tail + DBLocking *bool v3.3.0 Mar 6, 2025 Changes in this version + type Collectd struct + Listen string + Port *int32 + TypesDB string + func (_ *Collectd) Name() string + func (c *Collectd) Params(_ plugins.SecretLoader) (*params.KVs, error) + func (in *Collectd) DeepCopy() *Collectd + func (in *Collectd) DeepCopyInto(out *Collectd) + type Dummy struct + Dummy string + Rate *int32 + Samples *int32 + Tag string + func (_ *Dummy) Name() string + func (d *Dummy) Params(_ plugins.SecretLoader) (*params.KVs, error) + func (in *Dummy) DeepCopy() *Dummy + func (in *Dummy) DeepCopyInto(out *Dummy) + type ExecWasi struct + AccessiblePaths []string + BufSize string + IntervalNSec *int64 + IntervalSec *int32 + Parser string + Threaded *bool + WASIPath string + WasmHeapSize string + WasmStackSize string + func (_ *ExecWasi) Name() string + func (in *ExecWasi) DeepCopy() *ExecWasi + func (in *ExecWasi) DeepCopyInto(out *ExecWasi) + func (w *ExecWasi) Params(_ plugins.SecretLoader) (*params.KVs, error) + type FluentbitMetrics struct + ScrapeInterval string + ScrapeOnStart *bool + Tag string + func (_ *FluentbitMetrics) Name() string + func (f *FluentbitMetrics) Params(_ plugins.SecretLoader) (*params.KVs, error) + func (in *FluentbitMetrics) DeepCopy() *FluentbitMetrics + func (in *FluentbitMetrics) DeepCopyInto(out *FluentbitMetrics) + type Forward struct + BufferChunkSize string + BufferMaxSize string + Listen string + Port *int32 + Tag string + TagPrefix string + Threaded string + UnixPath string + UnixPerm string + func (_ *Forward) Name() string + func (f *Forward) Params(_ plugins.SecretLoader) (*params.KVs, error) + func (in *Forward) DeepCopy() *Forward + func (in *Forward) DeepCopyInto(out *Forward) + type HTTP struct + BufferChunkSize string + BufferMaxSize string + Listen string + Port *int32 + SuccessfulHeader string + SuccessfulResponseCode *int32 + Tagkey string + func (_ *HTTP) Name() string + func (h *HTTP) Params(sl plugins.SecretLoader) (*params.KVs, error) + func (in *HTTP) DeepCopy() *HTTP + func (in *HTTP) DeepCopyInto(out *HTTP) + type KubernetesEvents struct + DB string + DBSync string + IntervalNsec *int64 + IntervalSec *int32 + KubeCAFile string + KubeCAPath string + KubeNamespace string + KubeRequestLimit *int32 + KubeRetentionTime string + KubeTokenFile string + KubeTokenTTL string + KubeURL string + TLSDebug *int32 + TLSVerify *bool + TLSVhost string + Tag string + func (_ *KubernetesEvents) Name() string + func (in *KubernetesEvents) DeepCopy() *KubernetesEvents + func (in *KubernetesEvents) DeepCopyInto(out *KubernetesEvents) + func (k *KubernetesEvents) Params(_ plugins.SecretLoader) (*params.KVs, error) + type MQTT struct + Listen string + Port *int32 + func (_ *MQTT) Name() string + func (in *MQTT) DeepCopy() *MQTT + func (in *MQTT) DeepCopyInto(out *MQTT) + func (m *MQTT) Params(_ plugins.SecretLoader) (*params.KVs, error) + type Nginx struct + Host string + NginxPlus *bool + Port *int32 + StatusURL string + func (_ *Nginx) Name() string + func (in *Nginx) DeepCopy() *Nginx + func (in *Nginx) DeepCopyInto(out *Nginx) + func (n *Nginx) Params(_ plugins.SecretLoader) (*params.KVs, error) + type NodeExporterMetrics struct + Path *Path + ScrapeInterval string + Tag string + func (_ *NodeExporterMetrics) Name() string + func (d *NodeExporterMetrics) Params(_ plugins.SecretLoader) (*params.KVs, error) + func (in *NodeExporterMetrics) DeepCopy() *NodeExporterMetrics + func (in *NodeExporterMetrics) DeepCopyInto(out *NodeExporterMetrics) + type OpenTelemetry struct + BufferChunkSize string + BufferMaxSize string + Listen string + Port *int32 + RawTraces *bool + SuccessfulResponseCode *int32 + Tag string + TagFromURI *bool + Tagkey string + func (_ *OpenTelemetry) Name() string + func (in *OpenTelemetry) DeepCopy() *OpenTelemetry + func (in *OpenTelemetry) DeepCopyInto(out *OpenTelemetry) + func (ot *OpenTelemetry) Params(_ plugins.SecretLoader) (*params.KVs, error) + type Path struct + Procfs string + Sysfs string + func (in *Path) DeepCopy() *Path + func (in *Path) DeepCopyInto(out *Path) + type PrometheusScrapeMetrics struct + Host string + MetricsPath string + Port *int32 + ScrapeInterval string + Tag string + func (_ *PrometheusScrapeMetrics) Name() string + func (in *PrometheusScrapeMetrics) DeepCopy() *PrometheusScrapeMetrics + func (in *PrometheusScrapeMetrics) DeepCopyInto(out *PrometheusScrapeMetrics) + func (p *PrometheusScrapeMetrics) Params(_ plugins.SecretLoader) (*params.KVs, error) + type StatsD struct + Listen string + Port *int32 + func (_ *StatsD) Name() string + func (in *StatsD) DeepCopy() *StatsD + func (in *StatsD) DeepCopyInto(out *StatsD) + func (s *StatsD) Params(_ plugins.SecretLoader) (*params.KVs, error) + type Syslog struct + BufferChunkSize string + BufferMaxSize string + Listen string + Mode string + Parser string + Path string + Port *int32 + ReceiveBufferSize string + SourceAddressKey string + UnixPerm *int32 + func (_ *Syslog) Name() string + func (in *Syslog) DeepCopy() *Syslog + func (in *Syslog) DeepCopyInto(out *Syslog) + func (s *Syslog) Params(_ plugins.SecretLoader) (*params.KVs, error) + type Systemd struct + DB string + DBSync string + MaxEntries int + MaxFields int + Path string + PauseOnChunksOverlimit string + ReadFromTail string + StorageType string + StripUnderscores string + SystemdFilter []string + SystemdFilterType string + Tag string + func (_ *Systemd) Name() string + func (in *Systemd) DeepCopy() *Systemd + func (in *Systemd) DeepCopyInto(out *Systemd) + func (s *Systemd) Params(_ plugins.SecretLoader) (*params.KVs, error) + type TCP struct + BufferSize string + ChunkSize string + Format string + Listen string + Port *int32 + Separator string + func (_ *TCP) Name() string + func (in *TCP) DeepCopy() *TCP + func (in *TCP) DeepCopyInto(out *TCP) + func (t *TCP) Params(sl plugins.SecretLoader) (*params.KVs, error) + type Tail struct + BufferChunkSize string + BufferMaxSize string + DB string + DBSync string + DisableInotifyWatcher *bool + DockerMode *bool + DockerModeFlushSeconds *int64 + DockerModeParser string + ExcludePath string + IgnoreOlder string + Key string + MemBufLimit string + Multiline *bool + MultilineFlushSeconds *int64 + MultilineParser string + OffsetKey string + Parser string + ParserFirstline string + ParserN []string + Path string + PathKey string + PauseOnChunksOverlimit string + ReadFromHead *bool + RefreshIntervalSeconds *int64 + RotateWaitSeconds *int64 + SkipEmptyLines *bool + SkipLongLines *bool + StorageType string + Tag string + TagRegex string + Threaded *string + func (_ *Tail) Name() string + func (in *Tail) DeepCopy() *Tail + func (in *Tail) DeepCopyInto(out *Tail) + func (t *Tail) Params(_ plugins.SecretLoader) (*params.KVs, error) + type UDP struct + BufferSize *string + ChunkSize *string + Format *string + Listen *string + Port *int32 + Separator *string + SourceAddressKey *string + Threaded *string + func (_ *UDP) Name() string + func (in *UDP) DeepCopy() *UDP + func (in *UDP) DeepCopyInto(out *UDP) + func (u *UDP) Params(_ plugins.SecretLoader) (*params.KVs, error) Other modules containing this package github.com/fluent/fluent-operator github.com/fluent/fluent-operator/v2