fluentd

package

v0.0.0-...-3df867b Latest Latest Go to latest Published: Apr 29, 2024 License: Apache-2.0 Imports: 36 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kube-logging/logging-operator

Documentation ¶

Index ¶

Constants
func GetFluentd(ctx context.Context, Client client.Client, log logr.Logger, ...) *v1beta1.FluentdConfig
func RegisterWatches(builder *builder.Builder) *builder.Builder
type ConfigCheckResult
type DataProvider
- func NewDataProvider(client client.Client, logging *v1beta1.Logging, ...) *DataProvider
- func (p *DataProvider) GetReplicaCount(ctx context.Context) (*int32, error)
type Desire
type Reconciler
- func New(client client.Client, log logr.Logger, logging *v1beta1.Logging, ...) *Reconciler

Constants ¶

View Source

const (
	ComponentFluentd     = "fluentd"
	ComponentConfigCheck = "fluentd-configcheck"
	ComponentDrainer     = "fluentd-drainer"
	ComponentPlaceholder = "fluentd-placeholder"
)

View Source

const (
	SecretConfigName        = "fluentd"
	AppSecretConfigName     = "fluentd-app"
	ConfigCheckKey          = "generated.conf"
	ConfigKey               = "fluent.conf"
	AppConfigKey            = "fluentd.conf"
	StatefulSetName         = "fluentd"
	ServiceName             = "fluentd"
	ServicePort             = 24240
	OutputSecretName        = "fluentd-output"
	OutputSecretPath        = "/fluentd/secret"
	PodDisruptionBudgetName = "fluentd"
)

Variables ¶

This section is empty.

Functions ¶

func GetFluentd ¶

func GetFluentd(ctx context.Context, Client client.Client, log logr.Logger, controlNamespace string) *v1beta1.FluentdConfig

func RegisterWatches ¶

func RegisterWatches(builder *builder.Builder) *builder.Builder

Types ¶

type ConfigCheckResult ¶

type ConfigCheckResult struct {
	Valid   bool
	Ready   bool
	Message string
}

type DataProvider ¶

type DataProvider struct {
	// contains filtered or unexported fields
}

func NewDataProvider ¶

func NewDataProvider(client client.Client, logging *v1beta1.Logging, fluentdSpec *v1beta1.FluentdSpec, fluentdConfig *v1beta1.FluentdConfig) *DataProvider

func (*DataProvider) GetReplicaCount ¶

func (p *DataProvider) GetReplicaCount(ctx context.Context) (*int32, error)

type Desire ¶

type Desire struct {
	DesiredObject runtime.Object
	DesiredState  reconciler.DesiredState
	// BeforeUpdateHook has the ability to change the desired object
	// or even to change the desired state in case the object should be recreated
	BeforeUpdateHook func(runtime.Object) (reconciler.DesiredState, error)
}

type Reconciler ¶

type Reconciler struct {
	Logging *v1beta1.Logging

	*reconciler.GenericResourceReconciler
	// contains filtered or unexported fields
}

Reconciler holds info what resource to reconcile

func New ¶

func New(client client.Client, log logr.Logger,
	logging *v1beta1.Logging, fluentdSpec *v1beta1.FluentdSpec, fluentdConfig *v1beta1.FluentdConfig, config *string, secrets *secret.MountSecrets, opts reconciler.ReconcilerOpts) *Reconciler

func (*Reconciler) CheckForObjectExistence ¶

func (r *Reconciler) CheckForObjectExistence(ctx context.Context, object client.Object) (*ConfigCheckResult, error)

func (*Reconciler) FluentdObjectMeta ¶

func (r *Reconciler) FluentdObjectMeta(name, component string) metav1.ObjectMeta

FluentdObjectMeta creates an objectMeta for resource fluentd

func (*Reconciler) FluentdObjectMetaClusterScope ¶

func (r *Reconciler) FluentdObjectMetaClusterScope(name, component string) metav1.ObjectMeta

FluentdObjectMetaClusterScope creates an objectMeta for resource fluentd

func (*Reconciler) Reconcile ¶

func (r *Reconciler) Reconcile(ctx context.Context) (*reconcile.Result, error)

Reconcile reconciles the fluentd resource

Source Files ¶

View all Source files

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