fluentbit

Documentation

Index

• Constants
• func RegisterWatches(builder *builder.Builder) *builder.Builder
• type DesiredObject
• type FluentbitNameProvider
  • func NewLegacyFluentbitNameProvider(logging *v1beta1.Logging) *FluentbitNameProvider
  • func NewStandaloneFluentbitNameProvider(agent *v1beta1.FluentbitAgent) *FluentbitNameProvider
  • func (l *FluentbitNameProvider) ComponentName(name string) string
  • func (l *FluentbitNameProvider) Name() string
  • func (l *FluentbitNameProvider) OwnerRef() v1.OwnerReference
• type FluentbitNetwork
• type NameProvider
• 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(ctx context.Context) (*reconcile.Result, error)
• type Tenant
  • func FindTenants(ctx context.Context, target metav1.LabelSelector, reader client.Reader) ([]Tenant, error)

Constants

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

const BaseConfigName = "fluent-bit.conf"

const CustomParsersConfigName = "custom-parsers.conf"

const OperatorConfigPath = "/fluent-bit/etc-operator"

const StockBinPath = "/fluent-bit/bin/fluent-bit"

const StockConfigPath = "/fluent-bit/etc"

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 FluentbitNameProvider

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

func NewLegacyFluentbitNameProvider

func NewLegacyFluentbitNameProvider(logging *v1beta1.Logging) *FluentbitNameProvider

func NewStandaloneFluentbitNameProvider

func NewStandaloneFluentbitNameProvider(agent *v1beta1.FluentbitAgent) *FluentbitNameProvider

func (*FluentbitNameProvider) ComponentName

func (l *FluentbitNameProvider) ComponentName(name string) string

func (*FluentbitNameProvider) Name

func (l *FluentbitNameProvider) Name() string

func (*FluentbitNameProvider) OwnerRef

func (l *FluentbitNameProvider) OwnerRef() v1.OwnerReference

type FluentbitNetwork

type FluentbitNetwork struct {
	ConnectTimeoutSet         bool
	ConnectTimeout            uint32
	ConnectTimeoutLogErrorSet bool
	ConnectTimeoutLogError    bool
	DNSMode                   string
	DNSPreferIPV4Set          bool
	DNSPreferIPV4             bool
	DNSResolver               string
	KeepaliveSet              bool
	Keepalive                 bool
	KeepaliveIdleTimeoutSet   bool
	KeepaliveIdleTimeout      uint32
	KeepaliveMaxRecycleSet    bool
	KeepaliveMaxRecycle       uint32
	SourceAddress             string
}

type NameProvider

type NameProvider interface {
	// ComponentName provides a qualified name using (Name + "-" + name)
	ComponentName(name string) string
	// Name returns the name of the resource, that is owning fluentbit
	// It is Logging.Name for legacy but the resource's name for FluentbitAgent
	Name() string
	OwnerRef() v1.OwnerReference
}

type Reconciler

type Reconciler struct {
	Logging *v1beta1.Logging
	// 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,
	fluentbitSpec *v1beta1.FluentbitSpec,
	loggingDataProvider loggingdataprovider.LoggingDataProvider,
	nameProvider NameProvider,
	loggingResourcesRepo *model.LoggingResourceRepository) *Reconciler

NewReconciler creates a new FluentbitAgent 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(ctx context.Context) (*reconcile.Result, error)

Reconcile reconciles the fluentBit resource

type Tenant

type Tenant struct {
	Name         string
	AllNamespace bool
	Namespaces   []string
}

func FindTenants

func FindTenants(ctx context.Context, target metav1.LabelSelector, reader client.Reader) ([]Tenant, error)