The highest tagged major version is v3.

operator

package

v2.2.0 Latest Latest Go to latest Published: Apr 7, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/fluent/fluent-operator

Links

Open Source Insights

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, saAnnotations map[string]string) (*rbacv1.Role, *corev1.ServiceAccount, *rbacv1.RoleBinding)
func MakeStatefulset(fd fluentdv1alpha1.Fluentd) *appsv1.StatefulSet
func MakefbStatefuset(co fluentbitv1alpha2.Collector) *appsv1.StatefulSet

Constants ¶

View Source

const (
	CollecotrMetricsPortName = "metrics"
	CollecotrMetricsPort     = 2020
	CollecotrTCPProtocolName = "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

	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 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, saAnnotations map[string]string) (*rbacv1.ClusterRole, *corev1.ServiceAccount, *rbacv1.ClusterRoleBinding)

func MakeScopedRBACObjects ¶

func MakeScopedRBACObjects(fbName, fbNamespace string, saAnnotations map[string]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

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL