v1alpha1

package
v2.2.0 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2023 License: Apache-2.0 Imports: 17 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 CfgResources 

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

	// the hash codes used to depulicate removel
	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"`
}

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 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 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 filter plugins
	ClusterFilterSelector *metav1.LabelSelector `json:"clusterFilterSelector,omitempty"`
	// Select cluster output plugins
	ClusterOutputSelector *metav1.LabelSelector `json:"clusterOutputSelector,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"`
	// By default will build the related service according to the globalinputs definition.
	DisableService bool `json:"disableService,omitempty"`
	// Numbers of the Fluentd instance
	Replicas *int32 `json:"replicas,omitempty"`
	// Numbers of the workers in Fluentd instance
	Workers *int32 `json:"workers,omitempty"`
	// Fluentd image.
	Image string `json:"image,omitempty"`
	// Fluentd Watcher command line arguments.
	Args []string `json:"args,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"`
	// 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"`
}

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 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) PatchAndFilterClusterLevelResources 

func (pgr *PluginResources) PatchAndFilterClusterLevelResources(sl plugins.SecretLoader, cfgId string,
	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,
	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.