operator

Documentation

Index

• Constants
• Variables
• func FluentbitBufferMountPath(co fluentbitv1alpha2.Collector) string
• func MakeCollectorService(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 MakeFluentdDaemonSet(fd fluentdv1alpha1.Fluentd) *appsv1.DaemonSet
• func MakeFluentdPVC(fd fluentdv1alpha1.Fluentd) *corev1.PersistentVolumeClaim
• func MakeFluentdService(fd fluentdv1alpha1.Fluentd) *corev1.Service
• func MakeRBACNames(name, component string) (string, string, string)
• func MakeRBACObjects(name, namespace, component string, additionalRules []rbacv1.PolicyRule, ...) (*rbacv1.ClusterRole, *corev1.ServiceAccount, *rbacv1.ClusterRoleBinding)
• func MakeScopedRBACNames(name string) (string, string, string)
• func MakeScopedRBACObjects(name, namespace string, saAnnotations map[string]string) (*rbacv1.Role, *corev1.ServiceAccount, *rbacv1.RoleBinding)
• func MakeStatefulSet(fd fluentdv1alpha1.Fluentd) *appsv1.StatefulSet
• func MakefbStatefulset(co fluentbitv1alpha2.Collector) *appsv1.StatefulSet

Constants

const (
	CollectorMetricsPortName = "metrics"
	CollectorMetricsPort     = 2020
	CollectorTCPProtocolName = "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
	// 101 is the fsGroup that fluentd runs as in the kubesphere image
	DefaultFsGroup int64 = 101

	DefaultForwardName = "forward"
	DefaultHttpName    = "http"

	InputForwardType = "forward"
	InputHttpType    = "http"
)

Variables

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

Functions

func FluentbitBufferMountPath

func FluentbitBufferMountPath(co fluentbitv1alpha2.Collector) string

func MakeCollectorService

func MakeCollectorService(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 MakeFluentdDaemonSet

func MakeFluentdDaemonSet(fd fluentdv1alpha1.Fluentd) *appsv1.DaemonSet

func MakeFluentdPVC

func MakeFluentdPVC(fd fluentdv1alpha1.Fluentd) *corev1.PersistentVolumeClaim

func MakeFluentdService

func MakeFluentdService(fd fluentdv1alpha1.Fluentd) *corev1.Service

func MakeRBACNames

func MakeRBACNames(name, component string) (string, string, string)

func MakeRBACObjects

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

func MakeScopedRBACNames

func MakeScopedRBACNames(name string) (string, string, string)

func MakeScopedRBACObjects

func MakeScopedRBACObjects(name, namespace string, saAnnotations map[string]string) (*rbacv1.Role, *corev1.ServiceAccount, *rbacv1.RoleBinding)

func MakeStatefulSet

func MakeStatefulSet(fd fluentdv1alpha1.Fluentd) *appsv1.StatefulSet

func MakefbStatefulset

func MakefbStatefulset(co fluentbitv1alpha2.Collector) *appsv1.StatefulSet