v1alpha1

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Apr 14, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the telemetry v1alpha1 API group +kubebuilder:object:generate=true +groupName=telemetry.kyma-project.io

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "telemetry.kyma-project.io", Version: "v1alpha1"}

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

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

Functions

This section is empty.

Types

type ApplicationInput 

type ApplicationInput struct {
	// Describes whether application logs from specific Namespaces are selected. The options are mutually exclusive. System Namespaces are excluded by default from the collection.
	Namespaces InputNamespaces `json:"namespaces,omitempty"`
	// Describes whether application logs from specific containers are selected. The options are mutually exclusive.
	Containers InputContainers `json:"containers,omitempty"`
	// Defines whether to keep all Kubernetes annotations. The default is `false`.
	KeepAnnotations bool `json:"keepAnnotations,omitempty"`
	// Defines whether to drop all Kubernetes labels. The default is `false`.
	DropLabels bool `json:"dropLabels,omitempty"`
}

ApplicationInput specifies the default type of Input that handles application logs from runtime containers. It configures in more detail from which containers logs are selected as input.

func (*ApplicationInput) DeepCopy 

func (in *ApplicationInput) DeepCopy() *ApplicationInput

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

func (*ApplicationInput) DeepCopyInto 

func (in *ApplicationInput) DeepCopyInto(out *ApplicationInput)

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

type AuthenticationOptions 

type AuthenticationOptions struct {
	// Activates `Basic` authentication for the destination providing relevant Secrets.
	Basic *BasicAuthOptions `json:"basic,omitempty"`
}

func (*AuthenticationOptions) DeepCopy 

func (in *AuthenticationOptions) DeepCopy() *AuthenticationOptions

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

func (*AuthenticationOptions) DeepCopyInto 

func (in *AuthenticationOptions) DeepCopyInto(out *AuthenticationOptions)

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

type BasicAuthOptions 

type BasicAuthOptions struct {
	// Contains the basic auth username or a Secret reference.
	// +kubebuilder:validation:Required
	User ValueType `json:"user"`
	// Contains the basic auth password or a Secret reference.
	// +kubebuilder:validation:Required
	Password ValueType `json:"password"`
}

func (*BasicAuthOptions) DeepCopy 

func (in *BasicAuthOptions) DeepCopy() *BasicAuthOptions

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

func (*BasicAuthOptions) DeepCopyInto 

func (in *BasicAuthOptions) DeepCopyInto(out *BasicAuthOptions)

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

func (*BasicAuthOptions) IsDefined 

func (b *BasicAuthOptions) IsDefined() bool

type FileMount 

type FileMount struct {
	Name    string `json:"name,omitempty"`
	Content string `json:"content,omitempty"`
}

Provides file content to be consumed by a LogPipeline configuration

func (*FileMount) DeepCopy 

func (in *FileMount) DeepCopy() *FileMount

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

func (*FileMount) DeepCopyInto 

func (in *FileMount) DeepCopyInto(out *FileMount)

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

type Filter 

type Filter struct {
	// Custom filter definition in the Fluent Bit syntax. Note: If you use a `custom` filter, you put the LogPipeline in unsupported mode.
	Custom string `json:"custom,omitempty"`
}

Describes a filtering option on the logs of the pipeline.

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.

type HTTPOutput 

type HTTPOutput struct {
	// Defines the host of the HTTP receiver.
	Host ValueType `json:"host,omitempty"`
	// Defines the basic auth user.
	User ValueType `json:"user,omitempty"`
	// Defines the basic auth password.
	Password ValueType `json:"password,omitempty"`
	// Defines the URI of the HTTP receiver. Default is "/".
	URI string `json:"uri,omitempty"`
	// Defines the port of the HTTP receiver. Default is 443.
	Port string `json:"port,omitempty"`
	// Defines the compression algorithm to use.
	Compress string `json:"compress,omitempty"`
	// Data format to be used in the HTTP request body. Default is `json`.
	Format string `json:"format,omitempty"`
	// Configures TLS for the HTTP target server.
	TLSConfig TLSConfig `json:"tls,omitempty"`
	// Enables de-dotting of Kubernetes labels and annotations for compatibility with ElasticSearch based backends. Dots (.) will be replaced by underscores (_). Default is `false`.
	Dedot bool `json:"dedot,omitempty"`
}

