v1alpha1

package
v0.5.0 Latest Latest
Warning

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

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

Documentation

Overview

+groupName=logs.datadog.kubeform.com

Index

Constants

This section is empty.

Variables

View Source
var (
	// TODO: move SchemeBuilder with zz_generated.deepcopy.go to k8s.io/api.
	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
	SchemeBuilder runtime.SchemeBuilder

	AddToScheme = localSchemeBuilder.AddToScheme
)
View Source
var SchemeGroupVersion = schema.GroupVersion{Group: logs.GroupName, Version: "v1alpha1"}

Functions

func GetDecoder

func GetDecoder() map[string]jsoniter.ValDecoder

func GetEncoder

func GetEncoder() map[string]jsoniter.ValEncoder

func Kind

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns a Group qualified GroupKind

func Resource

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type Archive

type Archive struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ArchiveSpec   `json:"spec,omitempty"`
	Status            ArchiveStatus `json:"status,omitempty"`
}

func (*Archive) DeepCopy

func (in *Archive) DeepCopy() *Archive

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

func (*Archive) DeepCopyInto

func (in *Archive) DeepCopyInto(out *Archive)

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

func (*Archive) DeepCopyObject

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

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

func (*Archive) SetupWebhookWithManager

func (r *Archive) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Archive) ValidateCreate

func (r *Archive) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Archive) ValidateDelete

func (r *Archive) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Archive) ValidateUpdate

func (r *Archive) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type ArchiveList

type ArchiveList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of Archive CRD objects
	Items []Archive `json:"items,omitempty"`
}

ArchiveList is a list of Archives

func (*ArchiveList) DeepCopy

func (in *ArchiveList) DeepCopy() *ArchiveList

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

func (*ArchiveList) DeepCopyInto

func (in *ArchiveList) DeepCopyInto(out *ArchiveList)

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

func (*ArchiveList) DeepCopyObject

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

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

type ArchiveOrder

type ArchiveOrder struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ArchiveOrderSpec   `json:"spec,omitempty"`
	Status            ArchiveOrderStatus `json:"status,omitempty"`
}

func (*ArchiveOrder) DeepCopy

func (in *ArchiveOrder) DeepCopy() *ArchiveOrder

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

func (*ArchiveOrder) DeepCopyInto

func (in *ArchiveOrder) DeepCopyInto(out *ArchiveOrder)

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

func (*ArchiveOrder) DeepCopyObject

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

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

func (*ArchiveOrder) SetupWebhookWithManager

func (r *ArchiveOrder) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*ArchiveOrder) ValidateCreate

func (r *ArchiveOrder) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*ArchiveOrder) ValidateDelete

func (r *ArchiveOrder) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*ArchiveOrder) ValidateUpdate

func (r *ArchiveOrder) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type ArchiveOrderList

type ArchiveOrderList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of ArchiveOrder CRD objects
	Items []ArchiveOrder `json:"items,omitempty"`
}

ArchiveOrderList is a list of ArchiveOrders

func (*ArchiveOrderList) DeepCopy

func (in *ArchiveOrderList) DeepCopy() *ArchiveOrderList

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

func (*ArchiveOrderList) DeepCopyInto

func (in *ArchiveOrderList) DeepCopyInto(out *ArchiveOrderList)

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

func (*ArchiveOrderList) DeepCopyObject

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

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

type ArchiveOrderSpec

type ArchiveOrderSpec struct {
	State *ArchiveOrderSpecResource `json:"state,omitempty" tf:"-"`

	Resource ArchiveOrderSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*ArchiveOrderSpec) DeepCopy

func (in *ArchiveOrderSpec) DeepCopy() *ArchiveOrderSpec

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

func (*ArchiveOrderSpec) DeepCopyInto

func (in *ArchiveOrderSpec) DeepCopyInto(out *ArchiveOrderSpec)

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

type ArchiveOrderSpecResource

type ArchiveOrderSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// The archive IDs list. The order of archive IDs in this attribute defines the overall archive order for logs. If `archive_ids` is empty or not specified, it will import the actual archive order, and create the resource. Otherwise, it will try to update the order.
	// +optional
	ArchiveIDS []string `json:"archiveIDS,omitempty" tf:"archive_ids"`
}

func (*ArchiveOrderSpecResource) DeepCopy

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

func (*ArchiveOrderSpecResource) DeepCopyInto

func (in *ArchiveOrderSpecResource) DeepCopyInto(out *ArchiveOrderSpecResource)

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

type ArchiveOrderStatus

type ArchiveOrderStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*ArchiveOrderStatus) DeepCopy

func (in *ArchiveOrderStatus) DeepCopy() *ArchiveOrderStatus

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

func (*ArchiveOrderStatus) DeepCopyInto

func (in *ArchiveOrderStatus) DeepCopyInto(out *ArchiveOrderStatus)

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

type ArchiveSpec

type ArchiveSpec struct {
	State *ArchiveSpecResource `json:"state,omitempty" tf:"-"`

	Resource ArchiveSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*ArchiveSpec) DeepCopy

func (in *ArchiveSpec) DeepCopy() *ArchiveSpec

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

func (*ArchiveSpec) DeepCopyInto

func (in *ArchiveSpec) DeepCopyInto(out *ArchiveSpec)

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

type ArchiveSpecAzureArchive

type ArchiveSpecAzureArchive struct {
	// Your client id.
	ClientID *string `json:"clientID" tf:"client_id"`
	// The container where the archive will be stored.
	Container *string `json:"container" tf:"container"`
	// The path where the archive will be stored.
	// +optional
	Path *string `json:"path,omitempty" tf:"path"`
	// The associated storage account.
	StorageAccount *string `json:"storageAccount" tf:"storage_account"`
	// Your tenant id.
	TenantID *string `json:"tenantID" tf:"tenant_id"`
}

func (*ArchiveSpecAzureArchive) DeepCopy

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

func (*ArchiveSpecAzureArchive) DeepCopyInto

func (in *ArchiveSpecAzureArchive) DeepCopyInto(out *ArchiveSpecAzureArchive)

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

type ArchiveSpecAzureArchiveCodec

type ArchiveSpecAzureArchiveCodec struct {
}

+k8s:deepcopy-gen=false

func (ArchiveSpecAzureArchiveCodec) Decode

func (ArchiveSpecAzureArchiveCodec) Encode

func (ArchiveSpecAzureArchiveCodec) IsEmpty

type ArchiveSpecGcsArchive

type ArchiveSpecGcsArchive struct {
	// Name of your GCS bucket.
	Bucket *string `json:"bucket" tf:"bucket"`
	// Your client email.
	ClientEmail *string `json:"clientEmail" tf:"client_email"`
	// Path where the archive will be stored.
	Path *string `json:"path" tf:"path"`
	// Your project id.
	ProjectID *string `json:"projectID" tf:"project_id"`
}

func (*ArchiveSpecGcsArchive) DeepCopy

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

func (*ArchiveSpecGcsArchive) DeepCopyInto

func (in *ArchiveSpecGcsArchive) DeepCopyInto(out *ArchiveSpecGcsArchive)

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

type ArchiveSpecGcsArchiveCodec

type ArchiveSpecGcsArchiveCodec struct {
}

+k8s:deepcopy-gen=false

func (ArchiveSpecGcsArchiveCodec) Decode

func (ArchiveSpecGcsArchiveCodec) Encode

func (ArchiveSpecGcsArchiveCodec) IsEmpty

type ArchiveSpecResource

type ArchiveSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// Definition of an azure archive.
	// +optional
	AzureArchive *ArchiveSpecAzureArchive `json:"azureArchive,omitempty" tf:"azure_archive"`
	// Definition of a GCS archive.
	// +optional
	GcsArchive *ArchiveSpecGcsArchive `json:"gcsArchive,omitempty" tf:"gcs_archive"`
	// To store the tags in the archive, set the value `true`. If it is set to `false`, the tags will be dropped when the logs are sent to the archive.
	// +optional
	IncludeTags *bool `json:"includeTags,omitempty" tf:"include_tags"`
	// Your archive name.
	Name *string `json:"name" tf:"name"`
	// The archive query/filter. Logs matching this query are included in the archive.
	Query *string `json:"query" tf:"query"`
	// An array of tags to add to rehydrated logs from an archive.
	// +optional
	RehydrationTags []string `json:"rehydrationTags,omitempty" tf:"rehydration_tags"`
	// Definition of an s3 archive.
	// +optional
	S3Archive *ArchiveSpecS3Archive `json:"s3Archive,omitempty" tf:"s3_archive"`
}

func (*ArchiveSpecResource) DeepCopy

func (in *ArchiveSpecResource) DeepCopy() *ArchiveSpecResource

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

func (*ArchiveSpecResource) DeepCopyInto

func (in *ArchiveSpecResource) DeepCopyInto(out *ArchiveSpecResource)

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

type ArchiveSpecS3Archive

type ArchiveSpecS3Archive struct {
	// Your AWS account id.
	AccountID *string `json:"accountID" tf:"account_id"`
	// Name of your s3 bucket.
	Bucket *string `json:"bucket" tf:"bucket"`
	// Path where the archive will be stored.
	Path *string `json:"path" tf:"path"`
	// Your AWS role name
	RoleName *string `json:"roleName" tf:"role_name"`
}

func (*ArchiveSpecS3Archive) DeepCopy

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

func (*ArchiveSpecS3Archive) DeepCopyInto

func (in *ArchiveSpecS3Archive) DeepCopyInto(out *ArchiveSpecS3Archive)

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

type ArchiveSpecS3ArchiveCodec

type ArchiveSpecS3ArchiveCodec struct {
}

+k8s:deepcopy-gen=false

func (ArchiveSpecS3ArchiveCodec) Decode

func (ArchiveSpecS3ArchiveCodec) Encode

func (ArchiveSpecS3ArchiveCodec) IsEmpty

type ArchiveStatus

type ArchiveStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*ArchiveStatus) DeepCopy

func (in *ArchiveStatus) DeepCopy() *ArchiveStatus

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

func (*ArchiveStatus) DeepCopyInto

func (in *ArchiveStatus) DeepCopyInto(out *ArchiveStatus)

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

type CustomPipeline

type CustomPipeline struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              CustomPipelineSpec   `json:"spec,omitempty"`
	Status            CustomPipelineStatus `json:"status,omitempty"`
}

func (*CustomPipeline) DeepCopy

func (in *CustomPipeline) DeepCopy() *CustomPipeline

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

func (*CustomPipeline) DeepCopyInto

func (in *CustomPipeline) DeepCopyInto(out *CustomPipeline)

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

func (*CustomPipeline) DeepCopyObject

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

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

func (*CustomPipeline) SetupWebhookWithManager

func (r *CustomPipeline) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*CustomPipeline) ValidateCreate

func (r *CustomPipeline) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*CustomPipeline) ValidateDelete

func (r *CustomPipeline) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*CustomPipeline) ValidateUpdate

func (r *CustomPipeline) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type CustomPipelineList

type CustomPipelineList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of CustomPipeline CRD objects
	Items []CustomPipeline `json:"items,omitempty"`
}

CustomPipelineList is a list of CustomPipelines

func (*CustomPipelineList) DeepCopy

func (in *CustomPipelineList) DeepCopy() *CustomPipelineList

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

func (*CustomPipelineList) DeepCopyInto

func (in *CustomPipelineList) DeepCopyInto(out *CustomPipelineList)

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

func (*CustomPipelineList) DeepCopyObject

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

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

type CustomPipelineSpec

type CustomPipelineSpec struct {
	State *CustomPipelineSpecResource `json:"state,omitempty" tf:"-"`

	Resource CustomPipelineSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*CustomPipelineSpec) DeepCopy

func (in *CustomPipelineSpec) DeepCopy() *CustomPipelineSpec

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

func (*CustomPipelineSpec) DeepCopyInto

func (in *CustomPipelineSpec) DeepCopyInto(out *CustomPipelineSpec)

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

type CustomPipelineSpecFilter

type CustomPipelineSpecFilter struct {
	// Filter criteria of the category.
	Query *string `json:"query" tf:"query"`
}

func (*CustomPipelineSpecFilter) DeepCopy

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

func (*CustomPipelineSpecFilter) DeepCopyInto

func (in *CustomPipelineSpecFilter) DeepCopyInto(out *CustomPipelineSpecFilter)

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

type CustomPipelineSpecProcessor

type CustomPipelineSpecProcessor struct {
	// Arithmetic Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#arithmetic-processor)
	// +optional
	ArithmeticProcessor *CustomPipelineSpecProcessorArithmeticProcessor `json:"arithmeticProcessor,omitempty" tf:"arithmetic_processor"`
	// Attribute Remapper Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#remapper)
	// +optional
	AttributeRemapper *CustomPipelineSpecProcessorAttributeRemapper `json:"attributeRemapper,omitempty" tf:"attribute_remapper"`
	// Category Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#category-processor)
	// +optional
	CategoryProcessor *CustomPipelineSpecProcessorCategoryProcessor `json:"categoryProcessor,omitempty" tf:"category_processor"`
	// Date Remapper Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#log-date-remapper)
	// +optional
	DateRemapper *CustomPipelineSpecProcessorDateRemapper `json:"dateRemapper,omitempty" tf:"date_remapper"`
	// Date GeoIP Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#geoip-parser)
	// +optional
	GeoIPParser *CustomPipelineSpecProcessorGeoIPParser `json:"geoIPParser,omitempty" tf:"geo_ip_parser"`
	// Grok Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#grok-parser)
	// +optional
	GrokParser *CustomPipelineSpecProcessorGrokParser `json:"grokParser,omitempty" tf:"grok_parser"`
	// Lookup Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#lookup-processor)
	// +optional
	LookupProcessor *CustomPipelineSpecProcessorLookupProcessor `json:"lookupProcessor,omitempty" tf:"lookup_processor"`
	// Message Remapper Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#log-message-remapper)
	// +optional
	MessageRemapper *CustomPipelineSpecProcessorMessageRemapper `json:"messageRemapper,omitempty" tf:"message_remapper"`
	// +optional
	Pipeline *CustomPipelineSpecProcessorPipeline `json:"pipeline,omitempty" tf:"pipeline"`
	// Service Remapper Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#service-remapper)
	// +optional
	ServiceRemapper *CustomPipelineSpecProcessorServiceRemapper `json:"serviceRemapper,omitempty" tf:"service_remapper"`
	// Status Remapper Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#log-status-remapper)
	// +optional
	StatusRemapper *CustomPipelineSpecProcessorStatusRemapper `json:"statusRemapper,omitempty" tf:"status_remapper"`
	// String Builder Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#string-builder-processor)
	// +optional
	StringBuilderProcessor *CustomPipelineSpecProcessorStringBuilderProcessor `json:"stringBuilderProcessor,omitempty" tf:"string_builder_processor"`
	// Trace ID Remapper Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#trace-remapper)
	// +optional
	TraceIDRemapper *CustomPipelineSpecProcessorTraceIDRemapper `json:"traceIDRemapper,omitempty" tf:"trace_id_remapper"`
	// URL Parser Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#url-parser)
	// +optional
	UrlParser *CustomPipelineSpecProcessorUrlParser `json:"urlParser,omitempty" tf:"url_parser"`
	// User-Agent Parser Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#user-agent-parser)
	// +optional
	UserAgentParser *CustomPipelineSpecProcessorUserAgentParser `json:"userAgentParser,omitempty" tf:"user_agent_parser"`
}

