nodeagent

Documentation

Index

• Constants
• Variables
• func NodeAgentFluentbitDefaults(userDefined v1beta1.NodeAgentConfig) (*v1beta1.NodeAgentConfig, error)
• func RegisterWatches(builder *builder.Builder) *builder.Builder
• type Reconciler
  • func New(client client.Client, logger logr.Logger, logging *v1beta1.Logging, ...) *Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context) (*reconcile.Result, error)

Constants

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

const BaseConfigName = "fluent-bit.conf"

const UpstreamConfigName = "upstream.conf"

Variables

var NodeAgentFluentbitLinuxDefaults = &v1beta1.NodeAgentConfig{
	FluentbitSpec: &v1beta1.NodeAgentFluentbit{},
}

var NodeAgentFluentbitWindowsDefaults = &v1beta1.NodeAgentConfig{
	FluentbitSpec: &v1beta1.NodeAgentFluentbit{
		FilterKubernetes: v1beta1.FilterKubernetes{
			KubeURL:       "https://kubernetes.default.svc:443",
			KubeCAFile:    "c:\\var\\run\\secrets\\kubernetes.io\\serviceaccount\\ca.crt",
			KubeTokenFile: "c:\\var\\run\\secrets\\kubernetes.io\\serviceaccount\\token",
			KubeTagPrefix: "kubernetes.C.var.log.containers.",
		},
		InputTail: v1beta1.InputTail{
			Path: "C:\\var\\log\\containers\\*.log",
		},
		ContainersPath: "C:\\ProgramData\\docker",
		VarLogsPath:    "C:\\var\\log",
		DaemonSetOverrides: &typeoverride.DaemonSet{
			Spec: typeoverride.DaemonSetSpec{
				Template: typeoverride.PodTemplateSpec{
					Spec: typeoverride.PodSpec{
						Containers: []corev1.Container{
							{
								Name:    containerName,
								Image:   "rancher/fluent-bit:1.6.10-rc7",
								Command: []string{"fluent-bit", "-c", "fluent-bit\\conf_operator\\fluent-bit.conf"},
								Resources: corev1.ResourceRequirements{
									Limits: corev1.ResourceList{
										corev1.ResourceMemory: resource.MustParse("200M"),
										corev1.ResourceCPU:    resource.MustParse("200m"),
									},
									Requests: corev1.ResourceList{
										corev1.ResourceMemory: resource.MustParse("100M"),
										corev1.ResourceCPU:    resource.MustParse("100m"),
									},
								},
							}},
						NodeSelector: map[string]string{
							"kubernetes.io/os": "windows",
						},
					}},
			}},
	},
}

Functions

func NodeAgentFluentbitDefaults

func NodeAgentFluentbitDefaults(userDefined v1beta1.NodeAgentConfig) (*v1beta1.NodeAgentConfig, error)

func RegisterWatches

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

Types

type Reconciler

type Reconciler struct {
	Logging *v1beta1.Logging

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

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

Reconciler holds info what resource to reconcile

func New

func New(client client.Client, logger logr.Logger, logging *v1beta1.Logging, fluentdSpec *v1beta1.FluentdSpec, agents map[string]v1beta1.NodeAgentConfig, opts reconciler.ReconcilerOpts, fluentdDataProvider loggingdataprovider.LoggingDataProvider) *Reconciler

New creates a new NodeAgent reconciler

func (*Reconciler) Reconcile

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

Reconcile reconciles the InlineNodeAgent resource