v1alpha1

package
v3.0.0-...-cc23366 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 29, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the v1alpha1 API group +kubebuilder:object:generate=true +groupName=fluentd.fluent.io

Index

Constants

View Source 
const FluentdFinalizerName = "fluentd.fluent.io"

FluentBitFinalizerName is the name of the fluentbit finalizer

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: "fluentd.fluent.io", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type BufferVolume 

type BufferVolume struct {
	// Enabled buffer pvc by default.
	DisableBufferVolume bool `json:"disableBufferVolume,omitempty"`

	// Volume definition.
	HostPath *corev1.HostPathVolumeSource `json:"hostPath,omitempty"`
	EmptyDir *corev1.EmptyDirVolumeSource `json:"emptyDir,omitempty"`

	// PVC definition
	PersistentVolumeClaim *corev1.PersistentVolumeClaim `json:"pvc,omitempty"`
}

func (*BufferVolume) DeepCopy 

func (in *BufferVolume) DeepCopy() *BufferVolume

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BufferVolume.

func (*BufferVolume) DeepCopyInto 

func (in *BufferVolume) DeepCopyInto(out *BufferVolume)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ByHashcode 

type ByHashcode []params.PluginStore

+kubebuilder:object:generate:=false

func (ByHashcode) Less 

func (a ByHashcode) Less(i, j int) bool

type ByRouteLabels 

type ByRouteLabels []params.PluginStore

+kubebuilder:object:generate:=false

func (ByRouteLabels) Less 

func (a ByRouteLabels) Less(i, j int) bool

type ByRouteLabelsPointers 

type ByRouteLabelsPointers []*params.PluginStore

+kubebuilder:object:generate:=false

func (ByRouteLabelsPointers) Less 

func (a ByRouteLabelsPointers) Less(i, j int) bool

type ByTags 

type ByTags []params.PluginStore

+kubebuilder:object:generate:=false

func (ByTags) Less 

func (a ByTags) Less(i, j int) bool

type CfgResources 

type CfgResources struct {
	InputPlugins  []params.PluginStore
	FilterPlugins []params.PluginStore
	OutputPlugins []params.PluginStore

	// the hash codes used to depulicate removel
	InputsHashcodes  map[string]bool
	FiltersHashcodes map[string]bool
	OutputsHashcodes map[string]bool
}

+kubebuilder:object:generate=false All the filter/output selected to this cfg

func NewCfgResources 

func NewCfgResources() *CfgResources

type ClusterFilter 

type ClusterFilter struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ClusterFilterSpec   `json:"spec,omitempty"`
	Status ClusterFilterStatus `json:"status,omitempty"`
}

ClusterFilter is the Schema for the clusterfilters API

func (*ClusterFilter) DeepCopy 

func (in *ClusterFilter) DeepCopy() *ClusterFilter

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterFilter.

func (*ClusterFilter) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClusterFilter) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ClusterFilterList 

type ClusterFilterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ClusterFilter `json:"items"`
}

ClusterFilterList contains a list of ClusterFilter

func (*ClusterFilterList) DeepCopy 

func (in *ClusterFilterList) DeepCopy() *ClusterFilterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterFilterList.