HTTPOutput configures an HTTP-based output compatible with the Fluent Bit HTTP output plugin.

func (*HTTPOutput) DeepCopy 

func (in *HTTPOutput) DeepCopy() *HTTPOutput

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

func (*HTTPOutput) DeepCopyInto 

func (in *HTTPOutput) DeepCopyInto(out *HTTPOutput)

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

type Header struct {
	// Defines the header name.
	Name string `json:"name"`
	// Defines the header value.
	ValueType `json:",inline"`
}

func (*Header) DeepCopy 

func (in *Header) DeepCopy() *Header

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

func (*Header) DeepCopyInto 

func (in *Header) DeepCopyInto(out *Header)

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

type Input 

type Input struct {
	// Configures in more detail from which containers application logs are enabled as input.
	Application ApplicationInput `json:"application,omitempty"`
}

Input describes a log input for a LogPipeline.

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) IsDefined 

func (i *Input) IsDefined() bool

type InputContainers 

type InputContainers struct {
	// Specifies to include only the container logs with the specified container names.
	Include []string `json:"include,omitempty"`
	// Specifies to exclude only the container logs with the specified container names.
	Exclude []string `json:"exclude,omitempty"`
}

InputContainers describes whether application logs from specific containers are selected. The options are mutually exclusive.

func (*InputContainers) DeepCopy 

func (in *InputContainers) DeepCopy() *InputContainers

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

func (*InputContainers) DeepCopyInto 

func (in *InputContainers) DeepCopyInto(out *InputContainers)

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

type InputNamespaces 

type InputNamespaces struct {
	// Include only the container logs of the specified Namespace names.
	Include []string `json:"include,omitempty"`
	// Exclude the container logs of the specified Namespace names.
	Exclude []string `json:"exclude,omitempty"`
	// Set to `true` if collecting from all Namespaces must also include the system Namespaces like kube-system, istio-system, and kyma-system.
	System bool `json:"system,omitempty"`
}

InputNamespaces describes whether application logs from specific Namespaces are selected. The options are mutually exclusive. System Namespaces are excluded by default from the collection.

func (*InputNamespaces) DeepCopy 

func (in *InputNamespaces) DeepCopy() *InputNamespaces

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

func (*InputNamespaces) DeepCopyInto 

func (in *InputNamespaces) DeepCopyInto(out *InputNamespaces)

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

type LogParser 

type LogParser struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// Defines the desired state of LogParser.
	Spec LogParserSpec `json:"spec,omitempty"`
	// Shows the observed state of the LogParser.
	Status LogParserStatus `json:"status,omitempty"`
}

LogParser is the Schema for the logparsers API.

func (*LogParser) DeepCopy 

func (in *LogParser) DeepCopy() *LogParser

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

func (*LogParser) DeepCopyInto 

func (in *LogParser) DeepCopyInto(out *LogParser)

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

func (*LogParser) DeepCopyObject 

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

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

func (*LogParser) Validate 

func (lp *LogParser) Validate() error

type LogParserCondition 

type LogParserCondition struct {
	// An array of conditions describing the status of the parser.
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
	// An array of conditions describing the status of the parser.
	Reason string `json:"reason,omitempty"`
	// The possible transition types are:<br>- `Running`: The parser is ready and usable.<br>- `Pending`: The parser is being activated.
	Type LogParserConditionType `json:"type,omitempty"`
}

func NewLogParserCondition 

func NewLogParserCondition(reason string, condType LogParserConditionType) *LogParserCondition

func (*LogParserCondition) DeepCopy 

