operator

Documentation

Index

• Constants
• Variables
• func FlunetbitBufferMountPath(co fluentbitv1alpha2.Collector) string
• func MakeCollecotrService(co fluentbitv1alpha2.Collector) corev1.Service
• func MakeDaemonSet(fb fluentbitv1alpha2.FluentBit, logPath string) appsv1.DaemonSet
• func MakeFluentbitPVC(co fluentbitv1alpha2.Collector) corev1.PersistentVolumeClaim
• 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
• func MakefbStatefuset(co fluentbitv1alpha2.Collector) appsv1.StatefulSet

Constants

const (
	CollecotrMetricsPortName = "metrics"
	CollecotrMetricsPort     = 2020
	CollecotrTCPProtocolName = "TCP"
)

const (
	FluentBitMetricsPortName = "metrics"
	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"
)

Variables

var (
	// DefaultBufferPath defines the buffer path for single process
	DefaultBufferPath = "/buffers/fluentbit/log"
)

Functions

func FlunetbitBufferMountPath

func FlunetbitBufferMountPath(co fluentbitv1alpha2.Collector) string

func MakeCollecotrService

func MakeCollecotrService(co fluentbitv1alpha2.Collector) corev1.Service

func MakeDaemonSet

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

func MakeFluentbitPVC

func MakeFluentbitPVC(co fluentbitv1alpha2.Collector) corev1.PersistentVolumeClaim

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

func MakefbStatefuset

func MakefbStatefuset(co fluentbitv1alpha2.Collector) appsv1.StatefulSet