func (*CustomPipelineSpecProcessor) DeepCopy

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

func (*CustomPipelineSpecProcessor) DeepCopyInto

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

type CustomPipelineSpecProcessorArithmeticProcessor

type CustomPipelineSpecProcessorArithmeticProcessor struct {
	// Arithmetic operation between one or more log attributes.
	Expression *string `json:"expression" tf:"expression"`
	// Boolean value to enable your pipeline.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// If true, it replaces all missing attributes of expression by 0, false skips the operation if an attribute is missing.
	// +optional
	IsReplaceMissing *bool `json:"isReplaceMissing,omitempty" tf:"is_replace_missing"`
	// Your pipeline name.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// Name of the attribute that contains the result of the arithmetic operation.
	Target *string `json:"target" tf:"target"`
}

func (*CustomPipelineSpecProcessorArithmeticProcessor) DeepCopy

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

func (*CustomPipelineSpecProcessorArithmeticProcessor) DeepCopyInto

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

type CustomPipelineSpecProcessorArithmeticProcessorCodec

type CustomPipelineSpecProcessorArithmeticProcessorCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorArithmeticProcessorCodec) Decode

func (CustomPipelineSpecProcessorArithmeticProcessorCodec) Encode

func (CustomPipelineSpecProcessorArithmeticProcessorCodec) IsEmpty

type CustomPipelineSpecProcessorAttributeRemapper

type CustomPipelineSpecProcessorAttributeRemapper struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// Override the target element if already set.
	// +optional
	OverrideOnConflict *bool `json:"overrideOnConflict,omitempty" tf:"override_on_conflict"`
	// Remove or preserve the remapped source element.
	// +optional
	PreserveSource *bool `json:"preserveSource,omitempty" tf:"preserve_source"`
	// Defines where the sources are from (log `attribute` or `tag`).
	SourceType *string `json:"sourceType" tf:"source_type"`
	// List of source attributes or tags.
	Sources []string `json:"sources" tf:"sources"`
	// Final attribute or tag name to remap the sources.
	Target *string `json:"target" tf:"target"`
	// If the `target_type` of the remapper is `attribute`, try to cast the value to a new specific type. If the cast is not possible, the original type is kept. `string`, `integer`, or `double` are the possible types. If the `target_type` is `tag`, this parameter may not be specified.
	// +optional
	TargetFormat *string `json:"targetFormat,omitempty" tf:"target_format"`
	// Defines if the target is a log `attribute` or `tag`.
	TargetType *string `json:"targetType" tf:"target_type"`
}

func (*CustomPipelineSpecProcessorAttributeRemapper) DeepCopy

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

func (*CustomPipelineSpecProcessorAttributeRemapper) DeepCopyInto

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

type CustomPipelineSpecProcessorAttributeRemapperCodec

type CustomPipelineSpecProcessorAttributeRemapperCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorAttributeRemapperCodec) Decode

func (CustomPipelineSpecProcessorAttributeRemapperCodec) Encode

func (CustomPipelineSpecProcessorAttributeRemapperCodec) IsEmpty

type CustomPipelineSpecProcessorCategoryProcessor

type CustomPipelineSpecProcessorCategoryProcessor struct {
	// List of filters to match or exclude a log with their corresponding name to assign a custom value to the log.
	Category []CustomPipelineSpecProcessorCategoryProcessorCategory `json:"category" tf:"category"`
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the category
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// Name of the target attribute whose value is defined by the matching category.
	Target *string `json:"target" tf:"target"`
}

func (*CustomPipelineSpecProcessorCategoryProcessor) DeepCopy

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

func (*CustomPipelineSpecProcessorCategoryProcessor) DeepCopyInto

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

type CustomPipelineSpecProcessorCategoryProcessorCategory

type CustomPipelineSpecProcessorCategoryProcessorCategory struct {
	Filter *CustomPipelineSpecProcessorCategoryProcessorCategoryFilter `json:"filter" tf:"filter"`
	Name   *string                                                     `json:"name" tf:"name"`
}

func (*CustomPipelineSpecProcessorCategoryProcessorCategory) DeepCopy

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

func (*CustomPipelineSpecProcessorCategoryProcessorCategory) DeepCopyInto

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

type CustomPipelineSpecProcessorCategoryProcessorCategoryFilter

type CustomPipelineSpecProcessorCategoryProcessorCategoryFilter struct {
	// Filter criteria of the category.
	Query *string `json:"query" tf:"query"`
}

func (*CustomPipelineSpecProcessorCategoryProcessorCategoryFilter) DeepCopy

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

func (*CustomPipelineSpecProcessorCategoryProcessorCategoryFilter) DeepCopyInto

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

type CustomPipelineSpecProcessorCategoryProcessorCategoryFilterCodec

type CustomPipelineSpecProcessorCategoryProcessorCategoryFilterCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorCategoryProcessorCategoryFilterCodec) Decode

func (CustomPipelineSpecProcessorCategoryProcessorCategoryFilterCodec) Encode

func (CustomPipelineSpecProcessorCategoryProcessorCategoryFilterCodec) IsEmpty

type CustomPipelineSpecProcessorCategoryProcessorCodec

type CustomPipelineSpecProcessorCategoryProcessorCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorCategoryProcessorCodec) Decode

func (CustomPipelineSpecProcessorCategoryProcessorCodec) Encode

func (CustomPipelineSpecProcessorCategoryProcessorCodec) IsEmpty

type CustomPipelineSpecProcessorDateRemapper

type CustomPipelineSpecProcessorDateRemapper struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
}

func (*CustomPipelineSpecProcessorDateRemapper) DeepCopy

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

func (*CustomPipelineSpecProcessorDateRemapper) DeepCopyInto

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

type CustomPipelineSpecProcessorDateRemapperCodec

type CustomPipelineSpecProcessorDateRemapperCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorDateRemapperCodec) Decode

func (CustomPipelineSpecProcessorDateRemapperCodec) Encode

func (CustomPipelineSpecProcessorDateRemapperCodec) IsEmpty

type CustomPipelineSpecProcessorGeoIPParser

type CustomPipelineSpecProcessorGeoIPParser struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
	// Name of the parent attribute that contains all the extracted details from the sources.
	Target *string `json:"target" tf:"target"`
}

func (*CustomPipelineSpecProcessorGeoIPParser) DeepCopy

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

func (*CustomPipelineSpecProcessorGeoIPParser) DeepCopyInto

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

type CustomPipelineSpecProcessorGeoIPParserCodec

type CustomPipelineSpecProcessorGeoIPParserCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorGeoIPParserCodec) Decode

func (CustomPipelineSpecProcessorGeoIPParserCodec) Encode

func (CustomPipelineSpecProcessorGeoIPParserCodec) IsEmpty

type CustomPipelineSpecProcessorGrokParser

type CustomPipelineSpecProcessorGrokParser struct {
	Grok *CustomPipelineSpecProcessorGrokParserGrok `json:"grok" tf:"grok"`
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of sample logs for this parser. It can save up to 5 samples. Each sample takes up to 5000 characters.
	// +optional
	Samples []string `json:"samples,omitempty" tf:"samples"`
	// Name of the log attribute to parse.
	Source *string `json:"source" tf:"source"`
}

func (*CustomPipelineSpecProcessorGrokParser) DeepCopy

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

func (*CustomPipelineSpecProcessorGrokParser) DeepCopyInto

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

type CustomPipelineSpecProcessorGrokParserCodec

type CustomPipelineSpecProcessorGrokParserCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorGrokParserCodec) Decode

func (CustomPipelineSpecProcessorGrokParserCodec) Encode

func (CustomPipelineSpecProcessorGrokParserCodec) IsEmpty

type CustomPipelineSpecProcessorGrokParserGrok