func (*ClusterFilterList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClusterFilterList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ClusterFilterSpec 

type ClusterFilterSpec struct {
	Filters []filter.Filter `json:"filters,omitempty"`
}

ClusterFilterSpec defines the desired state of ClusterFilter

func (*ClusterFilterSpec) DeepCopy 

func (in *ClusterFilterSpec) DeepCopy() *ClusterFilterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterFilterSpec.

func (*ClusterFilterSpec) DeepCopyInto 

func (in *ClusterFilterSpec) DeepCopyInto(out *ClusterFilterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterFilterStatus 

type ClusterFilterStatus struct {
}

ClusterFilterStatus defines the observed state of ClusterFilter

func (*ClusterFilterStatus) DeepCopy 

func (in *ClusterFilterStatus) DeepCopy() *ClusterFilterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterFilterStatus.

func (*ClusterFilterStatus) DeepCopyInto 

func (in *ClusterFilterStatus) DeepCopyInto(out *ClusterFilterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterFluentdConfig 

type ClusterFluentdConfig struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ClusterFluentdConfigSpec   `json:"spec,omitempty"`
	Status ClusterFluentdConfigStatus `json:"status,omitempty"`
}

ClusterFluentdConfig is the Schema for the clusterfluentdconfigs API

func (*ClusterFluentdConfig) DeepCopy 

func (in *ClusterFluentdConfig) DeepCopy() *ClusterFluentdConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterFluentdConfig.

func (*ClusterFluentdConfig) DeepCopyInto 

func (in *ClusterFluentdConfig) DeepCopyInto(out *ClusterFluentdConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClusterFluentdConfig) DeepCopyObject 

func (in *ClusterFluentdConfig) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ClusterFluentdConfig) GetCfgId 

func (cfg *ClusterFluentdConfig) GetCfgId() string

func (*ClusterFluentdConfig) GetName 

func (cfg *ClusterFluentdConfig) GetName() string

func (*ClusterFluentdConfig) GetNamespace 

func (cfg *ClusterFluentdConfig) GetNamespace() string

func (*ClusterFluentdConfig) GetWatchedContainers 

func (cfg *ClusterFluentdConfig) GetWatchedContainers() []string

func (*ClusterFluentdConfig) GetWatchedHosts 

func (cfg *ClusterFluentdConfig) GetWatchedHosts() []string

func (*ClusterFluentdConfig) GetWatchedLabels 

func (cfg *ClusterFluentdConfig) GetWatchedLabels() map[string]string

func (*ClusterFluentdConfig) GetWatchedNamespaces 

func (cfg *ClusterFluentdConfig) GetWatchedNamespaces() []string

type ClusterFluentdConfigList 

type ClusterFluentdConfigList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ClusterFluentdConfig `json:"items"`
}

ClusterFluentdConfigList contains a list of ClusterFluentdConfig

func (*ClusterFluentdConfigList) DeepCopy 

func (in *ClusterFluentdConfigList) DeepCopy() *ClusterFluentdConfigList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterFluentdConfigList.

func (*ClusterFluentdConfigList) DeepCopyInto 

func (in *ClusterFluentdConfigList) DeepCopyInto(out *ClusterFluentdConfigList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClusterFluentdConfigList) DeepCopyObject 

func (in *ClusterFluentdConfigList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ClusterFluentdConfigSpec 

type ClusterFluentdConfigSpec struct {
	// Emit mode. If batch, the plugin will emit events per labels matched. Enum: record, batch.
	// will make no effect if EnableFilterKubernetes is set false.
	// +kubebuilder:validation:Enum:=record;batch
	EmitMode string `json:"emit_mode,omitempty"`
	// Sticky tags will match only one record from an event stream. The same tag will be treated the same way.
	// will make no effect if EnableFilterKubernetes is set false.
	StickyTags string `json:"stickyTags,omitempty"`
	// A set of namespaces. The whole namespaces would be watched if left empty.
	WatchedNamespaces []string `json:"watchedNamespaces,omitempty"`
	// A set of hosts. Ignored if left empty.
	WatchedHosts []string `json:"watchedHosts,omitempty"`
	// A set of container names. Ignored if left empty.
	WatchedContainers []string `json:"watchedConstainers,omitempty"`
	// Use this field to filter the logs, will make no effect if EnableFilterKubernetes is set false.
	WatchedLabels map[string]string `json:"watchedLabels,omitempty"`
	// Select cluster filter plugins
	ClusterFilterSelector *metav1.LabelSelector `json:"clusterFilterSelector,omitempty"`
	// Select cluster output plugins
	ClusterOutputSelector *metav1.LabelSelector `json:"clusterOutputSelector,omitempty"`
	// Select cluster input plugins
	ClusterInputSelector *metav1.LabelSelector `json:"clusterInputSelector,omitempty"`
}

ClusterFluentdConfigSpec defines the desired state of ClusterFluentdConfig

func (*ClusterFluentdConfigSpec) DeepCopy 

func (in *ClusterFluentdConfigSpec) DeepCopy() *ClusterFluentdConfigSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterFluentdConfigSpec.

func (*ClusterFluentdConfigSpec) DeepCopyInto 

func (in *ClusterFluentdConfigSpec) DeepCopyInto(out *ClusterFluentdConfigSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterFluentdConfigStatus 

type ClusterFluentdConfigStatus struct {
	// Messages defines the plugin errors which is selected by this fluentdconfig
	Messages string `json:"messages,omitempty"`
	// The state of this fluentd config
	State StatusState `json:"state,omitempty"`
}

ClusterFluentdConfigStatus defines the observed state of ClusterFluentdConfig

func (*ClusterFluentdConfigStatus) DeepCopy 

func (in *ClusterFluentdConfigStatus) DeepCopy() *ClusterFluentdConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterFluentdConfigStatus.

func (*ClusterFluentdConfigStatus) DeepCopyInto 

func (in *ClusterFluentdConfigStatus) DeepCopyInto(out *ClusterFluentdConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterInput 

type ClusterInput struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ClusterInputSpec   `json:"spec,omitempty"`
	Status ClusterInputStatus `json:"status,omitempty"`
}

ClusterInput is the Schema for the clusterinputs API

func (*ClusterInput) DeepCopy 

func (in *ClusterInput) DeepCopy() *ClusterInput

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterInput.

func (*ClusterInput) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClusterInput) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ClusterInputList 

type ClusterInputList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ClusterInput `json:"items"`
}

ClusterInputList contains a list of ClusterInput

func (*ClusterInputList) DeepCopy 

func (in *ClusterInputList) DeepCopy() *ClusterInputList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterInputList.

func (*ClusterInputList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClusterInputList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ClusterInputSpec 

type ClusterInputSpec struct {
	Inputs []input.Input `json:"inputs,omitempty"`
}

ClusterInputSpec defines the desired state of ClusterInput

func (*ClusterInputSpec) DeepCopy 

func (in *ClusterInputSpec) DeepCopy() *ClusterInputSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterInputSpec.

func (*ClusterInputSpec) DeepCopyInto 

func (in *ClusterInputSpec) DeepCopyInto(out *ClusterInputSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterInputStatus 

type ClusterInputStatus struct {
}

ClusterInputStatus defines the observed state of ClusterInput

func (*ClusterInputStatus) DeepCopy 

func (in *ClusterInputStatus) DeepCopy() *ClusterInputStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterInputStatus.

func (*ClusterInputStatus) DeepCopyInto 

func (in *ClusterInputStatus) DeepCopyInto(out *ClusterInputStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterOutput 

type ClusterOutput struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ClusterOutputSpec   `json:"spec,omitempty"`
	Status ClusterOutputStatus `json:"status,omitempty"`
}

ClusterOutput is the Schema for the clusteroutputs API

func (*ClusterOutput) DeepCopy 

func (in *ClusterOutput) DeepCopy() *ClusterOutput

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOutput.

func (*ClusterOutput) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClusterOutput) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ClusterOutputList 

type ClusterOutputList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ClusterOutput `json:"items"`
}

ClusterOutputList contains a list of ClusterOutput

func (*ClusterOutputList) DeepCopy 

func (in *ClusterOutputList) DeepCopy() *ClusterOutputList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOutputList.

