Documentation
¶
Overview ¶
+groupName=logs.datadog.kubeform.com
Index ¶
- Variables
- func GetDecoder() map[string]jsoniter.ValDecoder
- func GetEncoder() map[string]jsoniter.ValEncoder
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- type Archive
- func (in *Archive) DeepCopy() *Archive
- func (in *Archive) DeepCopyInto(out *Archive)
- func (in *Archive) DeepCopyObject() runtime.Object
- func (r *Archive) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *Archive) ValidateCreate() error
- func (r *Archive) ValidateDelete() error
- func (r *Archive) ValidateUpdate(old runtime.Object) error
- type ArchiveList
- type ArchiveOrder
- func (in *ArchiveOrder) DeepCopy() *ArchiveOrder
- func (in *ArchiveOrder) DeepCopyInto(out *ArchiveOrder)
- func (in *ArchiveOrder) DeepCopyObject() runtime.Object
- func (r *ArchiveOrder) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *ArchiveOrder) ValidateCreate() error
- func (r *ArchiveOrder) ValidateDelete() error
- func (r *ArchiveOrder) ValidateUpdate(old runtime.Object) error
- type ArchiveOrderList
- type ArchiveOrderSpec
- type ArchiveOrderSpecResource
- type ArchiveOrderStatus
- type ArchiveSpec
- type ArchiveSpecAzureArchive
- type ArchiveSpecAzureArchiveCodec
- type ArchiveSpecGcsArchive
- type ArchiveSpecGcsArchiveCodec
- type ArchiveSpecResource
- type ArchiveSpecS3Archive
- type ArchiveSpecS3ArchiveCodec
- type ArchiveStatus
- type CustomPipeline
- func (in *CustomPipeline) DeepCopy() *CustomPipeline
- func (in *CustomPipeline) DeepCopyInto(out *CustomPipeline)
- func (in *CustomPipeline) DeepCopyObject() runtime.Object
- func (r *CustomPipeline) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *CustomPipeline) ValidateCreate() error
- func (r *CustomPipeline) ValidateDelete() error
- func (r *CustomPipeline) ValidateUpdate(old runtime.Object) error
- type CustomPipelineList
- type CustomPipelineSpec
- type CustomPipelineSpecFilter
- type CustomPipelineSpecProcessor
- type CustomPipelineSpecProcessorArithmeticProcessor
- type CustomPipelineSpecProcessorArithmeticProcessorCodec
- func (CustomPipelineSpecProcessorArithmeticProcessorCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorArithmeticProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorArithmeticProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorAttributeRemapper
- type CustomPipelineSpecProcessorAttributeRemapperCodec
- func (CustomPipelineSpecProcessorAttributeRemapperCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorAttributeRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorAttributeRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorCategoryProcessor
- type CustomPipelineSpecProcessorCategoryProcessorCategory
- type CustomPipelineSpecProcessorCategoryProcessorCategoryFilter
- type CustomPipelineSpecProcessorCategoryProcessorCategoryFilterCodec
- func (CustomPipelineSpecProcessorCategoryProcessorCategoryFilterCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorCategoryProcessorCategoryFilterCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorCategoryProcessorCategoryFilterCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorCategoryProcessorCodec
- func (CustomPipelineSpecProcessorCategoryProcessorCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorCategoryProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorCategoryProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorDateRemapper
- type CustomPipelineSpecProcessorDateRemapperCodec
- type CustomPipelineSpecProcessorGeoIPParser
- type CustomPipelineSpecProcessorGeoIPParserCodec
- type CustomPipelineSpecProcessorGrokParser
- type CustomPipelineSpecProcessorGrokParserCodec
- type CustomPipelineSpecProcessorGrokParserGrok
- type CustomPipelineSpecProcessorGrokParserGrokCodec
- type CustomPipelineSpecProcessorLookupProcessor
- type CustomPipelineSpecProcessorLookupProcessorCodec
- func (CustomPipelineSpecProcessorLookupProcessorCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorLookupProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorLookupProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorMessageRemapper
- type CustomPipelineSpecProcessorMessageRemapperCodec
- func (CustomPipelineSpecProcessorMessageRemapperCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorMessageRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorMessageRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipeline
- type CustomPipelineSpecProcessorPipelineCodec
- type CustomPipelineSpecProcessorPipelineFilter
- type CustomPipelineSpecProcessorPipelineProcessor
- type CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor
- func (in *CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor
- func (in *CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor)
- type CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessorCodec
- func (CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessorCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper
- func (in *CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper
- func (in *CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper)
- type CustomPipelineSpecProcessorPipelineProcessorAttributeRemapperCodec
- func (CustomPipelineSpecProcessorPipelineProcessorAttributeRemapperCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorAttributeRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorAttributeRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor
- func (in *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor
- func (in *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor)
- type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory
- func (in *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory
- func (in *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory)
- type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilter
- type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilterCodec
- func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilterCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilterCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilterCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec
- func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorDateRemapper
- type CustomPipelineSpecProcessorPipelineProcessorDateRemapperCodec
- func (CustomPipelineSpecProcessorPipelineProcessorDateRemapperCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorDateRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorDateRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorGeoIPParser
- type CustomPipelineSpecProcessorPipelineProcessorGeoIPParserCodec
- func (CustomPipelineSpecProcessorPipelineProcessorGeoIPParserCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorGeoIPParserCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorGeoIPParserCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorGrokParser
- type CustomPipelineSpecProcessorPipelineProcessorGrokParserCodec
- func (CustomPipelineSpecProcessorPipelineProcessorGrokParserCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorGrokParserCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorGrokParserCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorGrokParserGrok
- type CustomPipelineSpecProcessorPipelineProcessorGrokParserGrokCodec
- func (CustomPipelineSpecProcessorPipelineProcessorGrokParserGrokCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorGrokParserGrokCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorGrokParserGrokCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorLookupProcessor
- type CustomPipelineSpecProcessorPipelineProcessorLookupProcessorCodec
- func (CustomPipelineSpecProcessorPipelineProcessorLookupProcessorCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorLookupProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorLookupProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorMessageRemapper
- type CustomPipelineSpecProcessorPipelineProcessorMessageRemapperCodec
- func (CustomPipelineSpecProcessorPipelineProcessorMessageRemapperCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorMessageRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorMessageRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorServiceRemapper
- type CustomPipelineSpecProcessorPipelineProcessorServiceRemapperCodec
- func (CustomPipelineSpecProcessorPipelineProcessorServiceRemapperCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorServiceRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorServiceRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorStatusRemapper
- type CustomPipelineSpecProcessorPipelineProcessorStatusRemapperCodec
- func (CustomPipelineSpecProcessorPipelineProcessorStatusRemapperCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorStatusRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorStatusRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor
- func (in *CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor
- func (in *CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor)
- type CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessorCodec
- func (CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessorCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapper
- type CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapperCodec
- func (CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapperCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorUrlParser
- type CustomPipelineSpecProcessorPipelineProcessorUrlParserCodec
- func (CustomPipelineSpecProcessorPipelineProcessorUrlParserCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorUrlParserCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorUrlParserCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorPipelineProcessorUserAgentParser
- type CustomPipelineSpecProcessorPipelineProcessorUserAgentParserCodec
- func (CustomPipelineSpecProcessorPipelineProcessorUserAgentParserCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorPipelineProcessorUserAgentParserCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorPipelineProcessorUserAgentParserCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorServiceRemapper
- type CustomPipelineSpecProcessorServiceRemapperCodec
- func (CustomPipelineSpecProcessorServiceRemapperCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorServiceRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorServiceRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorStatusRemapper
- type CustomPipelineSpecProcessorStatusRemapperCodec
- type CustomPipelineSpecProcessorStringBuilderProcessor
- type CustomPipelineSpecProcessorStringBuilderProcessorCodec
- func (CustomPipelineSpecProcessorStringBuilderProcessorCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorStringBuilderProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorStringBuilderProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorTraceIDRemapper
- type CustomPipelineSpecProcessorTraceIDRemapperCodec
- func (CustomPipelineSpecProcessorTraceIDRemapperCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorTraceIDRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorTraceIDRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecProcessorUrlParser
- type CustomPipelineSpecProcessorUrlParserCodec
- type CustomPipelineSpecProcessorUserAgentParser
- type CustomPipelineSpecProcessorUserAgentParserCodec
- func (CustomPipelineSpecProcessorUserAgentParserCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
- func (CustomPipelineSpecProcessorUserAgentParserCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
- func (CustomPipelineSpecProcessorUserAgentParserCodec) IsEmpty(ptr unsafe.Pointer) bool
- type CustomPipelineSpecResource
- type CustomPipelineStatus
- type Index
- func (in *Index) DeepCopy() *Index
- func (in *Index) DeepCopyInto(out *Index)
- func (in *Index) DeepCopyObject() runtime.Object
- func (r *Index) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *Index) ValidateCreate() error
- func (r *Index) ValidateDelete() error
- func (r *Index) ValidateUpdate(old runtime.Object) error
- type IndexList
- type IndexOrder
- func (in *IndexOrder) DeepCopy() *IndexOrder
- func (in *IndexOrder) DeepCopyInto(out *IndexOrder)
- func (in *IndexOrder) DeepCopyObject() runtime.Object
- func (r *IndexOrder) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *IndexOrder) ValidateCreate() error
- func (r *IndexOrder) ValidateDelete() error
- func (r *IndexOrder) ValidateUpdate(old runtime.Object) error
- type IndexOrderList
- type IndexOrderSpec
- type IndexOrderSpecResource
- type IndexOrderStatus
- type IndexSpec
- type IndexSpecExclusionFilter
- type IndexSpecExclusionFilterFilter
- type IndexSpecFilter
- type IndexSpecFilterCodec
- type IndexSpecResource
- type IndexStatus
- type IntegrationPipeline
- func (in *IntegrationPipeline) DeepCopy() *IntegrationPipeline
- func (in *IntegrationPipeline) DeepCopyInto(out *IntegrationPipeline)
- func (in *IntegrationPipeline) DeepCopyObject() runtime.Object
- func (r *IntegrationPipeline) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *IntegrationPipeline) ValidateCreate() error
- func (r *IntegrationPipeline) ValidateDelete() error
- func (r *IntegrationPipeline) ValidateUpdate(old runtime.Object) error
- type IntegrationPipelineList
- type IntegrationPipelineSpec
- type IntegrationPipelineSpecResource
- type IntegrationPipelineStatus
- type Metric
- func (in *Metric) DeepCopy() *Metric
- func (in *Metric) DeepCopyInto(out *Metric)
- func (in *Metric) DeepCopyObject() runtime.Object
- func (r *Metric) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *Metric) ValidateCreate() error
- func (r *Metric) ValidateDelete() error
- func (r *Metric) ValidateUpdate(old runtime.Object) error
- type MetricList
- type MetricSpec
- type MetricSpecCompute
- type MetricSpecComputeCodec
- type MetricSpecFilter
- type MetricSpecFilterCodec
- type MetricSpecGroupBy
- type MetricSpecResource
- type MetricStatus
- type PipelineOrder
- func (in *PipelineOrder) DeepCopy() *PipelineOrder
- func (in *PipelineOrder) DeepCopyInto(out *PipelineOrder)
- func (in *PipelineOrder) DeepCopyObject() runtime.Object
- func (r *PipelineOrder) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *PipelineOrder) ValidateCreate() error
- func (r *PipelineOrder) ValidateDelete() error
- func (r *PipelineOrder) ValidateUpdate(old runtime.Object) error
- type PipelineOrderList
- type PipelineOrderSpec
- type PipelineOrderSpecResource
- type PipelineOrderStatus
Constants ¶
This section is empty.
Variables ¶
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 )
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 ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Archive.
func (*Archive) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Archive) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Archive) SetupWebhookWithManager ¶
func (*Archive) ValidateCreate ¶
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*Archive) ValidateDelete ¶
ValidateDelete 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 ¶
func (in *ArchiveOrderSpecResource) DeepCopy() *ArchiveOrderSpecResource
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 ¶
func (in *ArchiveSpecAzureArchive) DeepCopy() *ArchiveSpecAzureArchive
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (ArchiveSpecAzureArchiveCodec) Encode ¶
func (ArchiveSpecAzureArchiveCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (ArchiveSpecAzureArchiveCodec) IsEmpty ¶
func (ArchiveSpecAzureArchiveCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *ArchiveSpecGcsArchive) DeepCopy() *ArchiveSpecGcsArchive
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (ArchiveSpecGcsArchiveCodec) Encode ¶
func (ArchiveSpecGcsArchiveCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (ArchiveSpecGcsArchiveCodec) IsEmpty ¶
func (ArchiveSpecGcsArchiveCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *ArchiveSpecS3Archive) DeepCopy() *ArchiveSpecS3Archive
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (ArchiveSpecS3ArchiveCodec) Encode ¶
func (ArchiveSpecS3ArchiveCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (ArchiveSpecS3ArchiveCodec) IsEmpty ¶
func (ArchiveSpecS3ArchiveCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecFilter) DeepCopy() *CustomPipelineSpecFilter
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 ¶
func (in *CustomPipelineSpecProcessor) DeepCopy() *CustomPipelineSpecProcessor
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessor.
func (*CustomPipelineSpecProcessor) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessor) DeepCopyInto(out *CustomPipelineSpecProcessor)
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 ¶
func (in *CustomPipelineSpecProcessorArithmeticProcessor) DeepCopy() *CustomPipelineSpecProcessorArithmeticProcessor
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorArithmeticProcessor.
func (*CustomPipelineSpecProcessorArithmeticProcessor) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorArithmeticProcessor) DeepCopyInto(out *CustomPipelineSpecProcessorArithmeticProcessor)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorArithmeticProcessorCodec) Encode ¶
func (CustomPipelineSpecProcessorArithmeticProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorArithmeticProcessorCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorArithmeticProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorAttributeRemapper) DeepCopy() *CustomPipelineSpecProcessorAttributeRemapper
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorAttributeRemapper.
func (*CustomPipelineSpecProcessorAttributeRemapper) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorAttributeRemapper) DeepCopyInto(out *CustomPipelineSpecProcessorAttributeRemapper)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorAttributeRemapperCodec) Encode ¶
func (CustomPipelineSpecProcessorAttributeRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorAttributeRemapperCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorAttributeRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorCategoryProcessor) DeepCopy() *CustomPipelineSpecProcessorCategoryProcessor
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorCategoryProcessor.
func (*CustomPipelineSpecProcessorCategoryProcessor) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorCategoryProcessor) DeepCopyInto(out *CustomPipelineSpecProcessorCategoryProcessor)
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 ¶
func (in *CustomPipelineSpecProcessorCategoryProcessorCategory) DeepCopy() *CustomPipelineSpecProcessorCategoryProcessorCategory
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorCategoryProcessorCategory.
func (*CustomPipelineSpecProcessorCategoryProcessorCategory) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorCategoryProcessorCategory) DeepCopyInto(out *CustomPipelineSpecProcessorCategoryProcessorCategory)
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 ¶
func (in *CustomPipelineSpecProcessorCategoryProcessorCategoryFilter) DeepCopy() *CustomPipelineSpecProcessorCategoryProcessorCategoryFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorCategoryProcessorCategoryFilter.
func (*CustomPipelineSpecProcessorCategoryProcessorCategoryFilter) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorCategoryProcessorCategoryFilter) DeepCopyInto(out *CustomPipelineSpecProcessorCategoryProcessorCategoryFilter)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorCategoryProcessorCategoryFilterCodec) Encode ¶
func (CustomPipelineSpecProcessorCategoryProcessorCategoryFilterCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorCategoryProcessorCategoryFilterCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorCategoryProcessorCategoryFilterCodec) IsEmpty(ptr unsafe.Pointer) bool
type CustomPipelineSpecProcessorCategoryProcessorCodec ¶
type CustomPipelineSpecProcessorCategoryProcessorCodec struct { }
+k8s:deepcopy-gen=false
func (CustomPipelineSpecProcessorCategoryProcessorCodec) Decode ¶
func (CustomPipelineSpecProcessorCategoryProcessorCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorCategoryProcessorCodec) Encode ¶
func (CustomPipelineSpecProcessorCategoryProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorCategoryProcessorCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorCategoryProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorDateRemapper) DeepCopy() *CustomPipelineSpecProcessorDateRemapper
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorDateRemapper.
func (*CustomPipelineSpecProcessorDateRemapper) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorDateRemapper) DeepCopyInto(out *CustomPipelineSpecProcessorDateRemapper)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorDateRemapperCodec) Encode ¶
func (CustomPipelineSpecProcessorDateRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorDateRemapperCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorDateRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorGeoIPParser) DeepCopy() *CustomPipelineSpecProcessorGeoIPParser
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorGeoIPParser.
func (*CustomPipelineSpecProcessorGeoIPParser) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorGeoIPParser) DeepCopyInto(out *CustomPipelineSpecProcessorGeoIPParser)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorGeoIPParserCodec) Encode ¶
func (CustomPipelineSpecProcessorGeoIPParserCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorGeoIPParserCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorGeoIPParserCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorGrokParser) DeepCopy() *CustomPipelineSpecProcessorGrokParser
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorGrokParser.
func (*CustomPipelineSpecProcessorGrokParser) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorGrokParser) DeepCopyInto(out *CustomPipelineSpecProcessorGrokParser)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorGrokParserCodec) Encode ¶
func (CustomPipelineSpecProcessorGrokParserCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorGrokParserCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorGrokParserCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorGrokParserGrok) DeepCopy() *CustomPipelineSpecProcessorGrokParserGrok
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorGrokParserGrok.
func (*CustomPipelineSpecProcessorGrokParserGrok) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorGrokParserGrok) DeepCopyInto(out *CustomPipelineSpecProcessorGrokParserGrok)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorGrokParserGrokCodec) Encode ¶
func (CustomPipelineSpecProcessorGrokParserGrokCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorGrokParserGrokCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorGrokParserGrokCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorLookupProcessor) DeepCopy() *CustomPipelineSpecProcessorLookupProcessor
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorLookupProcessor.
func (*CustomPipelineSpecProcessorLookupProcessor) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorLookupProcessor) DeepCopyInto(out *CustomPipelineSpecProcessorLookupProcessor)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorLookupProcessorCodec) Encode ¶
func (CustomPipelineSpecProcessorLookupProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorLookupProcessorCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorLookupProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorMessageRemapper) DeepCopy() *CustomPipelineSpecProcessorMessageRemapper
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorMessageRemapper.
func (*CustomPipelineSpecProcessorMessageRemapper) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorMessageRemapper) DeepCopyInto(out *CustomPipelineSpecProcessorMessageRemapper)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorMessageRemapperCodec) Encode ¶
func (CustomPipelineSpecProcessorMessageRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorMessageRemapperCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorMessageRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipeline) DeepCopy() *CustomPipelineSpecProcessorPipeline
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipeline.
func (*CustomPipelineSpecProcessorPipeline) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipeline) DeepCopyInto(out *CustomPipelineSpecProcessorPipeline)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineCodec) IsEmpty(ptr unsafe.Pointer) bool
type CustomPipelineSpecProcessorPipelineFilter ¶
type CustomPipelineSpecProcessorPipelineFilter struct { // Filter criteria of the category. Query *string `json:"query" tf:"query"` }
func (*CustomPipelineSpecProcessorPipelineFilter) DeepCopy ¶
func (in *CustomPipelineSpecProcessorPipelineFilter) DeepCopy() *CustomPipelineSpecProcessorPipelineFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineFilter.
func (*CustomPipelineSpecProcessorPipelineFilter) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineFilter) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineFilter)
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessor) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessor
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessor.
func (*CustomPipelineSpecProcessorPipelineProcessor) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessor) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessor)
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor.
func (*CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessor)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessorCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessorCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorArithmeticProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper.
func (*CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorAttributeRemapper)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorAttributeRemapperCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorAttributeRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorAttributeRemapperCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorAttributeRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor.
func (*CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessor)
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory.
func (*CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategory)
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilter) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilter.
func (*CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilter) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilter) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilter)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilterCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilterCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCategoryFilterCodec) IsEmpty ¶
type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec ¶
type CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec struct { }
+k8s:deepcopy-gen=false
func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec) Decode ¶
func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorCategoryProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorDateRemapper) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorDateRemapper
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorDateRemapper.
func (*CustomPipelineSpecProcessorPipelineProcessorDateRemapper) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorDateRemapper) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorDateRemapper)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorDateRemapperCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorDateRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorDateRemapperCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorDateRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorGeoIPParser) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorGeoIPParser
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorGeoIPParser.
func (*CustomPipelineSpecProcessorPipelineProcessorGeoIPParser) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorGeoIPParser) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorGeoIPParser)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorGeoIPParserCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorGeoIPParserCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorGeoIPParserCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorGeoIPParserCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorGrokParser) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorGrokParser
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorGrokParser.
func (*CustomPipelineSpecProcessorPipelineProcessorGrokParser) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorGrokParser) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorGrokParser)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorGrokParserCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorGrokParserCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorGrokParserCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorGrokParserCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorGrokParserGrok) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorGrokParserGrok
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorGrokParserGrok.
func (*CustomPipelineSpecProcessorPipelineProcessorGrokParserGrok) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorGrokParserGrok) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorGrokParserGrok)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorGrokParserGrokCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorGrokParserGrokCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorGrokParserGrokCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorGrokParserGrokCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorLookupProcessor) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorLookupProcessor
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorLookupProcessor.
func (*CustomPipelineSpecProcessorPipelineProcessorLookupProcessor) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorLookupProcessor) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorLookupProcessor)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorLookupProcessorCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorLookupProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorLookupProcessorCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorLookupProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorMessageRemapper) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorMessageRemapper
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorMessageRemapper.
func (*CustomPipelineSpecProcessorPipelineProcessorMessageRemapper) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorMessageRemapper) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorMessageRemapper)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorMessageRemapperCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorMessageRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorMessageRemapperCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorMessageRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorServiceRemapper) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorServiceRemapper
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorServiceRemapper.
func (*CustomPipelineSpecProcessorPipelineProcessorServiceRemapper) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorServiceRemapper) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorServiceRemapper)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorServiceRemapperCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorServiceRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorServiceRemapperCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorServiceRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorStatusRemapper) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorStatusRemapper
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorStatusRemapper.
func (*CustomPipelineSpecProcessorPipelineProcessorStatusRemapper) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorStatusRemapper) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorStatusRemapper)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorStatusRemapperCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorStatusRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorStatusRemapperCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorStatusRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor.
func (*CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessor)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessorCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessorCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorStringBuilderProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapper) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapper
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapper.
func (*CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapper) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapper) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapper)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapperCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapperCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorTraceIDRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorUrlParser) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorUrlParser
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorUrlParser.
func (*CustomPipelineSpecProcessorPipelineProcessorUrlParser) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorUrlParser) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorUrlParser)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorUrlParserCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorUrlParserCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorUrlParserCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorUrlParserCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorUserAgentParser) DeepCopy() *CustomPipelineSpecProcessorPipelineProcessorUserAgentParser
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorPipelineProcessorUserAgentParser.
func (*CustomPipelineSpecProcessorPipelineProcessorUserAgentParser) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorPipelineProcessorUserAgentParser) DeepCopyInto(out *CustomPipelineSpecProcessorPipelineProcessorUserAgentParser)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorPipelineProcessorUserAgentParserCodec) Encode ¶
func (CustomPipelineSpecProcessorPipelineProcessorUserAgentParserCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorPipelineProcessorUserAgentParserCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorPipelineProcessorUserAgentParserCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorServiceRemapper) DeepCopy() *CustomPipelineSpecProcessorServiceRemapper
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorServiceRemapper.
func (*CustomPipelineSpecProcessorServiceRemapper) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorServiceRemapper) DeepCopyInto(out *CustomPipelineSpecProcessorServiceRemapper)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorServiceRemapperCodec) Encode ¶
func (CustomPipelineSpecProcessorServiceRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorServiceRemapperCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorServiceRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorStatusRemapper) DeepCopy() *CustomPipelineSpecProcessorStatusRemapper
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorStatusRemapper.
func (*CustomPipelineSpecProcessorStatusRemapper) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorStatusRemapper) DeepCopyInto(out *CustomPipelineSpecProcessorStatusRemapper)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorStatusRemapperCodec) Encode ¶
func (CustomPipelineSpecProcessorStatusRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorStatusRemapperCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorStatusRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorStringBuilderProcessor) DeepCopy() *CustomPipelineSpecProcessorStringBuilderProcessor
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorStringBuilderProcessor.
func (*CustomPipelineSpecProcessorStringBuilderProcessor) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorStringBuilderProcessor) DeepCopyInto(out *CustomPipelineSpecProcessorStringBuilderProcessor)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorStringBuilderProcessorCodec) Encode ¶
func (CustomPipelineSpecProcessorStringBuilderProcessorCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorStringBuilderProcessorCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorStringBuilderProcessorCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorTraceIDRemapper) DeepCopy() *CustomPipelineSpecProcessorTraceIDRemapper
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorTraceIDRemapper.
func (*CustomPipelineSpecProcessorTraceIDRemapper) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorTraceIDRemapper) DeepCopyInto(out *CustomPipelineSpecProcessorTraceIDRemapper)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorTraceIDRemapperCodec) Encode ¶
func (CustomPipelineSpecProcessorTraceIDRemapperCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorTraceIDRemapperCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorTraceIDRemapperCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorUrlParser) DeepCopy() *CustomPipelineSpecProcessorUrlParser
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorUrlParser.
func (*CustomPipelineSpecProcessorUrlParser) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorUrlParser) DeepCopyInto(out *CustomPipelineSpecProcessorUrlParser)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorUrlParserCodec) Encode ¶
func (CustomPipelineSpecProcessorUrlParserCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorUrlParserCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorUrlParserCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecProcessorUserAgentParser) DeepCopy() *CustomPipelineSpecProcessorUserAgentParser
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecProcessorUserAgentParser.
func (*CustomPipelineSpecProcessorUserAgentParser) DeepCopyInto ¶
func (in *CustomPipelineSpecProcessorUserAgentParser) DeepCopyInto(out *CustomPipelineSpecProcessorUserAgentParser)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (CustomPipelineSpecProcessorUserAgentParserCodec) Encode ¶
func (CustomPipelineSpecProcessorUserAgentParserCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (CustomPipelineSpecProcessorUserAgentParserCodec) IsEmpty ¶
func (CustomPipelineSpecProcessorUserAgentParserCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *CustomPipelineSpecResource) DeepCopy() *CustomPipelineSpecResource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomPipelineSpecResource.
func (*CustomPipelineSpecResource) DeepCopyInto ¶
func (in *CustomPipelineSpecResource) DeepCopyInto(out *CustomPipelineSpecResource)
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 ¶
func (in *CustomPipelineStatus) DeepCopy() *CustomPipelineStatus
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Index.
func (*Index) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Index) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Index) SetupWebhookWithManager ¶
func (*Index) ValidateCreate ¶
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*Index) ValidateDelete ¶
ValidateDelete 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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IndexList.
func (*IndexList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
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 ¶
func (in *IndexOrderSpecResource) DeepCopy() *IndexOrderSpecResource
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IndexSpec.
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 ¶
func (in *IndexSpecExclusionFilter) DeepCopy() *IndexSpecExclusionFilter
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 ¶
func (in *IndexSpecExclusionFilterFilter) DeepCopy() *IndexSpecExclusionFilterFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IndexSpecExclusionFilterFilter.
func (*IndexSpecExclusionFilterFilter) DeepCopyInto ¶
func (in *IndexSpecExclusionFilterFilter) DeepCopyInto(out *IndexSpecExclusionFilterFilter)
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
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 ¶
func (in *IntegrationPipelineList) DeepCopy() *IntegrationPipelineList
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 ¶
func (in *IntegrationPipelineSpec) DeepCopy() *IntegrationPipelineSpec
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 ¶
func (in *IntegrationPipelineSpecResource) DeepCopy() *IntegrationPipelineSpecResource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IntegrationPipelineSpecResource.
func (*IntegrationPipelineSpecResource) DeepCopyInto ¶
func (in *IntegrationPipelineSpecResource) DeepCopyInto(out *IntegrationPipelineSpecResource)
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 ¶
func (in *IntegrationPipelineStatus) DeepCopy() *IntegrationPipelineStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IntegrationPipelineStatus.
func (*IntegrationPipelineStatus) DeepCopyInto ¶
func (in *IntegrationPipelineStatus) DeepCopyInto(out *IntegrationPipelineStatus)
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Metric.
func (*Metric) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Metric) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Metric) SetupWebhookWithManager ¶
func (*Metric) ValidateCreate ¶
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*Metric) ValidateDelete ¶
ValidateDelete 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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (MetricSpecComputeCodec) Encode ¶
func (MetricSpecComputeCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (MetricSpecComputeCodec) IsEmpty ¶
func (MetricSpecComputeCodec) IsEmpty(ptr unsafe.Pointer) bool
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) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)
func (MetricSpecFilterCodec) Encode ¶
func (MetricSpecFilterCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)
func (MetricSpecFilterCodec) IsEmpty ¶
func (MetricSpecFilterCodec) IsEmpty(ptr unsafe.Pointer) bool
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 ¶
func (in *PipelineOrderSpecResource) DeepCopy() *PipelineOrderSpecResource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipelineOrderSpecResource.
func (*PipelineOrderSpecResource) DeepCopyInto ¶
func (in *PipelineOrderSpecResource) DeepCopyInto(out *PipelineOrderSpecResource)
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.
Source Files
¶
- archive_order_types.go
- archive_order_webhook.go
- archive_types.go
- archive_webhook.go
- codec.go
- custom_pipeline_types.go
- custom_pipeline_webhook.go
- doc.go
- index_order_types.go
- index_order_webhook.go
- index_types.go
- index_webhook.go
- integration_pipeline_types.go
- integration_pipeline_webhook.go
- metric_types.go
- metric_webhook.go
- pipeline_order_types.go
- pipeline_order_webhook.go
- register.go
- zz_generated.deepcopy.go