func (in *LogParserCondition) DeepCopy() *LogParserCondition

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

func (*LogParserCondition) DeepCopyInto 

func (in *LogParserCondition) DeepCopyInto(out *LogParserCondition)

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

type LogParserConditionType 

type LogParserConditionType string
const (
	LogParserPending LogParserConditionType = "Pending"
	LogParserRunning LogParserConditionType = "Running"
)

These are the valid statuses of LogParser.

type LogParserList 

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

LogParserList contains a list of LogParser.

func (*LogParserList) DeepCopy 

func (in *LogParserList) DeepCopy() *LogParserList

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

func (*LogParserList) DeepCopyInto 

func (in *LogParserList) DeepCopyInto(out *LogParserList)

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

func (*LogParserList) DeepCopyObject 

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

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

type LogParserSpec 

type LogParserSpec struct {

	// [Fluent Bit Parsers](https://docs.fluentbit.io/manual/pipeline/parsers). The parser specified here has no effect until it is referenced by a [Pod annotation](https://docs.fluentbit.io/manual/pipeline/filters/kubernetes#kubernetes-annotations) on your workload or by a [Parser Filter](https://docs.fluentbit.io/manual/pipeline/filters/parser) defined in a pipeline's filters section.
	Parser string `json:"parser,omitempty"`
}

LogParserSpec defines the desired state of LogParser.

func (*LogParserSpec) DeepCopy 

func (in *LogParserSpec) DeepCopy() *LogParserSpec

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

func (*LogParserSpec) DeepCopyInto 

func (in *LogParserSpec) DeepCopyInto(out *LogParserSpec)

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

type LogParserStatus 

type LogParserStatus struct {
	// An array of conditions describing the status of the parser.
	Conditions []LogParserCondition `json:"conditions,omitempty"`
}

LogParserStatus shows the observed state of the LogParser.

func (*LogParserStatus) DeepCopy 

func (in *LogParserStatus) DeepCopy() *LogParserStatus

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

func (*LogParserStatus) DeepCopyInto 

func (in *LogParserStatus) DeepCopyInto(out *LogParserStatus)

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

func (*LogParserStatus) GetCondition 

func (lps *LogParserStatus) GetCondition(condType LogParserConditionType) *LogParserCondition

func (*LogParserStatus) HasCondition 

func (lps *LogParserStatus) HasCondition(condition LogParserConditionType) bool

func (*LogParserStatus) SetCondition 

func (lps *LogParserStatus) SetCondition(cond LogParserCondition)

type LogPipeline 

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

	// Defines the desired state of LogPipeline
	Spec LogPipelineSpec `json:"spec,omitempty"`
	// Shows the observed state of the LogPipeline
	Status LogPipelineStatus `json:"status,omitempty"`
}

+kubebuilder:object:root=true +kubebuilder:resource:scope=Cluster +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Status",type=string,JSONPath=`.status.conditions[-1].type` +kubebuilder:printcolumn:name="Unsupported-Mode",type=boolean,JSONPath=`.status.unsupportedMode` +kubebuilder:printcolumn:name="Age",type=date,JSONPath=`.metadata.creationTimestamp` LogPipeline is the Schema for the logpipelines API

func (*LogPipeline) ContainsCustomPlugin 

func (lp *LogPipeline) ContainsCustomPlugin() bool

ContainsCustomPlugin returns true if the pipeline contains any custom filters or outputs

func (*LogPipeline) DeepCopy 

func (in *LogPipeline) DeepCopy() *LogPipeline

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

func (*LogPipeline) DeepCopyInto 

func (in *LogPipeline) DeepCopyInto(out *LogPipeline)

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

func (*LogPipeline) DeepCopyObject 

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

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

func (*LogPipeline) GetSecretRefs 

func (lp *LogPipeline) GetSecretRefs() []SecretKeyRef

func (*LogPipeline) Validate 

func (lp *LogPipeline) Validate(vc *LogPipelineValidationConfig) error