type CustomPipelineSpecProcessorGrokParserGrok struct {
	// Match rules for your grok parser.
	MatchRules *string `json:"matchRules" tf:"match_rules"`
	// Support rules for your grok parser.
	SupportRules *string `json:"supportRules" tf:"support_rules"`
}

func (*CustomPipelineSpecProcessorGrokParserGrok) DeepCopy

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

func (*CustomPipelineSpecProcessorGrokParserGrok) DeepCopyInto

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

type CustomPipelineSpecProcessorGrokParserGrokCodec

type CustomPipelineSpecProcessorGrokParserGrokCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorGrokParserGrokCodec) Decode

func (CustomPipelineSpecProcessorGrokParserGrokCodec) Encode

func (CustomPipelineSpecProcessorGrokParserGrokCodec) IsEmpty

type CustomPipelineSpecProcessorLookupProcessor

type CustomPipelineSpecProcessorLookupProcessor struct {
	// Default lookup value to use if there is no entry in the lookup table for the value of the source attribute.
	// +optional
	DefaultLookup *string `json:"defaultLookup,omitempty" tf:"default_lookup"`
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// List of entries of the lookup table using `key,value` format.
	LookupTable []string `json:"lookupTable" tf:"lookup_table"`
	// Name of the processor
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// Name of the source attribute used to do the lookup.
	Source *string `json:"source" tf:"source"`
	// Name of the attribute that contains the result of the lookup.
	Target *string `json:"target" tf:"target"`
}

func (*CustomPipelineSpecProcessorLookupProcessor) DeepCopy

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

func (*CustomPipelineSpecProcessorLookupProcessor) DeepCopyInto

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

type CustomPipelineSpecProcessorLookupProcessorCodec

type CustomPipelineSpecProcessorLookupProcessorCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorLookupProcessorCodec) Decode

func (CustomPipelineSpecProcessorLookupProcessorCodec) Encode

func (CustomPipelineSpecProcessorLookupProcessorCodec) IsEmpty

type CustomPipelineSpecProcessorMessageRemapper

type CustomPipelineSpecProcessorMessageRemapper struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
}

func (*CustomPipelineSpecProcessorMessageRemapper) DeepCopy

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

func (*CustomPipelineSpecProcessorMessageRemapper) DeepCopyInto

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

type CustomPipelineSpecProcessorMessageRemapperCodec

type CustomPipelineSpecProcessorMessageRemapperCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorMessageRemapperCodec) Decode

func (CustomPipelineSpecProcessorMessageRemapperCodec) Encode

func (CustomPipelineSpecProcessorMessageRemapperCodec) IsEmpty

type CustomPipelineSpecProcessorPipeline

type CustomPipelineSpecProcessorPipeline struct {
	Filter []CustomPipelineSpecProcessorPipelineFilter `json:"filter" tf:"filter"`
	// +optional
	IsEnabled *bool   `json:"isEnabled,omitempty" tf:"is_enabled"`
	Name      *string `json:"name" tf:"name"`
	// +optional
	Processor []CustomPipelineSpecProcessorPipelineProcessor `json:"processor,omitempty" tf:"processor"`
}

func (*CustomPipelineSpecProcessorPipeline) DeepCopy

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

func (*CustomPipelineSpecProcessorPipeline) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineCodec

type CustomPipelineSpecProcessorPipelineCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineCodec) Decode

func (CustomPipelineSpecProcessorPipelineCodec) Encode

func (CustomPipelineSpecProcessorPipelineCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineFilter

type CustomPipelineSpecProcessorPipelineFilter struct {
	// Filter criteria of the category.
	Query *string `json:"query" tf:"query"`
}

func (*CustomPipelineSpecProcessorPipelineFilter) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineFilter) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessor

type CustomPipelineSpecProcessorPipelineProcessor struct {
	// Arithmetic Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#arithmetic-processor)
	// +optional
	ArithmeticProcessor *CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor `json:"arithmeticProcessor,omitempty" tf:"arithmetic_processor"`
	// Attribute Remapper Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#remapper)
	// +optional
	AttributeRemapper *CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper `json:"attributeRemapper,omitempty" tf:"attribute_remapper"`
	// Category Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#category-processor)
	// +optional
	CategoryProcessor *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor `json:"categoryProcessor,omitempty" tf:"category_processor"`
	// Date Remapper Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#log-date-remapper)
	// +optional
	DateRemapper *CustomPipelineSpecProcessorPipelineProcessorDateRemapper `json:"dateRemapper,omitempty" tf:"date_remapper"`
	// Date GeoIP Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#geoip-parser)
	// +optional
	GeoIPParser *CustomPipelineSpecProcessorPipelineProcessorGeoIPParser `json:"geoIPParser,omitempty" tf:"geo_ip_parser"`
	// Grok Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#grok-parser)
	// +optional
	GrokParser *CustomPipelineSpecProcessorPipelineProcessorGrokParser `json:"grokParser,omitempty" tf:"grok_parser"`
	// Lookup Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#lookup-processor)
	// +optional
	LookupProcessor *CustomPipelineSpecProcessorPipelineProcessorLookupProcessor `json:"lookupProcessor,omitempty" tf:"lookup_processor"`
	// Message Remapper Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#log-message-remapper)
	// +optional
	MessageRemapper *CustomPipelineSpecProcessorPipelineProcessorMessageRemapper `json:"messageRemapper,omitempty" tf:"message_remapper"`
	// Service Remapper Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#service-remapper)
	// +optional
	ServiceRemapper *CustomPipelineSpecProcessorPipelineProcessorServiceRemapper `json:"serviceRemapper,omitempty" tf:"service_remapper"`
	// Status Remapper Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#log-status-remapper)
	// +optional
	StatusRemapper *CustomPipelineSpecProcessorPipelineProcessorStatusRemapper `json:"statusRemapper,omitempty" tf:"status_remapper"`
	// String Builder Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#string-builder-processor)
	// +optional
	StringBuilderProcessor *CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor `json:"stringBuilderProcessor,omitempty" tf:"string_builder_processor"`
	// Trace ID Remapper Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#trace-remapper)
	// +optional
	TraceIDRemapper *CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapper `json:"traceIDRemapper,omitempty" tf:"trace_id_remapper"`
	// URL Parser Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#url-parser)
	// +optional
	UrlParser *CustomPipelineSpecProcessorPipelineProcessorUrlParser `json:"urlParser,omitempty" tf:"url_parser"`
	// User-Agent Parser Processor. More information can be found in the [official docs](https://docs.datadoghq.com/logs/processing/processors/?tab=ui#user-agent-parser)
	// +optional
	UserAgentParser *CustomPipelineSpecProcessorPipelineProcessorUserAgentParser `json:"userAgentParser,omitempty" tf:"user_agent_parser"`
}

func (*CustomPipelineSpecProcessorPipelineProcessor) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessor) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor

type CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor struct {
	// Arithmetic operation between one or more log attributes.
	Expression *string `json:"expression" tf:"expression"`
	// Boolean value to enable your pipeline.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// If true, it replaces all missing attributes of expression by 0, false skips the operation if an attribute is missing.
	// +optional
	IsReplaceMissing *bool `json:"isReplaceMissing,omitempty" tf:"is_replace_missing"`
	// Your pipeline name.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// Name of the attribute that contains the result of the arithmetic operation.
	Target *string `json:"target" tf:"target"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessorCodec

type CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessorCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessorCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessorCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessorCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper

type CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// Override the target element if already set.
	// +optional
	OverrideOnConflict *bool `json:"overrideOnConflict,omitempty" tf:"override_on_conflict"`
	// Remove or preserve the remapped source element.
	// +optional
	PreserveSource *bool `json:"preserveSource,omitempty" tf:"preserve_source"`
	// Defines where the sources are from (log `attribute` or `tag`).
	SourceType *string `json:"sourceType" tf:"source_type"`
	// List of source attributes or tags.
	Sources []string `json:"sources" tf:"sources"`
	// Final attribute or tag name to remap the sources.
	Target *string `json:"target" tf:"target"`
	// If the `target_type` of the remapper is `attribute`, try to cast the value to a new specific type. If the cast is not possible, the original type is kept. `string`, `integer`, or `double` are the possible types. If the `target_type` is `tag`, this parameter may not be specified.
	// +optional
	TargetFormat *string `json:"targetFormat,omitempty" tf:"target_format"`
	// Defines if the target is a log `attribute` or `tag`.
	TargetType *string `json:"targetType" tf:"target_type"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorAttributeRemapperCodec

type CustomPipelineSpecProcessorPipelineProcessorAttributeRemapperCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorAttributeRemapperCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorAttributeRemapperCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorAttributeRemapperCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor

type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor struct {
	// List of filters to match or exclude a log with their corresponding name to assign a custom value to the log.
	Category []CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory `json:"category" tf:"category"`
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the category
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// Name of the target attribute whose value is defined by the matching category.
	Target *string `json:"target" tf:"target"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory

type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory struct {
	Filter *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilter `json:"filter" tf:"filter"`
	Name   *string                                                                      `json:"name" tf:"name"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilter

type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilter struct {
	// Filter criteria of the category.
	Query *string `json:"query" tf:"query"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilter) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilter) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilterCodec

type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilterCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilterCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilterCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilterCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec

type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorDateRemapper

type CustomPipelineSpecProcessorPipelineProcessorDateRemapper struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorDateRemapper) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorDateRemapper) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorDateRemapperCodec

type CustomPipelineSpecProcessorPipelineProcessorDateRemapperCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorDateRemapperCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorDateRemapperCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorDateRemapperCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorGeoIPParser

type CustomPipelineSpecProcessorPipelineProcessorGeoIPParser struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
	// Name of the parent attribute that contains all the extracted details from the sources.
	Target *string `json:"target" tf:"target"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorGeoIPParser) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorGeoIPParser) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorGeoIPParserCodec

type CustomPipelineSpecProcessorPipelineProcessorGeoIPParserCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorGeoIPParserCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorGeoIPParserCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorGeoIPParserCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorGrokParser

type CustomPipelineSpecProcessorPipelineProcessorGrokParser struct {
	Grok *CustomPipelineSpecProcessorPipelineProcessorGrokParserGrok `json:"grok" tf:"grok"`
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of sample logs for this parser. It can save up to 5 samples. Each sample takes up to 5000 characters.
	// +optional
	Samples []string `json:"samples,omitempty" tf:"samples"`
	// Name of the log attribute to parse.
	Source *string `json:"source" tf:"source"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorGrokParser) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorGrokParser) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorGrokParserCodec

type CustomPipelineSpecProcessorPipelineProcessorGrokParserCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorGrokParserCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorGrokParserCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorGrokParserCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorGrokParserGrok

type CustomPipelineSpecProcessorPipelineProcessorGrokParserGrok struct {
	// Match rules for your grok parser.
	MatchRules *string `json:"matchRules" tf:"match_rules"`
	// Support rules for your grok parser.
	SupportRules *string `json:"supportRules" tf:"support_rules"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorGrokParserGrok) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorGrokParserGrok) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorGrokParserGrokCodec

type CustomPipelineSpecProcessorPipelineProcessorGrokParserGrokCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorGrokParserGrokCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorGrokParserGrokCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorGrokParserGrokCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorLookupProcessor

type CustomPipelineSpecProcessorPipelineProcessorLookupProcessor struct {
	// Default lookup value to use if there is no entry in the lookup table for the value of the source attribute.
	// +optional
	DefaultLookup *string `json:"defaultLookup,omitempty" tf:"default_lookup"`
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// List of entries of the lookup table using `key,value` format.
	LookupTable []string `json:"lookupTable" tf:"lookup_table"`
	// Name of the processor
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// Name of the source attribute used to do the lookup.
	Source *string `json:"source" tf:"source"`
	// Name of the attribute that contains the result of the lookup.
	Target *string `json:"target" tf:"target"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorLookupProcessor) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorLookupProcessor) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorLookupProcessorCodec

type CustomPipelineSpecProcessorPipelineProcessorLookupProcessorCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorLookupProcessorCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorLookupProcessorCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorLookupProcessorCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorMessageRemapper

type CustomPipelineSpecProcessorPipelineProcessorMessageRemapper struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorMessageRemapper) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorMessageRemapper) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorMessageRemapperCodec

type CustomPipelineSpecProcessorPipelineProcessorMessageRemapperCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorMessageRemapperCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorMessageRemapperCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorMessageRemapperCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorServiceRemapper

type CustomPipelineSpecProcessorPipelineProcessorServiceRemapper struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorServiceRemapper) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorServiceRemapper) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorServiceRemapperCodec

type CustomPipelineSpecProcessorPipelineProcessorServiceRemapperCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorServiceRemapperCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorServiceRemapperCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorServiceRemapperCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorStatusRemapper

type CustomPipelineSpecProcessorPipelineProcessorStatusRemapper struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorStatusRemapper) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorStatusRemapper) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorStatusRemapperCodec

type CustomPipelineSpecProcessorPipelineProcessorStatusRemapperCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorStatusRemapperCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorStatusRemapperCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorStatusRemapperCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor

type CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// If it replaces all missing attributes of template by an empty string.
	// +optional
	IsReplaceMissing *bool `json:"isReplaceMissing,omitempty" tf:"is_replace_missing"`
	// The name of the processor.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// The name of the attribute that contains the result of the template.
	Target *string `json:"target" tf:"target"`
	// The formula with one or more attributes and raw text.
	Template *string `json:"template" tf:"template"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessorCodec

type CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessorCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessorCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessorCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessorCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapper

type CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapper struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapper) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapper) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapperCodec

type CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapperCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapperCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapperCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapperCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorUrlParser

type CustomPipelineSpecProcessorPipelineProcessorUrlParser struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// Normalize the ending slashes or not.
	// +optional
	NormalizeEndingSlashes *bool `json:"normalizeEndingSlashes,omitempty" tf:"normalize_ending_slashes"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
	// Name of the parent attribute that contains all the extracted details from the sources.
	Target *string `json:"target" tf:"target"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorUrlParser) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorUrlParser) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorUrlParserCodec

type CustomPipelineSpecProcessorPipelineProcessorUrlParserCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorUrlParserCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorUrlParserCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorUrlParserCodec) IsEmpty

type CustomPipelineSpecProcessorPipelineProcessorUserAgentParser

type CustomPipelineSpecProcessorPipelineProcessorUserAgentParser struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// If the source attribute is URL encoded or not.
	// +optional
	IsEncoded *bool `json:"isEncoded,omitempty" tf:"is_encoded"`
	// Name of the processor
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
	// Name of the parent attribute that contains all the extracted details from the sources.
	Target *string `json:"target" tf:"target"`
}

func (*CustomPipelineSpecProcessorPipelineProcessorUserAgentParser) DeepCopy

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

func (*CustomPipelineSpecProcessorPipelineProcessorUserAgentParser) DeepCopyInto

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

type CustomPipelineSpecProcessorPipelineProcessorUserAgentParserCodec

type CustomPipelineSpecProcessorPipelineProcessorUserAgentParserCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorPipelineProcessorUserAgentParserCodec) Decode

func (CustomPipelineSpecProcessorPipelineProcessorUserAgentParserCodec) Encode

func (CustomPipelineSpecProcessorPipelineProcessorUserAgentParserCodec) IsEmpty

type CustomPipelineSpecProcessorServiceRemapper

type CustomPipelineSpecProcessorServiceRemapper struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
}

