plugins

Documentation

Index

• type CommonParams
  • func (c *CommonParams) AddCommonParams(kvs *params.KVs) error
  • func (in *CommonParams) DeepCopy() *CommonParams
  • func (in *CommonParams) DeepCopyInto(out *CommonParams)
• type ConfigMapLoader
  • func NewConfigMapLoader(c client.Client, ns string) ConfigMapLoader
  • func (cl ConfigMapLoader) LoadConfigMap(selector v1.ConfigMapKeySelector, namespace string) (string, error)
• type Plugin
• type Secret
  • func (in *Secret) DeepCopy() *Secret
  • func (in *Secret) DeepCopyInto(out *Secret)
• type SecretLoader
  • func NewSecretLoader(c client.Client, ns string) SecretLoader
  • func (sl SecretLoader) LoadSecret(s Secret) (string, error)
• type TLS
  • func (in *TLS) DeepCopy() *TLS
  • func (in *TLS) DeepCopyInto(out *TLS)
  • func (t *TLS) Params(sl SecretLoader) (*params.KVs, error)
• type ValueSource
  • func (in *ValueSource) DeepCopy() *ValueSource
  • func (in *ValueSource) DeepCopyInto(out *ValueSource)

Types

type CommonParams

type CommonParams struct {

	// Alias for the plugin
	Alias string `json:"alias,omitempty"`
	// RetryLimit describes how many times fluent-bit should retry to send data to a specific output. If set to false fluent-bit will try indefinetly. If set to any integer N>0 it will try at most N+1 times. Leading zeros are not allowed (values such as 007, 0150, 01 do not work). If this property is not defined fluent-bit will use the default value: 1.
	// +kubebuilder:validation:Pattern="^(((f|F)alse)|(no_limits)|(no_retries)|([1-9]+[0-9]*))$"
	RetryLimit string `json:"retryLimit,omitempty"`
}

func (*CommonParams) AddCommonParams

func (c *CommonParams) AddCommonParams(kvs *params.KVs) error

func (*CommonParams) DeepCopy

func (in *CommonParams) DeepCopy() *CommonParams

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CommonParams.

func (*CommonParams) DeepCopyInto

func (in *CommonParams) DeepCopyInto(out *CommonParams)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConfigMapLoader

type ConfigMapLoader struct {
	// contains filtered or unexported fields
}

func NewConfigMapLoader

func NewConfigMapLoader(c client.Client, ns string) ConfigMapLoader

func (ConfigMapLoader) LoadConfigMap

func (cl ConfigMapLoader) LoadConfigMap(selector v1.ConfigMapKeySelector, namespace string) (string, error)

type Plugin

type Plugin interface {
	Name() string
	Params(SecretLoader) (*params.KVs, error)
}

The Plugin interface defines methods for transferring input, filter and output plugins to textual section content.

type Secret

type Secret struct {
	ValueFrom ValueSource `json:"valueFrom,omitempty"`
}

+kubebuilder:object:generate:=true Secret defines the key of a value.

func (*Secret) DeepCopy

func (in *Secret) DeepCopy() *Secret

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Secret.

func (*Secret) DeepCopyInto

func (in *Secret) DeepCopyInto(out *Secret)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SecretLoader

type SecretLoader struct {
	Client client.Client
	// contains filtered or unexported fields
}

func NewSecretLoader

func NewSecretLoader(c client.Client, ns string) SecretLoader

func (SecretLoader) LoadSecret

func (sl SecretLoader) LoadSecret(s Secret) (string, error)

type TLS

type TLS struct {
	// Force certificate validation
	Verify *bool `json:"verify,omitempty"`
	// Set TLS debug verbosity level.
	// It accept the following values: 0 (No debug), 1 (Error), 2 (State change), 3 (Informational) and 4 Verbose
	// +kubebuilder:validation:Enum:=0;1;2;3;4
	Debug *int32 `json:"debug,omitempty"`
	// Absolute path to CA certificate file
	CAFile string `json:"caFile,omitempty"`
	// Absolute path to scan for certificate files
	CAPath string `json:"caPath,omitempty"`
	// Absolute path to Certificate file
	CRTFile string `json:"crtFile,omitempty"`
	// Absolute path to private Key file
	KeyFile string `json:"keyFile,omitempty"`
	// Optional password for tls.key_file file
	KeyPassword *Secret `json:"keyPassword,omitempty"`
	// Hostname to be used for TLS SNI extension
	Vhost string `json:"vhost,omitempty"`
}

Fluent Bit provides integrated support for Transport Layer Security (TLS) and it predecessor Secure Sockets Layer (SSL) respectively.

func (*TLS) DeepCopy

func (in *TLS) DeepCopy() *TLS

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLS.

func (*TLS) DeepCopyInto

func (in *TLS) DeepCopyInto(out *TLS)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TLS) Params

func (t *TLS) Params(sl SecretLoader) (*params.KVs, error)

type ValueSource

type ValueSource struct {
	// Selects a key of a secret in the pod's namespace
	// +optional
	SecretKeyRef corev1.SecretKeySelector `json:"secretKeyRef,omitempty"`
}

+kubebuilder:object:generate:=true ValueSource defines how to find a value's key.

func (*ValueSource) DeepCopy

func (in *ValueSource) DeepCopy() *ValueSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ValueSource.

func (*ValueSource) DeepCopyInto

func (in *ValueSource) DeepCopyInto(out *ValueSource)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.