func (*ClusterOutputList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClusterOutputList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ClusterOutputSpec 

type ClusterOutputSpec struct {
	Outputs []output.Output `json:"outputs,omitempty"`
}

ClusterOutputSpec defines the desired state of ClusterOutput

func (*ClusterOutputSpec) DeepCopy 

func (in *ClusterOutputSpec) DeepCopy() *ClusterOutputSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOutputSpec.

func (*ClusterOutputSpec) DeepCopyInto 

func (in *ClusterOutputSpec) DeepCopyInto(out *ClusterOutputSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterOutputStatus 

type ClusterOutputStatus struct {
}

ClusterOutputStatus defines the observed state of ClusterOutput

func (*ClusterOutputStatus) DeepCopy 

func (in *ClusterOutputStatus) DeepCopy() *ClusterOutputStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOutputStatus.

func (*ClusterOutputStatus) DeepCopyInto 

func (in *ClusterOutputStatus) DeepCopyInto(out *ClusterOutputStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Filter 

type Filter struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   FilterSpec   `json:"spec,omitempty"`
	Status FilterStatus `json:"status,omitempty"`
}

Filter is the Schema for the filters API

func (*Filter) DeepCopy 

func (in *Filter) DeepCopy() *Filter

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Filter.

func (*Filter) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Filter) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type FilterList 

type FilterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Filter `json:"items"`
}

FilterList contains a list of Filter

func (*FilterList) DeepCopy 

func (in *FilterList) DeepCopy() *FilterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FilterList.

func (*FilterList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FilterList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type FilterSpec 

type FilterSpec struct {
	Filters []filter.Filter `json:"filters,omitempty"`
}

FilterSpec defines the desired state of Filter

func (*FilterSpec) DeepCopy 

func (in *FilterSpec) DeepCopy() *FilterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FilterSpec.

func (*FilterSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FilterStatus 

type FilterStatus struct {
}

FilterStatus defines the observed state of Filter

func (*FilterStatus) DeepCopy 

func (in *FilterStatus) DeepCopy() *FilterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FilterStatus.

func (*FilterStatus) DeepCopyInto 

func (in *FilterStatus) DeepCopyInto(out *FilterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FluentDService 

type FluentDService struct {
	// Name is the name of the FluentD service.
	Name string `json:"name,omitempty"`
	// Annotations to add to each FluentD service.
	Annotations map[string]string `json:"annotations,omitempty"`
	// Labels to add to each FluentD service
	Labels map[string]string `json:"labels,omitempty"`
}

FluentDService the service of the FluentD

func (*FluentDService) DeepCopy 

func (in *FluentDService) DeepCopy() *FluentDService

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FluentDService.

func (*FluentDService) DeepCopyInto 

func (in *FluentDService) DeepCopyInto(out *FluentDService)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Fluentd 

type Fluentd struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   FluentdSpec   `json:"spec,omitempty"`
	Status FluentdStatus `json:"status,omitempty"`
}

Fluentd is the Schema for the fluentds API

func (*Fluentd) AddFinalizer 

func (fd *Fluentd) AddFinalizer(finalizerName string)

AddFinalizer adds the specified finalizer

func (*Fluentd) DeepCopy 

func (in *Fluentd) DeepCopy() *Fluentd

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Fluentd.

func (*Fluentd) DeepCopyInto 

func (in *Fluentd) DeepCopyInto(out *Fluentd)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Fluentd) DeepCopyObject 

func (in *Fluentd) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Fluentd) HasFinalizer 

func (fd *Fluentd) HasFinalizer(finalizerName string) bool

HasFinalizer returns true if the item has the specified finalizer

func (*Fluentd) IsBeingDeleted 

func (fd *Fluentd) IsBeingDeleted() bool

IsBeingDeleted returns true if a deletion timestamp is set

func (*Fluentd) RemoveFinalizer 

func (fd *Fluentd) RemoveFinalizer(finalizerName string)

RemoveFinalizer removes the specified finalizer

type FluentdConfig 

type FluentdConfig struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   FluentdConfigSpec   `json:"spec,omitempty"`
	Status FluentdConfigStatus `json:"status,omitempty"`
}

FluentdConfig is the Schema for the fluentdconfigs API

func (*FluentdConfig) DeepCopy 

func (in *FluentdConfig) DeepCopy() *FluentdConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FluentdConfig.

func (*FluentdConfig) DeepCopyInto 

func (in *FluentdConfig) DeepCopyInto(out *FluentdConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FluentdConfig) DeepCopyObject 

func (in *FluentdConfig) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*FluentdConfig) GetCfgId 

