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 CRIParserConfigName = "cri-log-parser.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
	MaxWorkerConnections      int
}

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)