nodeagent

Documentation

Index

• Constants
• Variables
• func NodeAgentFluentbitDefaults(userDefined **v1beta1.NodeAgent) (*v1beta1.NodeAgent, 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() (*reconcile.Result, error)

Constants

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

const BaseConfigName = "fluent-bit.conf"

const UpstreamConfigName = "upstream.conf"

Variables

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

var NodeAgentFluentbitWindowsDefaults = &v1beta1.NodeAgent{
	FluentbitSpec: &v1beta1.NodeAgentFluentbit{
		FilterKubernetes: v1beta1.FilterKubernetes{
			KubeURL:       "https://kubernetes.default.svc.cluster.local: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: []v1.Container{
							{
								Name:    containerName,
								Image:   "rancher/fluent-bit:1.6.10-rc7",
								Command: []string{"fluent-bit", "-c", "fluent-bit\\conf_operator\\fluent-bit.conf"},
								Resources: v1.ResourceRequirements{
									Limits: v1.ResourceList{
										v1.ResourceMemory: resource.MustParse("200M"),
										v1.ResourceCPU:    resource.MustParse("200m"),
									},
									Requests: v1.ResourceList{
										v1.ResourceMemory: resource.MustParse("100M"),
										v1.ResourceCPU:    resource.MustParse("100m"),
									},
								},
							}},
						NodeSelector: map[string]string{
							"kubernetes.io/os": "windows",
						},
						Tolerations: []v1.Toleration{{
							Key:      "node.kubernetes.io/os",
							Operator: "Equal",
							Value:    "windows",
							Effect:   "NoSchedule",
						},
						},
					}},
			}},
	},
}

Functions

func NodeAgentFluentbitDefaults

func NodeAgentFluentbitDefaults(userDefined **v1beta1.NodeAgent) (*v1beta1.NodeAgent, 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, opts reconciler.ReconcilerOpts) *Reconciler

NewReconciler creates a new NodeAgent reconciler

func (*Reconciler) Reconcile

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

Reconcile reconciles the NodeAgent resource