func (cfg *FluentdConfig) GetCfgId() string

func (*FluentdConfig) GetName 

func (cfg *FluentdConfig) GetName() string

func (*FluentdConfig) GetNamespace 

func (cfg *FluentdConfig) GetNamespace() string

func (*FluentdConfig) GetWatchedContainers 

func (cfg *FluentdConfig) GetWatchedContainers() []string

func (*FluentdConfig) GetWatchedHosts 

func (cfg *FluentdConfig) GetWatchedHosts() []string

func (*FluentdConfig) GetWatchedLabels 

func (cfg *FluentdConfig) GetWatchedLabels() map[string]string

func (*FluentdConfig) GetWatchedNamespaces 

func (cfg *FluentdConfig) GetWatchedNamespaces() []string

type FluentdConfigList 

type FluentdConfigList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []FluentdConfig `json:"items"`
}

FluentdConfigList contains a list of FluentdConfig

func (*FluentdConfigList) DeepCopy 

func (in *FluentdConfigList) DeepCopy() *FluentdConfigList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FluentdConfigList.

func (*FluentdConfigList) DeepCopyInto 

func (in *FluentdConfigList) DeepCopyInto(out *FluentdConfigList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FluentdConfigList) DeepCopyObject 

func (in *FluentdConfigList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type FluentdConfigSpec 

type FluentdConfigSpec struct {
	// Emit mode. If batch, the plugin will emit events per labels matched. Enum: record, batch.
	// will make no effect if EnableFilterKubernetes is set false.
	// +kubebuilder:validation:Enum:=record;batch
	EmitMode string `json:"emit_mode,omitempty"`
	// Sticky tags will match only one record from an event stream. The same tag will be treated the same way.
	// will make no effect if EnableFilterKubernetes is set false.
	StickyTags string `json:"stickyTags,omitempty"`
	// A set of hosts. Ignored if left empty.
	WatchedHosts []string `json:"watchedHosts,omitempty"`
	// A set of container names. Ignored if left empty.
	WatchedContainers []string `json:"watchedConstainers,omitempty"`
	// Use this field to filter the logs, will make no effect if EnableFilterKubernetes is set false.
	WatchedLabels map[string]string `json:"watchedLabels,omitempty"`
	// Select namespaced filter plugins
	FilterSelector *metav1.LabelSelector `json:"filterSelector,omitempty"`
	// Select namespaced output plugins
	OutputSelector *metav1.LabelSelector `json:"outputSelector,omitempty"`
	// Select cluster input plugins
	InputSelector *metav1.LabelSelector `json:"inputSelector,omitempty"`
	// Select cluster filter plugins
	ClusterFilterSelector *metav1.LabelSelector `json:"clusterFilterSelector,omitempty"`
	// Select cluster output plugins
	ClusterOutputSelector *metav1.LabelSelector `json:"clusterOutputSelector,omitempty"`
	// Select cluster input plugins
	ClusterInputSelector *metav1.LabelSelector `json:"clusterInputSelector,omitempty"`
}

FluentdConfigSpec defines the desired state of FluentdConfig

func (*FluentdConfigSpec) DeepCopy 

func (in *FluentdConfigSpec) DeepCopy() *FluentdConfigSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FluentdConfigSpec.

func (*FluentdConfigSpec) DeepCopyInto 

func (in *FluentdConfigSpec) DeepCopyInto(out *FluentdConfigSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FluentdConfigStatus 

type FluentdConfigStatus struct {
	// Messages defines the plugin errors which is selected by this fluentdconfig
	Messages string `json:"messages,omitempty"`
	// The state of this fluentd config
	State StatusState `json:"state,omitempty"`
}

FluentdConfigStatus defines the observed state of FluentdConfig

func (*FluentdConfigStatus) DeepCopy 

func (in *FluentdConfigStatus) DeepCopy() *FluentdConfigStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FluentdConfigStatus.

func (*FluentdConfigStatus) DeepCopyInto 

func (in *FluentdConfigStatus) DeepCopyInto(out *FluentdConfigStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FluentdList 

type FluentdList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Fluentd `json:"items"`
}

FluentdList contains a list of Fluentd

func (*FluentdList) DeepCopy 

func (in *FluentdList) DeepCopy() *FluentdList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FluentdList.

func (*FluentdList) DeepCopyInto 

func (in *FluentdList) DeepCopyInto(out *FluentdList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FluentdList) DeepCopyObject 

func (in *FluentdList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type FluentdSpec 

type FluentdSpec struct {
	// Fluentd global inputs.
	GlobalInputs []input.Input `json:"globalInputs,omitempty"`
	// Select cluster input plugins used to gather the default cluster output
	DefaultInputSelector *metav1.LabelSelector `json:"defaultInputSelector,omitempty"`
	// Select cluster filter plugins used to filter for the default cluster output
	DefaultFilterSelector *metav1.LabelSelector `json:"defaultFilterSelector,omitempty"`
	// Select cluster output plugins used to send all logs that did not match any route to the matching outputs
	DefaultOutputSelector *metav1.LabelSelector `json:"defaultOutputSelector,omitempty"`
	// By default will build the related service according to the globalinputs definition.
	DisableService bool `json:"disableService,omitempty"`
	// Numbers of the Fluentd instance
	// Applicable when the mode is "collector", and will be ignored when the mode is "agent"
	Replicas *int32 `json:"replicas,omitempty"`
	// Numbers of the workers in Fluentd instance
	Workers *int32 `json:"workers,omitempty"`
	// Global logging verbosity
	// +kubebuilder:validation:Optional
	// +kubebuilder:validation:Enum:=fatal;error;warn;info;debug;trace
	// +kubebuilder:default:=info
	LogLevel string `json:"logLevel,omitempty"`
	// Fluentd image.
	Image string `json:"image,omitempty"`
	// Fluentd Watcher command line arguments.
	Args []string `json:"args,omitempty"`
	// EnvVars represent environment variables that can be passed to fluentd pods.
	EnvVars []corev1.EnvVar `json:"envVars,omitempty"`
	// FluentdCfgSelector defines the selectors to select the fluentd config CRs.
	FluentdCfgSelector metav1.LabelSelector `json:"fluentdCfgSelector,omitempty"`
	// Buffer definition
	BufferVolume *BufferVolume `json:"buffer,omitempty"`
	// Fluentd image pull policy.
	ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"`
	// Fluentd image pull secret
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
	// Compute Resources required by container.
	Resources corev1.ResourceRequirements `json:"resources,omitempty"`
	// NodeSelector
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
	// Annotations to add to each Fluentd pod.
	Annotations map[string]string `json:"annotations,omitempty"`
	// Annotations to add to the Fluentd service account
	ServiceAccountAnnotations map[string]string `json:"serviceAccountAnnotations,omitempty"`
	// Pod's scheduling constraints.
	Affinity *corev1.Affinity `json:"affinity,omitempty"`
	// Tolerations
	Tolerations []corev1.Toleration `json:"tolerations,omitempty"`
	// RuntimeClassName represents the container runtime configuration.
	RuntimeClassName string `json:"runtimeClassName,omitempty"`
	// PriorityClassName represents the pod's priority class.
	PriorityClassName string `json:"priorityClassName,omitempty"`
	// RBACRules represents additional rbac rules which will be applied to the fluentd clusterrole.
	RBACRules []rbacv1.PolicyRule `json:"rbacRules,omitempty"`
	// List of volumes that can be mounted by containers belonging to the pod.
	Volumes []corev1.Volume `json:"volumes,omitempty"`
	// Pod volumes to mount into the container's filesystem. Cannot be updated.
	VolumeMounts []corev1.VolumeMount `json:"volumeMounts,omitempty"`
	// volumeClaimTemplates is a list of claims that pods are allowed to reference.
	// The StatefulSet controller is responsible for mapping network identities to
	// claims in a way that maintains the identity of a pod. Every claim in
	// this list must have at least one matching (by name) volumeMount in one
	// container in the template.
	// Applicable when the mode is "collector", and will be ignored when the mode is "agent"
	VolumeClaimTemplates []corev1.PersistentVolumeClaim `json:"volumeClaimTemplates,omitempty"`
	// Service represents configurations on the fluentd service.
	Service FluentDService `json:"service,omitempty"`
	// PodSecurityContext represents the security context for the fluentd pods.
	SecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty"`
	// SchedulerName represents the desired scheduler for fluentd pods.
	SchedulerName string `json:"schedulerName,omitempty"`
	// Mode to determine whether to run Fluentd as collector or agent.
	// +kubebuilder:validation:Enum:=collector;agent
	// +kubebuilder:default:=collector
	Mode string `json:"mode,omitempty"`
	// ContainerSecurityContext represents the security context for the fluentd container.
	ContainerSecurityContext *corev1.SecurityContext `json:"containerSecurityContext,omitempty"`
	// Storage for position db. You will use it if tail input is enabled.
	// Applicable when the mode is "agent", and will be ignored when the mode is "collector"
	PositionDB corev1.VolumeSource `json:"positionDB,omitempty"`
	// LivenessProbe represents the liveness probe for the fluentd container.
	LivenessProbe *corev1.Probe `json:"livenessProbe,omitempty"`
	// ReadinessProbe represents the readiness probe for the fluentd container.
	ReadinessProbe *corev1.Probe `json:"readinessProbe,omitempty"`
	// HostAliases is an optional list of IPs and hostnames that will be injected into the pod's hosts file if specified.
	HostAliases []corev1.HostAlias `json:"hostAliases,omitempty"`
}

FluentdSpec defines the desired state of Fluentd

func (*FluentdSpec) DeepCopy 

func (in *FluentdSpec) DeepCopy() *FluentdSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FluentdSpec.

func (*FluentdSpec) DeepCopyInto 

func (in *FluentdSpec) DeepCopyInto(out *FluentdSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FluentdStatus 

type FluentdStatus struct {
	// Messages defines the plugin errors which is selected by this fluentdconfig
	Messages string `json:"messages,omitempty"`
	// The state of this fluentd
	State StatusState `json:"state,omitempty"`
}

FluentdStatus defines the observed state of Fluentd

func (*FluentdStatus) DeepCopy 

func (in *FluentdStatus) DeepCopy() *FluentdStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FluentdStatus.

func (*FluentdStatus) DeepCopyInto 

func (in *FluentdStatus) DeepCopyInto(out *FluentdStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Input 

type Input struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   InputSpec   `json:"spec,omitempty"`
	Status InputStatus `json:"status,omitempty"`
}

Input is the Schema for the inputs API

func (*Input) DeepCopy 

func (in *Input) DeepCopy() *Input

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Input.

func (*Input) DeepCopyInto 

func (in *Input) DeepCopyInto(out *Input)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Input) DeepCopyObject 

func (in *Input) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type InputList 

type InputList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Input `json:"items"`
}

InputList contains a list of Input

func (*InputList) DeepCopy 

func (in *InputList) DeepCopy() *InputList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InputList.

func (*InputList) DeepCopyInto 

func (in *InputList) DeepCopyInto(out *InputList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*InputList) DeepCopyObject 

func (in *InputList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type InputSpec 

type InputSpec struct {
	Inputs []input.Input `json:"inputs,omitempty"`
}

InputSpec defines the desired state of Input

func (*InputSpec) DeepCopy 

func (in *InputSpec) DeepCopy() *InputSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InputSpec.

func (*InputSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type InputStatus 

type InputStatus struct {
}

InputStatus defines the observed state of Input

func (*InputStatus) DeepCopy 

func (in *InputStatus) DeepCopy() *InputStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InputStatus.

func (*InputStatus) DeepCopyInto 

func (in *InputStatus) DeepCopyInto(out *InputStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Output 

type Output struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   OutputSpec   `json:"spec,omitempty"`
	Status OutputStatus `json:"status,omitempty"`
}

Output is the Schema for the outputs API

func (*Output) DeepCopy 

func (in *Output) DeepCopy() *Output

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Output.

func (*Output) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Output) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type OutputList 

type OutputList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Output `json:"items"`
}

OutputList contains a list of Output

func (*OutputList) DeepCopy 

func (in *OutputList) DeepCopy() *OutputList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputList.

func (*OutputList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*OutputList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type OutputSpec 

type OutputSpec struct {
	Outputs []output.Output `json:"outputs,omitempty"`
}

OutputSpec defines the desired state of Output

func (*OutputSpec) DeepCopy 

func (in *OutputSpec) DeepCopy() *OutputSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputSpec.

func (*OutputSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type OutputStatus 

type OutputStatus struct {
}

OutputStatus defines the observed state of Output

func (*OutputStatus) DeepCopy 

func (in *OutputStatus) DeepCopy() *OutputStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OutputStatus.

func (*OutputStatus) DeepCopyInto 

func (in *OutputStatus) DeepCopyInto(out *OutputStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PluginResources 

type PluginResources struct {
	InputPlugins         []params.PluginStore
	MainRouterPlugins    params.PluginStore
	LabelPluginResources []params.PluginStore
}

+kubebuilder:object:generate=false Global pluginstores for the fluentd.

func NewGlobalPluginResources 

func NewGlobalPluginResources(globalId string) *PluginResources

NewGlobalPluginResources represents a combined global fluentd resources

func (*PluginResources) BuildCfgRouter 

func (pgr *PluginResources) BuildCfgRouter(cfg Renderer) (*fluentdRouter.Route, error)

func (*PluginResources) CombineGlobalInputsPlugins 

func (pgr *PluginResources) CombineGlobalInputsPlugins(sl plugins.SecretLoader, inputs []input.Input) []string

func (*PluginResources) IdentifyCopyAndPatchOutput 

func (pgr *PluginResources) IdentifyCopyAndPatchOutput(cfgResources *CfgResources) error

IdentifyCopyAndPatchOutput patches up the controller with the Manager

func (*PluginResources) PatchAndFilterClusterLevelResources 

func (pgr *PluginResources) PatchAndFilterClusterLevelResources(
	sl plugins.SecretLoader,
	cfgId string,
	clusterInputs []ClusterInput,
	clusterfilters []ClusterFilter,
	clusteroutputs []ClusterOutput,
) (*CfgResources, []string)

PatchAndFilterClusterLevelResources will combine and patch all the cluster CRs that the fluentdconfig selected, convert the related filter/output pluginstores to the global pluginresources.

func (*PluginResources) PatchAndFilterNamespacedLevelResources 

func (pgr *PluginResources) PatchAndFilterNamespacedLevelResources(
	sl plugins.SecretLoader,
	cfgId string,
	inputs []Input,
	filters []Filter,
	outputs []Output,
) (*CfgResources, []string)

PatchAndFilterNamespacedLevelResources will combine and patch all the cluster CRs that the fluentdconfig selected, convert the related filter/output pluginstores to the global pluginresources.

func (*PluginResources) RenderMainConfig 

func (pgr *PluginResources) RenderMainConfig(enableMultiWorkers bool) (string, error)

func (*PluginResources) WithCfgResources 

func (pgr *PluginResources) WithCfgResources(cfgRouteLabel string, r *CfgResources) error

convert the cfg plugins to a label plugin, appends to the global label plugins

type Renderer 

type Renderer interface {
	GetNamespace() string
	GetName() string
	GetCfgId() string
	GetWatchedLabels() map[string]string
	GetWatchedNamespaces() []string
	GetWatchedContainers() []string
	GetWatchedHosts() []string
}

+kubebuilder:object:generate=false

type StatusState 

type StatusState string
const (
	InvalidState StatusState = "invalid"
	ValidState   StatusState = "valid"
)
const (
	ActiveState   StatusState = "active"
	InactiveState StatusState = "inactive"
)

Source Files

View all Source files

Directories

Path Synopsis
common
custom
filter
input
output
params

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.