func (*CustomPipelineSpecProcessorServiceRemapper) DeepCopy

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

func (*CustomPipelineSpecProcessorServiceRemapper) DeepCopyInto

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

type CustomPipelineSpecProcessorServiceRemapperCodec

type CustomPipelineSpecProcessorServiceRemapperCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorServiceRemapperCodec) Decode

func (CustomPipelineSpecProcessorServiceRemapperCodec) Encode

func (CustomPipelineSpecProcessorServiceRemapperCodec) IsEmpty

type CustomPipelineSpecProcessorStatusRemapper

type CustomPipelineSpecProcessorStatusRemapper struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
}

func (*CustomPipelineSpecProcessorStatusRemapper) DeepCopy

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

func (*CustomPipelineSpecProcessorStatusRemapper) DeepCopyInto

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

type CustomPipelineSpecProcessorStatusRemapperCodec

type CustomPipelineSpecProcessorStatusRemapperCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorStatusRemapperCodec) Decode

func (CustomPipelineSpecProcessorStatusRemapperCodec) Encode

func (CustomPipelineSpecProcessorStatusRemapperCodec) IsEmpty

type CustomPipelineSpecProcessorStringBuilderProcessor

type CustomPipelineSpecProcessorStringBuilderProcessor struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// If it replaces all missing attributes of template by an empty string.
	// +optional
	IsReplaceMissing *bool `json:"isReplaceMissing,omitempty" tf:"is_replace_missing"`
	// The name of the processor.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// The name of the attribute that contains the result of the template.
	Target *string `json:"target" tf:"target"`
	// The formula with one or more attributes and raw text.
	Template *string `json:"template" tf:"template"`
}

func (*CustomPipelineSpecProcessorStringBuilderProcessor) DeepCopy

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

func (*CustomPipelineSpecProcessorStringBuilderProcessor) DeepCopyInto

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

type CustomPipelineSpecProcessorStringBuilderProcessorCodec

type CustomPipelineSpecProcessorStringBuilderProcessorCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorStringBuilderProcessorCodec) Decode

func (CustomPipelineSpecProcessorStringBuilderProcessorCodec) Encode

func (CustomPipelineSpecProcessorStringBuilderProcessorCodec) IsEmpty

type CustomPipelineSpecProcessorTraceIDRemapper

type CustomPipelineSpecProcessorTraceIDRemapper struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
}

func (*CustomPipelineSpecProcessorTraceIDRemapper) DeepCopy

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

func (*CustomPipelineSpecProcessorTraceIDRemapper) DeepCopyInto

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

type CustomPipelineSpecProcessorTraceIDRemapperCodec

type CustomPipelineSpecProcessorTraceIDRemapperCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorTraceIDRemapperCodec) Decode

func (CustomPipelineSpecProcessorTraceIDRemapperCodec) Encode

func (CustomPipelineSpecProcessorTraceIDRemapperCodec) IsEmpty

type CustomPipelineSpecProcessorUrlParser

