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 ¶
View Source
const ( CollectorMetricsPortName = "metrics" CollectorMetricsPort = 2020 CollectorTCPProtocolName = "TCP" )
View Source
const ( FluentBitMetricsPortName = "metrics" FluentBitTCPProtocolName = "TCP" )
View Source
const ( FluentdForwardPortName = "forward" FluentdHttpPortName = "http" )
View Source
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 ¶
View Source
var (
// DefaultBufferPath defines the buffer path for single process
DefaultBufferPath = "/buffers/fluentbit/log"
)
Functions ¶
func FluentbitBufferMountPath ¶ added in v2.4.0
func FluentbitBufferMountPath(co fluentbitv1alpha2.Collector) string
func MakeCollectorService ¶ added in v2.4.0
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 ¶ added in v2.5.0
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 ¶ added in v2.4.0
func MakeRBACObjects ¶
func MakeRBACObjects(name, namespace, component string, additionalRules []rbacv1.PolicyRule, saAnnotations map[string]string) (*rbacv1.ClusterRole, *corev1.ServiceAccount, *rbacv1.ClusterRoleBinding)
func MakeScopedRBACNames ¶ added in v2.4.0
func MakeScopedRBACObjects ¶
func MakeScopedRBACObjects(name, namespace string, saAnnotations map[string]string) (*rbacv1.Role, *corev1.ServiceAccount, *rbacv1.RoleBinding)
func MakeStatefulSet ¶ added in v2.5.0
func MakeStatefulSet(fd fluentdv1alpha1.Fluentd) *appsv1.StatefulSet
func MakefbStatefulset ¶ added in v2.4.0
func MakefbStatefulset(co fluentbitv1alpha2.Collector) *appsv1.StatefulSet
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.