v1alpha1

package

Go to main page

Versions in this module

v2

v2.9.0

Jun 13, 2024

v2.8.0

Apr 22, 2024

Changes in this version

+ type ByTags []params.PluginStore

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

v2.7.0

Dec 18, 2023

Changes in this version

type PluginResources

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

v2.6.0

Nov 22, 2023

Changes in this version

type CfgResources

+ InputPlugins []params.PluginStore

+ InputsHashcodes map[string]bool

type ClusterFluentdConfigSpec

+ ClusterInputSelector *metav1.LabelSelector

+ type ClusterInput struct

+ Spec ClusterInputSpec

+ Status ClusterInputStatus

+ 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

+ type ClusterInputSpec struct

+ Inputs []input.Input

+ func (in *ClusterInputSpec) DeepCopy() *ClusterInputSpec

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

+ type ClusterInputStatus struct

+ func (in *ClusterInputStatus) DeepCopy() *ClusterInputStatus

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

type FluentdConfigSpec

+ ClusterInputSelector *metav1.LabelSelector

+ InputSelector *metav1.LabelSelector

type FluentdSpec

+ DefaultInputSelector *metav1.LabelSelector

+ LivenessProbe *corev1.Probe

+ ReadinessProbe *corev1.Probe

+ type Input struct

+ Spec InputSpec

+ Status InputStatus

+ func (in *Input) DeepCopy() *Input

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

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

+ type InputList struct

+ Items []Input

+ func (in *InputList) DeepCopy() *InputList

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

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

+ type InputSpec struct

+ Inputs []input.Input

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

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

+ type InputStatus struct

+ func (in *InputStatus) DeepCopy() *InputStatus

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

v2.5.0

Sep 13, 2023

Changes in this version

type FluentdSpec

+ ContainerSecurityContext *corev1.SecurityContext

+ Mode string

+ PositionDB corev1.VolumeSource

v2.4.0

Jul 19, 2023

Changes in this version

type FluentdSpec

+ DefaultFilterSelector *metav1.LabelSelector

+ DefaultOutputSelector *metav1.LabelSelector

v2.3.0

Jun 5, 2023

Changes in this version

type FluentdSpec

+ Annotations map[string]string

+ EnvVars []corev1.EnvVar

+ LogLevel string

+ SchedulerName string

+ SecurityContext *corev1.PodSecurityContext

v2.2.0

Apr 7, 2023

Changes in this version

+ const FluentdFinalizerName

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var SchemeBuilder = &scheme.Builder

+ var SchemeGroupVersion = schema.GroupVersion

+ type BufferVolume struct

+ DisableBufferVolume bool

+ EmptyDir *corev1.EmptyDirVolumeSource

+ HostPath *corev1.HostPathVolumeSource

+ PersistentVolumeClaim *corev1.PersistentVolumeClaim

+ func (in *BufferVolume) DeepCopy() *BufferVolume

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

+ type ByHashcode []params.PluginStore

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

+ type ByRouteLabels []params.PluginStore

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

+ type ByRouteLabelsPointers []*params.PluginStore

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

+ type CfgResources struct

+ FilterPlugins []params.PluginStore

+ FiltersHashcodes map[string]bool

+ OutputPlugins []params.PluginStore

+ OutputsHashcodes map[string]bool

+ func NewCfgResources() *CfgResources

+ type ClusterFilter struct

+ Spec ClusterFilterSpec

+ Status ClusterFilterStatus

+ 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

+ type ClusterFilterSpec struct

+ Filters []filter.Filter

+ func (in *ClusterFilterSpec) DeepCopy() *ClusterFilterSpec

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

+ type ClusterFilterStatus struct

+ func (in *ClusterFilterStatus) DeepCopy() *ClusterFilterStatus

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

+ type ClusterFluentdConfig struct

+ Spec ClusterFluentdConfigSpec

+ Status ClusterFluentdConfigStatus

+ func (cfg *ClusterFluentdConfig) GetCfgId() string

+ func (cfg *ClusterFluentdConfig) GetName() string

+ func (cfg *ClusterFluentdConfig) GetNamespace() string

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

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

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

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

+ func (in *ClusterFluentdConfig) DeepCopy() *ClusterFluentdConfig

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

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

+ type ClusterFluentdConfigList struct

+ Items []ClusterFluentdConfig

+ func (in *ClusterFluentdConfigList) DeepCopy() *ClusterFluentdConfigList

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

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

+ type ClusterFluentdConfigSpec struct

+ ClusterFilterSelector *metav1.LabelSelector

+ ClusterOutputSelector *metav1.LabelSelector

+ EmitMode string

+ StickyTags string

+ WatchedContainers []string

+ WatchedHosts []string

+ WatchedLabels map[string]string

+ WatchedNamespaces []string

+ func (in *ClusterFluentdConfigSpec) DeepCopy() *ClusterFluentdConfigSpec

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

+ type ClusterFluentdConfigStatus struct

+ Messages string

+ State StatusState

+ func (in *ClusterFluentdConfigStatus) DeepCopy() *ClusterFluentdConfigStatus

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

