Versions in this module Expand all Collapse all v2 v2.2.0 Mar 9, 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 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 + Tolerations []corev1.Toleration + 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