v1alpha2

package
v0.0.0-...-0a9c605 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 10, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package v1alpha2 contains API Schema definitions for the logging v1alpha2 API group +kubebuilder:object:generate=true +groupName=logging.kubesphere.io

Index

Constants

View Source 
const FluentBitFinalizerName = "fluentbit.logging.kubesphere.io"

FluentBitFinalizerName is the name of the fluentbit finalizer

Variables

View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: "logging.kubesphere.io", Version: "v1alpha2"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type ByName 

type ByName []Script

+kubebuilder:object:generate:=false ByName implements sort.Interface for []Script based on the Name field.

func (ByName) Len 

func (a ByName) Len() int

func (ByName) Less 

func (a ByName) Less(i, j int) bool

func (ByName) Swap 

func (a ByName) Swap(i, j int)

type Decorder 

type Decorder struct {
	// If the content can be decoded in a structured message,
	// append that structure message (keys and values) to the original log message.
	DecodeField string `json:"decodeField,omitempty"`
	// Any content decoded (unstructured or structured) will be replaced in the same key/value,
	// no extra keys are added.
	DecodeFieldAs string `json:"decodeFieldAs,omitempty"`
}

func (*Decorder) DeepCopy 

func (in *Decorder) DeepCopy() *Decorder

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

func (*Decorder) DeepCopyInto 

func (in *Decorder) DeepCopyInto(out *Decorder)

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

type Filter 

type Filter struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// Specification of desired Filter configuration.
	Spec FilterSpec `json:"spec,omitempty"`
}

Filter defines a Filter configuration.

func (*Filter) DeepCopy 

func (in *Filter) DeepCopy() *Filter

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

func (*Filter) DeepCopyInto 

func (in *Filter) DeepCopyInto(out *Filter)

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

func (*Filter) DeepCopyObject 

func (in *Filter) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type FilterByName 

type FilterByName []Filter

+kubebuilder:object:generate:=false FilterByName implements sort.Interface for []Filter based on the Name field.

func (FilterByName) Len 

func (a FilterByName) Len() int

func (FilterByName) Less 

func (a FilterByName) Less(i, j int) bool

func (FilterByName) Swap 

func (a FilterByName) Swap(i, j int)

type FilterItem 

type FilterItem struct {
	// Grep defines Grep Filter configuration.
	Grep *filter.Grep `json:"grep,omitempty"`
	// RecordModifier defines Record Modifier Filter configuration.
	RecordModifier *filter.RecordModifier `json:"recordModifier,omitempty"`
	// Kubernetes defines Kubernetes Filter configuration.
	Kubernetes *filter.Kubernetes `json:"kubernetes,omitempty"`
	// Modify defines Modify Filter configuration.
	Modify *filter.Modify `json:"modify,omitempty"`
	// Nest defines Nest Filter configuration.
	Nest *filter.Nest `json:"nest,omitempty"`
	// Parser defines Parser Filter configuration.
	Parser *filter.Parser `json:"parser,omitempty"`
	// Lua defines Lua Filter configuration.
	Lua *filter.Lua `json:"lua,omitempty"`
	// Throttle defines a Throttle configuration.
	Throttle *filter.Throttle `json:"throttle,omitempty"`
	// RewriteTag defines a RewriteTag configuration.
	RewriteTag *filter.RewriteTag `json:"rewriteTag,omitempty"`
}

func (*FilterItem) DeepCopy 

func (in *FilterItem) DeepCopy() *FilterItem

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

func (*FilterItem) DeepCopyInto 

func (in *FilterItem) DeepCopyInto(out *FilterItem)

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

type FilterList 

type FilterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Filter `json:"items"`
}

FilterList contains a list of Filter

func (*FilterList) DeepCopy 

func (in *FilterList) DeepCopy() *FilterList

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

func (*FilterList) DeepCopyInto 

func (in *FilterList) DeepCopyInto(out *FilterList)

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

func (*FilterList) DeepCopyObject 

func (in *FilterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (FilterList) Load 

func (list FilterList) Load(sl plugins.SecretLoader) (string, error)

type FilterSpec 

type FilterSpec struct {
	// A pattern to match against the tags of incoming records.
	// It's case sensitive and support the star (*) character as a wildcard.
	Match string `json:"match,omitempty"`
	// A regular expression to match against the tags of incoming records.
	// Use this option if you want to use the full regex syntax.
	MatchRegex string `json:"matchRegex,omitempty"`
	// A set of filter plugins in order.
	FilterItems []FilterItem `json:"filters,omitempty"`
}

FilterSpec defines the desired state of Filter

func (*FilterSpec) DeepCopy 

func (in *FilterSpec) DeepCopy() *FilterSpec

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

func (*FilterSpec) DeepCopyInto 

func (in *FilterSpec) DeepCopyInto(out *FilterSpec)

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

type FluentBit 

type FluentBit struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   FluentBitSpec   `json:"spec,omitempty"`
	Status FluentBitStatus `json:"status,omitempty"`
}

FluentBit is the Schema for the fluentbits API

func (*FluentBit) AddFinalizer 

func (fb *FluentBit) AddFinalizer(finalizerName string)

AddFinalizer adds the specified finalizer

func (*FluentBit) DeepCopy 

func (in *FluentBit) DeepCopy() *FluentBit

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

func (*FluentBit) DeepCopyInto 

func (in *FluentBit) DeepCopyInto(out *FluentBit)

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

func (*FluentBit) DeepCopyObject 

func (in *FluentBit) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*FluentBit) HasFinalizer 

func (fb *FluentBit) HasFinalizer(finalizerName string) bool

HasFinalizer returns true if the item has the specified finalizer

func (*FluentBit) IsBeingDeleted 

func (fb *FluentBit) IsBeingDeleted() bool

IsBeingDeleted returns true if a deletion timestamp is set

func (*FluentBit) RemoveFinalizer 

func (fb *FluentBit) RemoveFinalizer(finalizerName string)

RemoveFinalizer removes the specified finalizer

type FluentBitConfig 

type FluentBitConfig struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec FluentBitConfigSpec `json:"spec,omitempty"`
}

FluentBitConfig is the Schema for the fluentbitconfigs API

func (*FluentBitConfig) DeepCopy 

func (in *FluentBitConfig) DeepCopy() *FluentBitConfig

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

func (*FluentBitConfig) DeepCopyInto 

func (in *FluentBitConfig) DeepCopyInto(out *FluentBitConfig)

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

func (*FluentBitConfig) DeepCopyObject 

func (in *FluentBitConfig) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (FluentBitConfig) RenderLuaScript 

func (cfg FluentBitConfig) RenderLuaScript(cl plugins.ConfigMapLoader, filters FilterList) ([]Script, error)

func (FluentBitConfig) RenderMainConfig 

func (cfg FluentBitConfig) RenderMainConfig(sl plugins.SecretLoader, inputs InputList, filters FilterList, outputs OutputList) (string, error)

func (FluentBitConfig) RenderParserConfig 

func (cfg FluentBitConfig) RenderParserConfig(sl plugins.SecretLoader, parsers ParserList) (string, error)

type FluentBitConfigList 

type FluentBitConfigList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []FluentBitConfig `json:"items"`
}

FluentBitConfigList contains a list of FluentBitConfig

func (*FluentBitConfigList) DeepCopy 

func (in *FluentBitConfigList) DeepCopy() *FluentBitConfigList

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

func (*FluentBitConfigList) DeepCopyInto 

func (in *FluentBitConfigList) DeepCopyInto(out *FluentBitConfigList)

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

func (*FluentBitConfigList) DeepCopyObject 

func (in *FluentBitConfigList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type FluentBitConfigSpec 

type FluentBitConfigSpec struct {
	// Service defines the global behaviour of the Fluent Bit engine.
	Service *Service `json:"service,omitempty"`
	// Select input plugins
	InputSelector metav1.LabelSelector `json:"inputSelector,omitempty"`
	// Select filter plugins
	FilterSelector metav1.LabelSelector `json:"filterSelector,omitempty"`
	// Select output plugins
	OutputSelector metav1.LabelSelector `json:"outputSelector,omitempty"`
	// Select parser plugins
	ParserSelector metav1.LabelSelector `json:"parserSelector,omitempty"`
}

FluentBitConfigSpec defines the desired state of FluentBitConfig

func (*FluentBitConfigSpec) DeepCopy 

func (in *FluentBitConfigSpec) DeepCopy() *FluentBitConfigSpec

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

func (*FluentBitConfigSpec) DeepCopyInto 

func (in *FluentBitConfigSpec) DeepCopyInto(out *FluentBitConfigSpec)

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

type FluentBitList 

type FluentBitList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []FluentBit `json:"items"`
}

FluentBitList contains a list of FluentBit

func (*FluentBitList) DeepCopy 

func (in *FluentBitList) DeepCopy() *FluentBitList

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

func (*FluentBitList) DeepCopyInto 

func (in *FluentBitList) DeepCopyInto(out *FluentBitList)

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

func (*FluentBitList) DeepCopyObject 

func (in *FluentBitList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type FluentBitSpec 

type FluentBitSpec struct {
	// Fluent Bit image.
	Image string `json:"image,omitempty"`
	// Fluent Bit Plugin Init image.
	InitPluginImage string `json:"initPluginImage,omitempty"`
	// Fluent Bit Journald Init image.
	InitJournaldImage string `json:"initJournaldImage,omitempty"`
	// Fluent Bit Watcher command line arguments.
	Command []string `json:"command,omitempty"`
	// Fluent Bit Plugin command.
	InitPluginCommand []string `json:"initPluginCommand,omitempty"`
	// Fluent Bit Journald command.
	InitJournaldCommand []string `json:"initJournaldCommand,omitempty"`
	// Fluent Bit image pull policy.
	ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"`
	// Fluent Bit image pull secret
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
	// Storage for position db. You will use it if tail input is enabled.
	PositionDB corev1.VolumeSource `json:"positionDB,omitempty"`
	// Container log path
	ContainerLogRealPath string `json:"containerLogRealPath,omitempty"`
	// Compute Resources required by container.
	Resources corev1.ResourceRequirements `json:"resources,omitempty"`
	// NodeSelector
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
	// Pod's scheduling constraints.
	Affinity *corev1.Affinity `json:"affinity,omitempty"`
	// Tolerations
	Tolerations []corev1.Toleration `json:"tolerations,omitempty"`
	// Fluentbitconfig object associated with this Fluentbit
	FluentBitConfigName string `json:"fluentBitConfigName,omitempty"`
	// The Secrets are mounted into /fluent-bit/secrets/<secret-name>.
	Secrets []string `json:"secrets,omitempty"`
	// RuntimeClassName represents the container runtime configuration.
	RuntimeClassName string `json:"runtimeClassName,omitempty"`
	// PriorityClassName represents the pod's priority class.
	PriorityClassName string `json:"priorityClassName,omitempty"`
}

FluentBitSpec defines the desired state of FluentBit

func (*FluentBitSpec) DeepCopy 

func (in *FluentBitSpec) DeepCopy() *FluentBitSpec

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

func (*FluentBitSpec) DeepCopyInto 

func (in *FluentBitSpec) DeepCopyInto(out *FluentBitSpec)

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

type FluentBitStatus 

type FluentBitStatus struct {
}

FluentBitStatus defines the observed state of FluentBit

func (*FluentBitStatus) DeepCopy 

func (in *FluentBitStatus) DeepCopy() *FluentBitStatus

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

func (*FluentBitStatus) DeepCopyInto 

func (in *FluentBitStatus) DeepCopyInto(out *FluentBitStatus)

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

type Input 

type Input struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec InputSpec `json:"spec,omitempty"`
}

Input is the Schema for the inputs API

func (*Input) DeepCopy 

func (in *Input) DeepCopy() *Input

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

func (*Input) DeepCopyInto 

func (in *Input) DeepCopyInto(out *Input)

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

func (*Input) DeepCopyObject 

func (in *Input) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type InputByName 

type InputByName []Input

+kubebuilder:object:generate:=false InputByName implements sort.Interface for []Input based on the Name field.

func (InputByName) Len 

func (a InputByName) Len() int

func (InputByName) Less 

func (a InputByName) Less(i, j int) bool

func (InputByName) Swap 

func (a InputByName) Swap(i, j int)

type InputList 

type InputList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Input `json:"items"`
}

InputList contains a list of Input

func (*InputList) DeepCopy 

func (in *InputList) DeepCopy() *InputList

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

func (*InputList) DeepCopyInto 

func (in *InputList) DeepCopyInto(out *InputList)

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

func (*InputList) DeepCopyObject 

func (in *InputList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (InputList) Load 

func (list InputList) Load(sl plugins.SecretLoader) (string, error)

type InputSpec 

type InputSpec struct {
	// A user friendly alias name for this input plugin.
	// Used in metrics for distinction of each configured input.
	Alias string `json:"alias,omitempty"`
	// Dummy defines Dummy Input configuration.
	Dummy *input.Dummy `json:"dummy,omitempty"`
	// Tail defines Tail Input configuration.
	Tail *input.Tail `json:"tail,omitempty"`
	// Systemd defines Systemd Input configuration.
	Systemd *input.Systemd `json:"systemd,omitempty"`
}

InputSpec defines the desired state of Input

func (*InputSpec) DeepCopy 

func (in *InputSpec) DeepCopy() *InputSpec

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

func (*InputSpec) DeepCopyInto 

func (in *InputSpec) DeepCopyInto(out *InputSpec)

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

type Output 

type Output struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec OutputSpec `json:"spec,omitempty"`
}

Output is the Schema for the outputs API

func (*Output) DeepCopy 

func (in *Output) DeepCopy() *Output

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

func (*Output) DeepCopyInto 

func (in *Output) DeepCopyInto(out *Output)

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

func (*Output) DeepCopyObject 

func (in *Output) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type OutputByName 

type OutputByName []Output

+kubebuilder:object:generate:=false OutputByName implements sort.Interface for []Output based on the Name field.

func (OutputByName) Len 

func (a OutputByName) Len() int

func (OutputByName) Less 

func (a OutputByName) Less(i, j int) bool

func (OutputByName) Swap 

func (a OutputByName) Swap(i, j int)

type OutputList 

type OutputList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Output `json:"items"`
}

OutputList contains a list of Output

func (*OutputList) DeepCopy 

func (in *OutputList) DeepCopy() *OutputList

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

func (*OutputList) DeepCopyInto 

func (in *OutputList) DeepCopyInto(out *OutputList)

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

func (*OutputList) DeepCopyObject 

func (in *OutputList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (OutputList) Load 

func (list OutputList) Load(sl plugins.SecretLoader) (string, error)

type OutputSpec 

type OutputSpec struct {
	// A pattern to match against the tags of incoming records.
	// It's case sensitive and support the star (*) character as a wildcard.
	Match string `json:"match,omitempty"`
	// A regular expression to match against the tags of incoming records.
	// Use this option if you want to use the full regex syntax.
	MatchRegex string `json:"matchRegex,omitempty"`
	// A user friendly alias name for this output plugin.
	// Used in metrics for distinction of each configured output.
	Alias string `json:"alias,omitempty"`
	// RetryLimit represents configuration for the scheduler which can be set independently on each output section.
	// This option allows to disable retries or impose a limit to try N times and then discard the data after reaching that limit.
	RetryLimit string `json:"retry_limit,omitempty"`
	// Elasticsearch defines Elasticsearch Output configuration.
	Elasticsearch *output.Elasticsearch `json:"es,omitempty"`
	// File defines File Output configuration.
	File *output.File `json:"file,omitempty"`
	// Forward defines Forward Output configuration.
	Forward *output.Forward `json:"forward,omitempty"`
	// HTTP defines HTTP Output configuration.
	HTTP *output.HTTP `json:"http,omitempty"`
	// Kafka defines Kafka Output configuration.
	Kafka *output.Kafka `json:"kafka,omitempty"`
	// Null defines Null Output configuration.
	Null *output.Null `json:"null,omitempty"`
	// Stdout defines Stdout Output configuration.
	Stdout *output.Stdout `json:"stdout,omitempty"`
	// TCP defines TCP Output configuration.
	TCP *output.TCP `json:"tcp,omitempty"`
	// Loki defines Loki Output configuration.
	Loki *output.Loki `json:"loki,omitempty"`
	// GardenerLoki defines Loki Output configuration for Gardener.
	GardenerLoki *output.GardenerLoki `json:"gardenerloki,omitempty"`
	// Syslog defines Syslog Output configuration.
	Syslog *output.Syslog `json:"syslog,omitempty"`
	// DataDog defines DataDog Output configuration.
	DataDog *output.DataDog `json:"datadog,omitempty"`
}

OutputSpec defines the desired state of Output

func (*OutputSpec) DeepCopy 

func (in *OutputSpec) DeepCopy() *OutputSpec

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

func (*OutputSpec) DeepCopyInto 

func (in *OutputSpec) DeepCopyInto(out *OutputSpec)

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

type Parser 

type Parser struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec ParserSpec `json:"spec,omitempty"`
}

Parser is the Schema for the parsers API

func (*Parser) DeepCopy 

func (in *Parser) DeepCopy() *Parser

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

func (*Parser) DeepCopyInto 

func (in *Parser) DeepCopyInto(out *Parser)

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

func (*Parser) DeepCopyObject 

func (in *Parser) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ParserByName 

type ParserByName []Parser

+kubebuilder:object:generate:=false ParserByName implements sort.Interface for []Parser based on the Name field.

func (ParserByName) Len 

func (a ParserByName) Len() int

func (ParserByName) Less 

func (a ParserByName) Less(i, j int) bool

func (ParserByName) Swap 

func (a ParserByName) Swap(i, j int)

type ParserList 

type ParserList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Parser `json:"items"`
}

ParserList contains a list of Parser

func (*ParserList) DeepCopy 

func (in *ParserList) DeepCopy() *ParserList

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

func (*ParserList) DeepCopyInto 

func (in *ParserList) DeepCopyInto(out *ParserList)

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

func (*ParserList) DeepCopyObject 

func (in *ParserList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (ParserList) Load 

func (list ParserList) Load(sl plugins.SecretLoader) (string, error)

type ParserSpec 

type ParserSpec struct {

	// JSON defines json parser configuration.
	JSON *parser.JSON `json:"json,omitempty"`
	// Regex defines regex parser configuration.
	Regex *parser.Regex `json:"regex,omitempty"`
	// LTSV defines ltsv parser configuration.
	LTSV *parser.LSTV `json:"ltsv,omitempty"`
	// Logfmt defines logfmt parser configuration.
	Logfmt *parser.Logfmt `json:"logfmt,omitempty"`
	// Decoders are a built-in feature available through the Parsers file, each Parser definition can optionally set one or multiple decoders.
	// There are two type of decoders type: Decode_Field and Decode_Field_As.
	Decoders []Decorder `json:"decoders,omitempty"`
}

ParserSpec defines the desired state of Parser

func (*ParserSpec) DeepCopy 

func (in *ParserSpec) DeepCopy() *ParserSpec

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

func (*ParserSpec) DeepCopyInto 

func (in *ParserSpec) DeepCopyInto(out *ParserSpec)

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

type Script 

type Script struct {
	Name    string
	Content string
}

+kubebuilder:object:generate:=false

type Service 

type Service struct {
	// If true go to background on start
	Daemon *bool `json:"daemon,omitempty"`
	// Interval to flush output
	FlushSeconds *int64 `json:"flushSeconds,omitempty"`
	// Wait time on exit
	GraceSeconds *int64 `json:"graceSeconds,omitempty"`
	// Address to listen
	// +kubebuilder:validation:Pattern:="^\\d{1,3}.\\d{1,3}.\\d{1,3}.\\d{1,3}$"
	HttpListen string `json:"httpListen,omitempty"`
	// Port to listen
	// +kubebuilder:validation:Minimum:=1
	// +kubebuilder:validation:Maximum:=65535
	HttpPort *int32 `json:"httpPort,omitempty"`
	// If true enable statistics HTTP server
	HttpServer *bool `json:"httpServer,omitempty"`
	// File to log diagnostic output
	LogFile string `json:"logFile,omitempty"`
	// Diagnostic level (error/warning/info/debug/trace)
	// +kubebuilder:validation:Enum:=error;warning;info;debug;trace
	LogLevel string `json:"logLevel,omitempty"`
	// Optional 'parsers' config file (can be multiple)
	ParsersFile string `json:"parsersFile,omitempty"`
}

func (*Service) DeepCopy 

func (in *Service) DeepCopy() *Service

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

func (*Service) DeepCopyInto 

func (in *Service) DeepCopyInto(out *Service)

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

func (*Service) Params 

func (s *Service) Params() *params.KVs

Source Files

View all Source files

Directories

Path Synopsis
filter
input
output
params
parser

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.