fluentbit

Documentation

Index

• Constants
• func RegisterWatches(builder *builder.Builder) *builder.Builder
• type DesiredObject
• type Reconciler
  • func New(client client.Client, logger logr.Logger, logging *v1beta1.Logging, ...) *Reconciler
  • func (r *Reconciler) FluentbitObjectMeta(name string) metav1.ObjectMeta
  • func (r *Reconciler) FluentbitObjectMetaClusterScope(name string) metav1.ObjectMeta
  • func (r *Reconciler) Reconcile() (*reconcile.Result, error)

Constants

const (
	TailPositionVolume  = "positiondb"
	BufferStorageVolume = "buffers"
)

const BaseConfigName = "fluent-bit.conf"

const UpstreamConfigName = "upstream.conf"

Functions

func RegisterWatches

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

Types

type DesiredObject

type DesiredObject struct {
	Object runtime.Object
	State  reconciler.DesiredState
}

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, logger logr.Logger, logging *v1beta1.Logging, opts reconciler.ReconcilerOpts) *Reconciler

NewReconciler creates a new Fluentbit reconciler

func (*Reconciler) FluentbitObjectMeta

func (r *Reconciler) FluentbitObjectMeta(name string) metav1.ObjectMeta

FluentbitObjectMeta creates an objectMeta for resource fluentbit

func (*Reconciler) FluentbitObjectMetaClusterScope

func (r *Reconciler) FluentbitObjectMetaClusterScope(name string) metav1.ObjectMeta

FluentbitObjectMetaClusterScope creates an cluster scoped objectMeta for resource fluentbit

func (*Reconciler) Reconcile

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

Reconcile reconciles the fluentBit resource