type CustomPipelineSpecProcessorUrlParser struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// Name of the processor
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// Normalize the ending slashes or not.
	// +optional
	NormalizeEndingSlashes *bool `json:"normalizeEndingSlashes,omitempty" tf:"normalize_ending_slashes"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
	// Name of the parent attribute that contains all the extracted details from the sources.
	Target *string `json:"target" tf:"target"`
}

func (*CustomPipelineSpecProcessorUrlParser) DeepCopy

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

func (*CustomPipelineSpecProcessorUrlParser) DeepCopyInto

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

type CustomPipelineSpecProcessorUrlParserCodec

type CustomPipelineSpecProcessorUrlParserCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorUrlParserCodec) Decode

func (CustomPipelineSpecProcessorUrlParserCodec) Encode

func (CustomPipelineSpecProcessorUrlParserCodec) IsEmpty

type CustomPipelineSpecProcessorUserAgentParser

type CustomPipelineSpecProcessorUserAgentParser struct {
	// If the processor is enabled or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// If the source attribute is URL encoded or not.
	// +optional
	IsEncoded *bool `json:"isEncoded,omitempty" tf:"is_encoded"`
	// Name of the processor
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// List of source attributes.
	Sources []string `json:"sources" tf:"sources"`
	// Name of the parent attribute that contains all the extracted details from the sources.
	Target *string `json:"target" tf:"target"`
}

func (*CustomPipelineSpecProcessorUserAgentParser) DeepCopy

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

func (*CustomPipelineSpecProcessorUserAgentParser) DeepCopyInto

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

type CustomPipelineSpecProcessorUserAgentParserCodec

type CustomPipelineSpecProcessorUserAgentParserCodec struct {
}

+k8s:deepcopy-gen=false

func (CustomPipelineSpecProcessorUserAgentParserCodec) Decode

func (CustomPipelineSpecProcessorUserAgentParserCodec) Encode

func (CustomPipelineSpecProcessorUserAgentParserCodec) IsEmpty

type CustomPipelineSpecResource

type CustomPipelineSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	Filter []CustomPipelineSpecFilter `json:"filter" tf:"filter"`
	// +optional
	IsEnabled *bool   `json:"isEnabled,omitempty" tf:"is_enabled"`
	Name      *string `json:"name" tf:"name"`
	// +optional
	Processor []CustomPipelineSpecProcessor `json:"processor,omitempty" tf:"processor"`
}

func (*CustomPipelineSpecResource) DeepCopy

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

func (*CustomPipelineSpecResource) DeepCopyInto

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

type CustomPipelineStatus

type CustomPipelineStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*CustomPipelineStatus) DeepCopy

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

func (*CustomPipelineStatus) DeepCopyInto

func (in *CustomPipelineStatus) DeepCopyInto(out *CustomPipelineStatus)

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

type Index

type Index struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              IndexSpec   `json:"spec,omitempty"`
	Status            IndexStatus `json:"status,omitempty"`
}

func (*Index) DeepCopy

func (in *Index) DeepCopy() *Index

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

func (*Index) DeepCopyInto

func (in *Index) DeepCopyInto(out *Index)

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

func (*Index) DeepCopyObject

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

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

func (*Index) SetupWebhookWithManager

func (r *Index) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Index) ValidateCreate

func (r *Index) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Index) ValidateDelete

func (r *Index) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Index) ValidateUpdate

func (r *Index) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type IndexList

type IndexList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of Index CRD objects
	Items []Index `json:"items,omitempty"`
}

IndexList is a list of Indexs

func (*IndexList) DeepCopy

func (in *IndexList) DeepCopy() *IndexList

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

func (*IndexList) DeepCopyInto

func (in *IndexList) DeepCopyInto(out *IndexList)

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

func (*IndexList) DeepCopyObject

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

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

type IndexOrder

type IndexOrder struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              IndexOrderSpec   `json:"spec,omitempty"`
	Status            IndexOrderStatus `json:"status,omitempty"`
}

func (*IndexOrder) DeepCopy

func (in *IndexOrder) DeepCopy() *IndexOrder

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

func (*IndexOrder) DeepCopyInto

func (in *IndexOrder) DeepCopyInto(out *IndexOrder)

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

func (*IndexOrder) DeepCopyObject

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

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

func (*IndexOrder) SetupWebhookWithManager

func (r *IndexOrder) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*IndexOrder) ValidateCreate

func (r *IndexOrder) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*IndexOrder) ValidateDelete

func (r *IndexOrder) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*IndexOrder) ValidateUpdate

func (r *IndexOrder) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type IndexOrderList

type IndexOrderList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of IndexOrder CRD objects
	Items []IndexOrder `json:"items,omitempty"`
}

IndexOrderList is a list of IndexOrders

func (*IndexOrderList) DeepCopy

func (in *IndexOrderList) DeepCopy() *IndexOrderList

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

func (*IndexOrderList) DeepCopyInto

func (in *IndexOrderList) DeepCopyInto(out *IndexOrderList)

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

func (*IndexOrderList) DeepCopyObject

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

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

type IndexOrderSpec

type IndexOrderSpec struct {
	State *IndexOrderSpecResource `json:"state,omitempty" tf:"-"`

	Resource IndexOrderSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*IndexOrderSpec) DeepCopy

func (in *IndexOrderSpec) DeepCopy() *IndexOrderSpec

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

func (*IndexOrderSpec) DeepCopyInto

func (in *IndexOrderSpec) DeepCopyInto(out *IndexOrderSpec)

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

type IndexOrderSpecResource

type IndexOrderSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// The index resource list. Logs are tested against the query filter of each index one by one following the order of the list.
	Indexes []string `json:"indexes" tf:"indexes"`
	// The unique name of the index order resource.
	Name *string `json:"name" tf:"name"`
}

func (*IndexOrderSpecResource) DeepCopy

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

func (*IndexOrderSpecResource) DeepCopyInto

func (in *IndexOrderSpecResource) DeepCopyInto(out *IndexOrderSpecResource)

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

type IndexOrderStatus

type IndexOrderStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*IndexOrderStatus) DeepCopy

func (in *IndexOrderStatus) DeepCopy() *IndexOrderStatus

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

func (*IndexOrderStatus) DeepCopyInto

func (in *IndexOrderStatus) DeepCopyInto(out *IndexOrderStatus)

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

type IndexSpec

type IndexSpec struct {
	State *IndexSpecResource `json:"state,omitempty" tf:"-"`

	Resource IndexSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*IndexSpec) DeepCopy

func (in *IndexSpec) DeepCopy() *IndexSpec

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

func (*IndexSpec) DeepCopyInto

func (in *IndexSpec) DeepCopyInto(out *IndexSpec)

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

type IndexSpecExclusionFilter

type IndexSpecExclusionFilter struct {
	// +optional
	Filter []IndexSpecExclusionFilterFilter `json:"filter,omitempty" tf:"filter"`
	// A boolean stating if the exclusion is active or not.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
	// The name of the exclusion filter.
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
}

func (*IndexSpecExclusionFilter) DeepCopy

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

func (*IndexSpecExclusionFilter) DeepCopyInto

func (in *IndexSpecExclusionFilter) DeepCopyInto(out *IndexSpecExclusionFilter)

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

type IndexSpecExclusionFilterFilter

type IndexSpecExclusionFilterFilter struct {
	// Only logs matching the filter criteria and the query of the parent index will be considered for this exclusion filter.
	// +optional
	Query *string `json:"query,omitempty" tf:"query"`
	// The fraction of logs excluded by the exclusion filter, when active.
	// +optional
	SampleRate *float64 `json:"sampleRate,omitempty" tf:"sample_rate"`
}

func (*IndexSpecExclusionFilterFilter) DeepCopy

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

func (*IndexSpecExclusionFilterFilter) DeepCopyInto

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

type IndexSpecFilter

type IndexSpecFilter struct {
	// Logs filter criteria. Only logs matching this filter criteria are considered for this index.
	Query *string `json:"query" tf:"query"`
}

func (*IndexSpecFilter) DeepCopy

func (in *IndexSpecFilter) DeepCopy() *IndexSpecFilter

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

func (*IndexSpecFilter) DeepCopyInto

func (in *IndexSpecFilter) DeepCopyInto(out *IndexSpecFilter)

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

type IndexSpecFilterCodec added in v0.4.0

type IndexSpecFilterCodec struct {
}

+k8s:deepcopy-gen=false

func (IndexSpecFilterCodec) Decode added in v0.4.0

func (IndexSpecFilterCodec) Encode added in v0.4.0

func (IndexSpecFilterCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (IndexSpecFilterCodec) IsEmpty added in v0.4.0

func (IndexSpecFilterCodec) IsEmpty(ptr unsafe.Pointer) bool

type IndexSpecResource

type IndexSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// The number of log events you can send in this index per day before you are rate-limited.
	// +optional
	DailyLimit *int64 `json:"dailyLimit,omitempty" tf:"daily_limit"`
	// If true, sets the daily_limit value to null and the index is not limited on a daily basis (any specified daily_limit value in the request is ignored). If false or omitted, the index's current daily_limit is maintained.
	// +optional
	DisableDailyLimit *bool `json:"disableDailyLimit,omitempty" tf:"disable_daily_limit"`
	// List of exclusion filters.
	// +optional
	ExclusionFilter []IndexSpecExclusionFilter `json:"exclusionFilter,omitempty" tf:"exclusion_filter"`
	// Logs filter
	Filter *IndexSpecFilter `json:"filter" tf:"filter"`
	// The name of the index.
	Name *string `json:"name" tf:"name"`
	// The number of days before logs are deleted from this index.
	// +optional
	RetentionDays *int64 `json:"retentionDays,omitempty" tf:"retention_days"`
}

func (*IndexSpecResource) DeepCopy

func (in *IndexSpecResource) DeepCopy() *IndexSpecResource

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

func (*IndexSpecResource) DeepCopyInto

func (in *IndexSpecResource) DeepCopyInto(out *IndexSpecResource)

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

type IndexStatus

type IndexStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*IndexStatus) DeepCopy

func (in *IndexStatus) DeepCopy() *IndexStatus

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

func (*IndexStatus) DeepCopyInto

func (in *IndexStatus) DeepCopyInto(out *IndexStatus)

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

type IntegrationPipeline

type IntegrationPipeline struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              IntegrationPipelineSpec   `json:"spec,omitempty"`
	Status            IntegrationPipelineStatus `json:"status,omitempty"`
}

func (*IntegrationPipeline) DeepCopy

func (in *IntegrationPipeline) DeepCopy() *IntegrationPipeline

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

func (*IntegrationPipeline) DeepCopyInto

func (in *IntegrationPipeline) DeepCopyInto(out *IntegrationPipeline)

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

func (*IntegrationPipeline) DeepCopyObject

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

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

func (*IntegrationPipeline) SetupWebhookWithManager

func (r *IntegrationPipeline) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*IntegrationPipeline) ValidateCreate

func (r *IntegrationPipeline) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*IntegrationPipeline) ValidateDelete

func (r *IntegrationPipeline) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*IntegrationPipeline) ValidateUpdate

func (r *IntegrationPipeline) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type IntegrationPipelineList

type IntegrationPipelineList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of IntegrationPipeline CRD objects
	Items []IntegrationPipeline `json:"items,omitempty"`
}

IntegrationPipelineList is a list of IntegrationPipelines

func (*IntegrationPipelineList) DeepCopy

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

func (*IntegrationPipelineList) DeepCopyInto

func (in *IntegrationPipelineList) DeepCopyInto(out *IntegrationPipelineList)

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

func (*IntegrationPipelineList) DeepCopyObject

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

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

type IntegrationPipelineSpec

type IntegrationPipelineSpec struct {
	State *IntegrationPipelineSpecResource `json:"state,omitempty" tf:"-"`

	Resource IntegrationPipelineSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*IntegrationPipelineSpec) DeepCopy

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

func (*IntegrationPipelineSpec) DeepCopyInto

func (in *IntegrationPipelineSpec) DeepCopyInto(out *IntegrationPipelineSpec)

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

type IntegrationPipelineSpecResource

type IntegrationPipelineSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// Boolean value to enable your pipeline.
	// +optional
	IsEnabled *bool `json:"isEnabled,omitempty" tf:"is_enabled"`
}

func (*IntegrationPipelineSpecResource) DeepCopy

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

func (*IntegrationPipelineSpecResource) DeepCopyInto

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

type IntegrationPipelineStatus

type IntegrationPipelineStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*IntegrationPipelineStatus) DeepCopy

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

func (*IntegrationPipelineStatus) DeepCopyInto

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

type Metric

type Metric struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              MetricSpec   `json:"spec,omitempty"`
	Status            MetricStatus `json:"status,omitempty"`
}

func (*Metric) DeepCopy

func (in *Metric) DeepCopy() *Metric

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

func (*Metric) DeepCopyInto

func (in *Metric) DeepCopyInto(out *Metric)

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

func (*Metric) DeepCopyObject

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

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

func (*Metric) SetupWebhookWithManager

func (r *Metric) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Metric) ValidateCreate

func (r *Metric) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Metric) ValidateDelete

func (r *Metric) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Metric) ValidateUpdate

func (r *Metric) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type MetricList

type MetricList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of Metric CRD objects
	Items []Metric `json:"items,omitempty"`
}

MetricList is a list of Metrics

func (*MetricList) DeepCopy

func (in *MetricList) DeepCopy() *MetricList

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

func (*MetricList) DeepCopyInto

func (in *MetricList) DeepCopyInto(out *MetricList)

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

func (*MetricList) DeepCopyObject

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

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

type MetricSpec

type MetricSpec struct {
	State *MetricSpecResource `json:"state,omitempty" tf:"-"`

	Resource MetricSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*MetricSpec) DeepCopy

func (in *MetricSpec) DeepCopy() *MetricSpec

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

func (*MetricSpec) DeepCopyInto

func (in *MetricSpec) DeepCopyInto(out *MetricSpec)

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

type MetricSpecCompute

type MetricSpecCompute struct {
	// The type of aggregation to use. This field can't be updated after creation.
	AggregationType *string `json:"aggregationType" tf:"aggregation_type"`
	// The path to the value the log-based metric will aggregate on (only used if the aggregation type is a "distribution"). This field can't be updated after creation.
	// +optional
	Path *string `json:"path,omitempty" tf:"path"`
}

func (*MetricSpecCompute) DeepCopy

func (in *MetricSpecCompute) DeepCopy() *MetricSpecCompute

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

func (*MetricSpecCompute) DeepCopyInto

func (in *MetricSpecCompute) DeepCopyInto(out *MetricSpecCompute)

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

type MetricSpecComputeCodec

type MetricSpecComputeCodec struct {
}

+k8s:deepcopy-gen=false

func (MetricSpecComputeCodec) Decode

func (MetricSpecComputeCodec) Encode

func (MetricSpecComputeCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (MetricSpecComputeCodec) IsEmpty

type MetricSpecFilter

type MetricSpecFilter struct {
	// The search query - following the log search syntax.
	Query *string `json:"query" tf:"query"`
}

func (*MetricSpecFilter) DeepCopy

func (in *MetricSpecFilter) DeepCopy() *MetricSpecFilter

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

func (*MetricSpecFilter) DeepCopyInto

func (in *MetricSpecFilter) DeepCopyInto(out *MetricSpecFilter)

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

type MetricSpecFilterCodec

type MetricSpecFilterCodec struct {
}

+k8s:deepcopy-gen=false

func (MetricSpecFilterCodec) Decode

func (MetricSpecFilterCodec) Encode

func (MetricSpecFilterCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

func (MetricSpecFilterCodec) IsEmpty

type MetricSpecGroupBy

type MetricSpecGroupBy struct {
	// The path to the value the log-based metric will be aggregated over.
	Path *string `json:"path" tf:"path"`
	// Name of the tag that gets created.
	TagName *string `json:"tagName" tf:"tag_name"`
}

func (*MetricSpecGroupBy) DeepCopy

func (in *MetricSpecGroupBy) DeepCopy() *MetricSpecGroupBy

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

func (*MetricSpecGroupBy) DeepCopyInto

func (in *MetricSpecGroupBy) DeepCopyInto(out *MetricSpecGroupBy)

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

type MetricSpecResource

type MetricSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// The compute rule to compute the log-based metric. This field can't be updated after creation.
	Compute *MetricSpecCompute `json:"compute" tf:"compute"`
	// The log-based metric filter. Logs matching this filter will be aggregated in this metric.
	Filter *MetricSpecFilter `json:"filter" tf:"filter"`
	// The rules for the group by.
	// +optional
	GroupBy []MetricSpecGroupBy `json:"groupBy,omitempty" tf:"group_by"`
	// The name of the log-based metric. This field can't be updated after creation.
	Name *string `json:"name" tf:"name"`
}

func (*MetricSpecResource) DeepCopy

func (in *MetricSpecResource) DeepCopy() *MetricSpecResource

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

func (*MetricSpecResource) DeepCopyInto

func (in *MetricSpecResource) DeepCopyInto(out *MetricSpecResource)

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

type MetricStatus

type MetricStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*MetricStatus) DeepCopy

func (in *MetricStatus) DeepCopy() *MetricStatus

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

func (*MetricStatus) DeepCopyInto

func (in *MetricStatus) DeepCopyInto(out *MetricStatus)

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

type PipelineOrder

type PipelineOrder struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              PipelineOrderSpec   `json:"spec,omitempty"`
	Status            PipelineOrderStatus `json:"status,omitempty"`
}

func (*PipelineOrder) DeepCopy

func (in *PipelineOrder) DeepCopy() *PipelineOrder

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

func (*PipelineOrder) DeepCopyInto

func (in *PipelineOrder) DeepCopyInto(out *PipelineOrder)

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

func (*PipelineOrder) DeepCopyObject

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

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

func (*PipelineOrder) SetupWebhookWithManager

func (r *PipelineOrder) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*PipelineOrder) ValidateCreate

func (r *PipelineOrder) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*PipelineOrder) ValidateDelete

func (r *PipelineOrder) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*PipelineOrder) ValidateUpdate

func (r *PipelineOrder) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type PipelineOrderList

type PipelineOrderList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of PipelineOrder CRD objects
	Items []PipelineOrder `json:"items,omitempty"`
}

PipelineOrderList is a list of PipelineOrders

func (*PipelineOrderList) DeepCopy

func (in *PipelineOrderList) DeepCopy() *PipelineOrderList

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

func (*PipelineOrderList) DeepCopyInto

func (in *PipelineOrderList) DeepCopyInto(out *PipelineOrderList)

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

func (*PipelineOrderList) DeepCopyObject

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

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

type PipelineOrderSpec

type PipelineOrderSpec struct {
	State *PipelineOrderSpecResource `json:"state,omitempty" tf:"-"`

	Resource PipelineOrderSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*PipelineOrderSpec) DeepCopy

func (in *PipelineOrderSpec) DeepCopy() *PipelineOrderSpec

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

func (*PipelineOrderSpec) DeepCopyInto

func (in *PipelineOrderSpec) DeepCopyInto(out *PipelineOrderSpec)

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

type PipelineOrderSpecResource

type PipelineOrderSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// The name attribute in the resource `datadog_logs_pipeline_order` needs to be unique. It's recommended to use the same value as the resource name. No related field is available in [Logs Pipeline API](https://docs.datadoghq.com/api/v1/logs-pipelines/#get-pipeline-order).
	Name *string `json:"name" tf:"name"`
	// The pipeline IDs list. The order of pipeline IDs in this attribute defines the overall pipeline order for logs.
	Pipelines []string `json:"pipelines" tf:"pipelines"`
}

func (*PipelineOrderSpecResource) DeepCopy

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

func (*PipelineOrderSpecResource) DeepCopyInto

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

type PipelineOrderStatus

type PipelineOrderStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*PipelineOrderStatus) DeepCopy

func (in *PipelineOrderStatus) DeepCopy() *PipelineOrderStatus

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

func (*PipelineOrderStatus) DeepCopyInto

func (in *PipelineOrderStatus) DeepCopyInto(out *PipelineOrderStatus)

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

Jump to

Keyboard shortcuts

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