operator

Documentation

Index

• Constants
• func MakeDaemonSet(fb fluentbitv1alpha2.FluentBit, logPath string) appsv1.DaemonSet
• func MakeFluentbitService(fb fluentbitv1alpha2.FluentBit) corev1.Service
• func MakeFluentdPVC(fd fluentdv1alpha1.Fluentd) corev1.PersistentVolumeClaim
• func MakeFluentdService(fd fluentdv1alpha1.Fluentd) corev1.Service
• func MakeRBACObjects(name, namespace, component string, additionalRules []rbacv1.PolicyRule) (*rbacv1.ClusterRole, *corev1.ServiceAccount, *rbacv1.ClusterRoleBinding)
• func MakeScopedRBACObjects(fbName, fbNamespace string) (*rbacv1.Role, *corev1.ServiceAccount, *rbacv1.RoleBinding)
• func MakeStatefulset(fd fluentdv1alpha1.Fluentd) appsv1.StatefulSet

Constants

const (
	FluentBitMetricsPortName = "metrics"
	FluentBitMetricsPort     = 2020
	FluentBitTCPProtocolName = "TCP"
)

const (
	FluentdForwardPortName = "forward"
	FluentdHttpPortName    = "http"
)

const (
	SecretVolName    = "config"
	FluentdMountPath = "/fluentd/etc"
	BufferMountPath  = "/buffers"

	MetricsName = "metrics"

	MetricsPort int32 = 2021

	DefaultForwardPort int32 = 24424
	DefaultHttpPort    int32 = 9880

	DefaultForwardName = "forward"
	DefaultHttpName    = "http"

	InputForwardType = "forward"
	InputHttpType    = "http"
)

Functions

func MakeDaemonSet

func MakeDaemonSet(fb fluentbitv1alpha2.FluentBit, logPath string) appsv1.DaemonSet

func MakeFluentbitService

func MakeFluentbitService(fb fluentbitv1alpha2.FluentBit) corev1.Service

func MakeFluentdPVC

func MakeFluentdPVC(fd fluentdv1alpha1.Fluentd) corev1.PersistentVolumeClaim

func MakeFluentdService

func MakeFluentdService(fd fluentdv1alpha1.Fluentd) corev1.Service

func MakeRBACObjects

func MakeRBACObjects(name, namespace, component string, additionalRules []rbacv1.PolicyRule) (*rbacv1.ClusterRole, *corev1.ServiceAccount, *rbacv1.ClusterRoleBinding)

func MakeScopedRBACObjects

func MakeScopedRBACObjects(fbName, fbNamespace string) (*rbacv1.Role, *corev1.ServiceAccount, *rbacv1.RoleBinding)

func MakeStatefulset

func MakeStatefulset(fd fluentdv1alpha1.Fluentd) appsv1.StatefulSet