+ type ClusterOutput struct

+ Spec ClusterOutputSpec

+ Status ClusterOutputStatus

+ 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

+ type ClusterOutputSpec struct

+ Outputs []output.Output

+ func (in *ClusterOutputSpec) DeepCopy() *ClusterOutputSpec

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

+ type ClusterOutputStatus struct

+ func (in *ClusterOutputStatus) DeepCopy() *ClusterOutputStatus

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

+ type Filter struct

+ Spec FilterSpec

+ Status FilterStatus

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

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

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

+ type FilterList struct

+ Items []Filter

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

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

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

+ type FilterSpec struct

+ Filters []filter.Filter

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

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

+ type FilterStatus struct

+ func (in *FilterStatus) DeepCopy() *FilterStatus

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

+ type FluentDService struct

+ Annotations map[string]string

+ Labels map[string]string

+ Name string

+ func (in *FluentDService) DeepCopy() *FluentDService

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

+ type Fluentd struct

+ Spec FluentdSpec

+ Status FluentdStatus

+ func (fd *Fluentd) AddFinalizer(finalizerName string)

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

+ func (fd *Fluentd) IsBeingDeleted() bool

+ func (fd *Fluentd) RemoveFinalizer(finalizerName string)

+ func (in *Fluentd) DeepCopy() *Fluentd

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

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

+ type FluentdConfig struct

+ Spec FluentdConfigSpec

+ Status FluentdConfigStatus

+ func (cfg *FluentdConfig) GetCfgId() string

+ func (cfg *FluentdConfig) GetName() string

+ func (cfg *FluentdConfig) GetNamespace() string

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

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

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

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

+ func (in *FluentdConfig) DeepCopy() *FluentdConfig

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

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

+ type FluentdConfigList struct

+ Items []FluentdConfig

+ func (in *FluentdConfigList) DeepCopy() *FluentdConfigList

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

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

+ type FluentdConfigSpec struct

+ ClusterFilterSelector *metav1.LabelSelector

+ ClusterOutputSelector *metav1.LabelSelector

+ EmitMode string

+ FilterSelector *metav1.LabelSelector

+ OutputSelector *metav1.LabelSelector

+ StickyTags string

+ WatchedContainers []string

+ WatchedHosts []string

+ WatchedLabels map[string]string

+ func (in *FluentdConfigSpec) DeepCopy() *FluentdConfigSpec

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

+ type FluentdConfigStatus struct

+ Messages string

+ State StatusState

+ func (in *FluentdConfigStatus) DeepCopy() *FluentdConfigStatus

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

+ type FluentdList struct

+ Items []Fluentd

+ func (in *FluentdList) DeepCopy() *FluentdList

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

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

+ type FluentdSpec struct

+ Affinity *corev1.Affinity

+ Args []string

+ BufferVolume *BufferVolume

+ DisableService bool

+ FluentdCfgSelector metav1.LabelSelector

+ GlobalInputs []input.Input

+ Image string

+ ImagePullPolicy corev1.PullPolicy

+ ImagePullSecrets []corev1.LocalObjectReference

+ NodeSelector map[string]string

+ PriorityClassName string

+ RBACRules []rbacv1.PolicyRule

+ Replicas *int32

+ Resources corev1.ResourceRequirements

+ RuntimeClassName string

+ Service FluentDService

+ ServiceAccountAnnotations map[string]string

+ Tolerations []corev1.Toleration

+ VolumeClaimTemplates []corev1.PersistentVolumeClaim

+ VolumeMounts []corev1.VolumeMount

+ Volumes []corev1.Volume

+ Workers *int32

+ func (in *FluentdSpec) DeepCopy() *FluentdSpec

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

+ type FluentdStatus struct

+ Messages string

+ State StatusState

+ func (in *FluentdStatus) DeepCopy() *FluentdStatus

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

+ type Output struct

+ Spec OutputSpec

+ Status OutputStatus

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

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

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

+ type OutputList struct

+ Items []Output

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

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

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

+ type OutputSpec struct

+ Outputs []output.Output

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

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

+ type OutputStatus struct

+ func (in *OutputStatus) DeepCopy() *OutputStatus

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

+ type PluginResources struct

+ InputPlugins []params.PluginStore

+ LabelPluginResources []params.PluginStore

+ MainRouterPlugins params.PluginStore

+ func NewGlobalPluginResources(globalId string) *PluginResources

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

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

+ func (pgr *PluginResources) PatchAndFilterClusterLevelResources(sl plugins.SecretLoader, cfgId string, clusterfilters []ClusterFilter, ...) (*CfgResources, []string)

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

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

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

+ type Renderer interface

+ GetCfgId func() string

+ GetName func() string

+ GetNamespace func() string

+ GetWatchedContainers func() []string

+ GetWatchedHosts func() []string

+ GetWatchedLabels func() map[string]string

+ GetWatchedNamespaces func() []string

+ type StatusState string

+ const ActiveState

+ const InactiveState

+ const InvalidState

+ const ValidState

Other modules containing this package

github.com/fluent/fluent-operator

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL