fluentd

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
  • func (r *Reconciler) CheckForObjectExistence(ctx context.Context, object client.Object) (*ConfigCheckResult, error)
  • func (r *Reconciler) FluentdObjectMeta(name, component string) metav1.ObjectMeta
  • func (r *Reconciler) FluentdObjectMetaClusterScope(name, component string) metav1.ObjectMeta
  • func (r *Reconciler) Reconcile(ctx context.Context) (*reconcile.Result, error)

Constants

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

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

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