type LogPipelineCondition 

type LogPipelineCondition struct {
	// An array of conditions describing the status of the pipeline.
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
	//  An array of conditions describing the status of the pipeline.
	Reason string `json:"reason,omitempty"`
	// The possible transition types are:<br>- `Running`: The instance is ready and usable.<br>- `Pending`: The pipeline is being activated.
	Type LogPipelineConditionType `json:"type,omitempty"`
}

LogPipelineCondition contains details for the current condition of this LogPipeline

func NewLogPipelineCondition 

func NewLogPipelineCondition(reason string, condType LogPipelineConditionType) *LogPipelineCondition

func (*LogPipelineCondition) DeepCopy 

func (in *LogPipelineCondition) DeepCopy() *LogPipelineCondition

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

func (*LogPipelineCondition) DeepCopyInto 

func (in *LogPipelineCondition) DeepCopyInto(out *LogPipelineCondition)

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

type LogPipelineConditionType 

type LogPipelineConditionType string
const (
	LogPipelinePending LogPipelineConditionType = "Pending"
	LogPipelineRunning LogPipelineConditionType = "Running"
)

These are the valid statuses of LogPipeline.

type LogPipelineList 

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

+kubebuilder:object:root=true LogPipelineList contains a list of LogPipeline

func (*LogPipelineList) DeepCopy 

func (in *LogPipelineList) DeepCopy() *LogPipelineList

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

func (*LogPipelineList) DeepCopyInto 

func (in *LogPipelineList) DeepCopyInto(out *LogPipelineList)

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

func (*LogPipelineList) DeepCopyObject 

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

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

type LogPipelineSpec 

type LogPipelineSpec struct {

	// Defines where to collect logs, including selector mechanisms.
	Input   Input    `json:"input,omitempty"`
	Filters []Filter `json:"filters,omitempty"`
	// [Fluent Bit output](https://docs.fluentbit.io/manual/pipeline/outputs) where you want to push the logs. Only one output can be specified.
	Output Output      `json:"output,omitempty"`
	Files  []FileMount `json:"files,omitempty"`
	// A list of mappings from Kubernetes Secret keys to environment variables. Mapped keys are mounted as environment variables, so that they are available as [Variables](https://docs.fluentbit.io/manual/administration/configuring-fluent-bit/classic-mode/variables) in the sections.
	Variables []VariableRef `json:"variables,omitempty"`
}

LogPipelineSpec defines the desired state of LogPipeline

func (*LogPipelineSpec) DeepCopy 

func (in *LogPipelineSpec) DeepCopy() *LogPipelineSpec

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

func (*LogPipelineSpec) DeepCopyInto 

func (in *LogPipelineSpec) DeepCopyInto(out *LogPipelineSpec)

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

type LogPipelineStatus 

type LogPipelineStatus struct {
	// An array of conditions describing the status of the pipeline.
	Conditions []LogPipelineCondition `json:"conditions,omitempty"`
	// Is active when the LogPipeline uses a `custom` output or filter; see [unsupported mode](./../../01-overview/main-areas/telemetry/telemetry-02-logs.md#unsupported-mode#unsupported-mode).
	UnsupportedMode bool `json:"unsupportedMode,omitempty"`
}

LogPipelineStatus shows the observed state of the LogPipeline

func (*LogPipelineStatus) DeepCopy 

func (in *LogPipelineStatus) DeepCopy() *LogPipelineStatus

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

func (*LogPipelineStatus) DeepCopyInto 

func (in *LogPipelineStatus) DeepCopyInto(out *LogPipelineStatus)

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

func (*LogPipelineStatus) GetCondition 

func (lps *LogPipelineStatus) GetCondition(condType LogPipelineConditionType) *LogPipelineCondition

func (*LogPipelineStatus) HasCondition 

func (lps *LogPipelineStatus) HasCondition(condition LogPipelineConditionType) bool

func (*LogPipelineStatus) SetCondition 

func (lps *LogPipelineStatus) SetCondition(cond LogPipelineCondition)

type LogPipelineValidationConfig 

type LogPipelineValidationConfig struct {
	DeniedOutPutPlugins []string
	DeniedFilterPlugins []string
}

func (*LogPipelineValidationConfig) DeepCopy 

func (in *LogPipelineValidationConfig) DeepCopy() *LogPipelineValidationConfig

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

func (*LogPipelineValidationConfig) DeepCopyInto 

func (in *LogPipelineValidationConfig) DeepCopyInto(out *LogPipelineValidationConfig)

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

type LokiOutput 

type LokiOutput struct {
	// Grafana Loki URL.
	URL ValueType `json:"url,omitempty"`
	// Labels to set for each log record.
	Labels map[string]string `json:"labels,omitempty"`
	// Attributes to be removed from a log record.
	RemoveKeys []string `json:"removeKeys,omitempty"`
}

LokiOutput configures an output to the Kyma-internal Loki instance.

func (*LokiOutput) DeepCopy 

func (in *LokiOutput) DeepCopy() *LokiOutput

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

func (*LokiOutput) DeepCopyInto 

func (in *LokiOutput) DeepCopyInto(out *LokiOutput)

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

type MetricPipeline 

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

	Spec   MetricPipelineSpec   `json:"spec,omitempty"`
	Status MetricPipelineStatus `json:"status,omitempty"`
}

MetricPipeline is the Schema for the metricpipelines API

func (*MetricPipeline) DeepCopy 

func (in *MetricPipeline) DeepCopy() *MetricPipeline

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

func (*MetricPipeline) DeepCopyInto 

func (in *MetricPipeline) DeepCopyInto(out *MetricPipeline)

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

func (*MetricPipeline) DeepCopyObject 

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

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

func (*MetricPipeline) GetSecretRefs 

func (mp *MetricPipeline) GetSecretRefs() []SecretKeyRef

type MetricPipelineCondition 

type MetricPipelineCondition struct {
	LastTransitionTime metav1.Time                 `json:"lastTransitionTime,omitempty"`
	Reason             string                      `json:"reason,omitempty"`
	Type               MetricPipelineConditionType `json:"type,omitempty"`
}

Contains details for the current condition of this MetricPipeline

func NewMetricPipelineCondition 

func NewMetricPipelineCondition(reason string, condType MetricPipelineConditionType) *MetricPipelineCondition

func (*MetricPipelineCondition) DeepCopy 

func (in *MetricPipelineCondition) DeepCopy() *MetricPipelineCondition

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

func (*MetricPipelineCondition) DeepCopyInto 

func (in *MetricPipelineCondition) DeepCopyInto(out *MetricPipelineCondition)

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

type MetricPipelineConditionType 

type MetricPipelineConditionType string
const (
	MetricPipelinePending MetricPipelineConditionType = "Pending"
	MetricPipelineRunning MetricPipelineConditionType = "Running"
)

These are the valid statuses of MetricPipeline.

type MetricPipelineList 

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

MetricPipelineList contains a list of MetricPipeline

func (*MetricPipelineList) DeepCopy 

func (in *MetricPipelineList) DeepCopy() *MetricPipelineList

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

func (*MetricPipelineList) DeepCopyInto 

func (in *MetricPipelineList) DeepCopyInto(out *MetricPipelineList)

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

func (*MetricPipelineList) DeepCopyObject 

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

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

type MetricPipelineOutput 

type MetricPipelineOutput struct {
	// Defines an output using the OpenTelmetry protocol.
	Otlp *OtlpOutput `json:"otlp"`
}

MetricPipelineOutput defines the output configuration section.

func (*MetricPipelineOutput) DeepCopy 

func (in *MetricPipelineOutput) DeepCopy() *MetricPipelineOutput

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

func (*MetricPipelineOutput) DeepCopyInto 

func (in *MetricPipelineOutput) DeepCopyInto(out *MetricPipelineOutput)

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

type MetricPipelineSpec 

type MetricPipelineSpec struct {
	// Configures the trace receiver of a MetricPipeline.
	Output MetricPipelineOutput `json:"output"`
}

MetricPipelineSpec defines the desired state of MetricPipeline

func (*MetricPipelineSpec) DeepCopy 

func (in *MetricPipelineSpec) DeepCopy() *MetricPipelineSpec

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

func (*MetricPipelineSpec) DeepCopyInto 

func (in *MetricPipelineSpec) DeepCopyInto(out *MetricPipelineSpec)

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

type MetricPipelineStatus 

type MetricPipelineStatus struct {
	Conditions []MetricPipelineCondition `json:"conditions,omitempty"`
}

Defines the observed state of MetricPipeline

func (*MetricPipelineStatus) DeepCopy 

func (in *MetricPipelineStatus) DeepCopy() *MetricPipelineStatus

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

func (*MetricPipelineStatus) DeepCopyInto 

func (in *MetricPipelineStatus) DeepCopyInto(out *MetricPipelineStatus)

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

func (*MetricPipelineStatus) GetCondition 

func (tps *MetricPipelineStatus) GetCondition(condType MetricPipelineConditionType) *MetricPipelineCondition

func (*MetricPipelineStatus) HasCondition 

func (tps *MetricPipelineStatus) HasCondition(condition MetricPipelineConditionType) bool

func (*MetricPipelineStatus) SetCondition 

func (tps *MetricPipelineStatus) SetCondition(cond MetricPipelineCondition)

type OtlpOutput 

type OtlpOutput struct {
	// Defines the OTLP protocol (http or grpc). Default is GRPC.
	// +kubebuilder:validation:MinLength=1
	// +kubebuilder:default:=grpc
	// +kubebuilder:validation:Enum=grpc;http
	Protocol string `json:"protocol,omitempty"`
	// Defines the host and port (<host>:<port>) of an OTLP endpoint.
	// +kubebuilder:validation:Required
	Endpoint ValueType `json:"endpoint"`
	// Defines authentication options for the OTLP output
	Authentication *AuthenticationOptions `json:"authentication,omitempty"`
	// Defines custom headers to be added to outgoing HTTP or GRPC requests.
	Headers []Header `json:"headers,omitempty"`
}

func (*OtlpOutput) DeepCopy 

func (in *OtlpOutput) DeepCopy() *OtlpOutput

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

func (*OtlpOutput) DeepCopyInto 

func (in *OtlpOutput) DeepCopyInto(out *OtlpOutput)

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

type Output 

type Output struct {
	// Defines a custom output in the Fluent Bit syntax. Note: If you use a `custom` output, you put the LogPipeline in unsupported mode.
	Custom string `json:"custom,omitempty"`
	// Configures an HTTP-based output compatible with the Fluent Bit HTTP output plugin.
	HTTP *HTTPOutput `json:"http,omitempty"`
	// Configures an output to the Kyma-internal Loki instance. [Fluent Bit grafana-loki output](https://grafana.com/docs/loki/v2.2.x/clients/fluentbit/). **Note:** This output is considered legacy and is only provided for backward compatibility with the [deprecated](https://kyma-project.io/blog/2022/11/2/loki-deprecation/) in-cluster Loki instance. It might not be compatible with the latest Loki versions. For integration with a custom Loki installation use the `custom` output with the name `loki` instead, see also [Installing a custom Loki stack in Kyma](https://github.com/kyma-project/examples/tree/main/loki).
	Loki *LokiOutput `json:"grafana-loki,omitempty"`
}

Output describes a Fluent Bit output configuration section.

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) IsAnyDefined 

func (o *Output) IsAnyDefined() bool

func (*Output) IsCustomDefined 

func (o *Output) IsCustomDefined() bool

func (*Output) IsHTTPDefined 

func (o *Output) IsHTTPDefined() bool

func (*Output) IsLokiDefined 

func (o *Output) IsLokiDefined() bool

func (*Output) IsSingleDefined 

func (o *Output) IsSingleDefined() bool

type SecretKeyRef 

type SecretKeyRef struct {
	Name      string `json:"name,omitempty"`
	Namespace string `json:"namespace,omitempty"`
	Key       string `json:"key,omitempty"`
}

func (*SecretKeyRef) DeepCopy 

func (in *SecretKeyRef) DeepCopy() *SecretKeyRef

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

func (*SecretKeyRef) DeepCopyInto 

func (in *SecretKeyRef) DeepCopyInto(out *SecretKeyRef)

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

func (*SecretKeyRef) NamespacedName 

func (skr *SecretKeyRef) NamespacedName() types.NamespacedName

type TLSConfig 

type TLSConfig struct {
	// Indicates if TLS is disabled or enabled. Default is `false`.
	Disabled bool `json:"disabled,omitempty"`
	// If `true`, the validation of certificates is skipped. Default is `false`.
	SkipCertificateValidation bool `json:"skipCertificateValidation,omitempty"`
}

func (*TLSConfig) DeepCopy 

func (in *TLSConfig) DeepCopy() *TLSConfig

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

func (*TLSConfig) DeepCopyInto 

func (in *TLSConfig) DeepCopyInto(out *TLSConfig)

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

type TracePipeline 

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

	// Defines the desired state of TracePipeline
	Spec TracePipelineSpec `json:"spec,omitempty"`
	// Shows the observed state of the TracePipeline
	Status TracePipelineStatus `json:"status,omitempty"`
}

+kubebuilder:object:root=true +kubebuilder:resource:scope=Cluster +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Status",type=string,JSONPath=`.status.conditions[-1].type` +kubebuilder:printcolumn:name="Age",type=date,JSONPath=`.metadata.creationTimestamp` TracePipeline is the Schema for the tracepipelines API

func (*TracePipeline) DeepCopy 

func (in *TracePipeline) DeepCopy() *TracePipeline

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

func (*TracePipeline) DeepCopyInto 

func (in *TracePipeline) DeepCopyInto(out *TracePipeline)

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

func (*TracePipeline) DeepCopyObject 

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

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

func (*TracePipeline) GetSecretRefs 

func (tp *TracePipeline) GetSecretRefs() []SecretKeyRef

type TracePipelineCondition 

type TracePipelineCondition struct {
	// An array of conditions describing the status of the pipeline.
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
	// An array of conditions describing the status of the pipeline.
	Reason string `json:"reason,omitempty"`
	// The possible transition types are:<br>- `Running`: The instance is ready and usable.<br>- `Pending`: The pipeline is being activated.
	Type TracePipelineConditionType `json:"type,omitempty"`
}

An array of conditions describing the status of the pipeline.

func NewTracePipelineCondition 

func NewTracePipelineCondition(reason string, condType TracePipelineConditionType) *TracePipelineCondition

func (*TracePipelineCondition) DeepCopy 

func (in *TracePipelineCondition) DeepCopy() *TracePipelineCondition

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

func (*TracePipelineCondition) DeepCopyInto 

func (in *TracePipelineCondition) DeepCopyInto(out *TracePipelineCondition)

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

type TracePipelineConditionType 

type TracePipelineConditionType string
const (
	TracePipelinePending TracePipelineConditionType = "Pending"
	TracePipelineRunning TracePipelineConditionType = "Running"
)

These are the valid statuses of TracePipeline.

type TracePipelineList 

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

TracePipelineList contains a list of TracePipeline

func (*TracePipelineList) DeepCopy 

func (in *TracePipelineList) DeepCopy() *TracePipelineList

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

func (*TracePipelineList) DeepCopyInto 

func (in *TracePipelineList) DeepCopyInto(out *TracePipelineList)

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

func (*TracePipelineList) DeepCopyObject 

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

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

type TracePipelineOutput 

type TracePipelineOutput struct {
	// Configures the underlying Otel Collector with an [OTLP exporter](https://github.com/open-telemetry/opentelemetry-collector/blob/main/exporter/otlpexporter/README.md). If you switch `protocol`to `http`, an [OTLP HTTP exporter](https://github.com/open-telemetry/opentelemetry-collector/tree/main/exporter/otlphttpexporter) is used.
	Otlp *OtlpOutput `json:"otlp"`
}

TracePipelineOutput defines the output configuration section.

func (*TracePipelineOutput) DeepCopy 

func (in *TracePipelineOutput) DeepCopy() *TracePipelineOutput

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

func (*TracePipelineOutput) DeepCopyInto 

func (in *TracePipelineOutput) DeepCopyInto(out *TracePipelineOutput)

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

type TracePipelineSpec 

type TracePipelineSpec struct {
	// Defines a destination for shipping trace data. Only one can be defined per pipeline.
	Output TracePipelineOutput `json:"output"`
}

TracePipelineSpec defines the desired state of TracePipeline

func (*TracePipelineSpec) DeepCopy 

func (in *TracePipelineSpec) DeepCopy() *TracePipelineSpec

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

func (*TracePipelineSpec) DeepCopyInto 

func (in *TracePipelineSpec) DeepCopyInto(out *TracePipelineSpec)

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

type TracePipelineStatus 

type TracePipelineStatus struct {
	Conditions []TracePipelineCondition `json:"conditions,omitempty"`
}

Defines the observed state of TracePipeline

func (*TracePipelineStatus) DeepCopy 

func (in *TracePipelineStatus) DeepCopy() *TracePipelineStatus

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

func (*TracePipelineStatus) DeepCopyInto 

func (in *TracePipelineStatus) DeepCopyInto(out *TracePipelineStatus)

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

func (*TracePipelineStatus) GetCondition 

func (tps *TracePipelineStatus) GetCondition(condType TracePipelineConditionType) *TracePipelineCondition

func (*TracePipelineStatus) HasCondition 

func (tps *TracePipelineStatus) HasCondition(condition TracePipelineConditionType) bool

func (*TracePipelineStatus) SetCondition 

func (tps *TracePipelineStatus) SetCondition(cond TracePipelineCondition)

type ValueFromSource 

type ValueFromSource struct {
	// Refers to a key in a Secret. You must provide `name` and `namespace` of the Secret, as well as the name of the `key`.
	SecretKeyRef *SecretKeyRef `json:"secretKeyRef,omitempty"`
}

func (*ValueFromSource) DeepCopy 

func (in *ValueFromSource) DeepCopy() *ValueFromSource

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

func (*ValueFromSource) DeepCopyInto 

func (in *ValueFromSource) DeepCopyInto(out *ValueFromSource)

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

func (*ValueFromSource) IsSecretKeyRef 

func (v *ValueFromSource) IsSecretKeyRef() bool

type ValueType 

type ValueType struct {
	// Value that can contain references to Secret values.
	Value     string           `json:"value,omitempty"`
	ValueFrom *ValueFromSource `json:"valueFrom,omitempty"`
}

func (*ValueType) DeepCopy 

func (in *ValueType) DeepCopy() *ValueType

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

func (*ValueType) DeepCopyInto 

func (in *ValueType) DeepCopyInto(out *ValueType)

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

func (*ValueType) IsDefined 

func (v *ValueType) IsDefined() bool

type VariableRef 

type VariableRef struct {
	// Name of the variable to map.
	Name      string          `json:"name,omitempty"`
	ValueFrom ValueFromSource `json:"valueFrom,omitempty"`
}

References a Kubernetes secret that should be provided as environment variable to Fluent Bit

func (*VariableRef) DeepCopy 

func (in *VariableRef) DeepCopy() *VariableRef

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

func (*VariableRef) DeepCopyInto 

func (in *VariableRef) DeepCopyInto(out *VariableRef)

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

Source Files

View all Source files

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.