Documentation
¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the observability v1alpha1 API group +kubebuilder:object:generate=true +groupName=observability.kaasops.io
Index ¶
- Variables
- type ApiSpec
- type ClusterVectorPipeline
- func (in *ClusterVectorPipeline) DeepCopy() *ClusterVectorPipeline
- func (in *ClusterVectorPipeline) DeepCopyInto(out *ClusterVectorPipeline)
- func (in *ClusterVectorPipeline) DeepCopyObject() runtime.Object
- func (vp *ClusterVectorPipeline) GetConfigCheckResult() *bool
- func (vp *ClusterVectorPipeline) GetLastAppliedPipeline() *uint32
- func (vp *ClusterVectorPipeline) GetName() string
- func (vp *ClusterVectorPipeline) GetNamespace() string
- func (vp *ClusterVectorPipeline) GetSpec() VectorPipelineSpec
- func (vp *ClusterVectorPipeline) IsDeleted() bool
- func (vp *ClusterVectorPipeline) IsValid() bool
- func (vp *ClusterVectorPipeline) SetConfigCheck(value bool)
- func (vp *ClusterVectorPipeline) SetLastAppliedPipeline(hash *uint32)
- func (vp *ClusterVectorPipeline) SetReason(reason *string)
- func (vp *ClusterVectorPipeline) Type() string
- func (vp *ClusterVectorPipeline) UpdateStatus(ctx context.Context, c client.Client) error
- type ClusterVectorPipelineList
- type ConfigCheck
- type Vector
- type VectorAgent
- type VectorAggregator
- type VectorList
- type VectorPipeline
- func (in *VectorPipeline) DeepCopy() *VectorPipeline
- func (in *VectorPipeline) DeepCopyInto(out *VectorPipeline)
- func (in *VectorPipeline) DeepCopyObject() runtime.Object
- func (vp *VectorPipeline) GetConfigCheckResult() *bool
- func (vp *VectorPipeline) GetLastAppliedPipeline() *uint32
- func (vp *VectorPipeline) GetName() string
- func (vp *VectorPipeline) GetNamespace() string
- func (vp *VectorPipeline) GetSpec() VectorPipelineSpec
- func (vp *VectorPipeline) IsDeleted() bool
- func (vp *VectorPipeline) IsValid() bool
- func (vp *VectorPipeline) SetConfigCheck(value bool)
- func (vp *VectorPipeline) SetLastAppliedPipeline(hash *uint32)
- func (vp *VectorPipeline) SetReason(reason *string)
- func (vp *VectorPipeline) Type() string
- func (vp *VectorPipeline) UpdateStatus(ctx context.Context, c client.Client) error
- type VectorPipelineList
- type VectorPipelineSpec
- type VectorPipelineStatus
- type VectorSpec
- type VectorStatus
Constants ¶
This section is empty.
Variables ¶
var ( // GroupVersion is group version used to register these objects GroupVersion = schema.GroupVersion{Group: "observability.kaasops.io", Version: "v1alpha1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion} // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme )
var (
ClusterPipelineKind = "ClusterVectorPipeline"
)
var (
LocalPipelineKind = "VectorPipeline"
)
Functions ¶
This section is empty.
Types ¶
type ApiSpec ¶
type ApiSpec struct {
Enabled bool `json:"enabled,omitempty"`
Playground bool `json:"playground,omitempty"`
// Enable ReadinessProbe and LivenessProbe via api /health endpoint.
// If probe enabled via VectorAgent, this setting will be ignored for that probe.
// +optional
Healthcheck bool `json:"healthcheck,omitempty"`
}
ApiSpec is the Schema for the Vector Agent GraphQL API - https://vector.dev/docs/reference/api/
func (*ApiSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApiSpec.
func (*ApiSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterVectorPipeline ¶
type ClusterVectorPipeline struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec VectorPipelineSpec `json:"spec,omitempty"`
Status VectorPipelineStatus `json:"status,omitempty"`
}
ClusterVectorPipeline is the Schema for the clustervectorpipelines API
func (*ClusterVectorPipeline) DeepCopy ¶
func (in *ClusterVectorPipeline) DeepCopy() *ClusterVectorPipeline
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterVectorPipeline.
func (*ClusterVectorPipeline) DeepCopyInto ¶
func (in *ClusterVectorPipeline) DeepCopyInto(out *ClusterVectorPipeline)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ClusterVectorPipeline) DeepCopyObject ¶
func (in *ClusterVectorPipeline) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ClusterVectorPipeline) GetConfigCheckResult ¶ added in v0.0.8
func (vp *ClusterVectorPipeline) GetConfigCheckResult() *bool
func (*ClusterVectorPipeline) GetLastAppliedPipeline ¶ added in v0.0.2
func (vp *ClusterVectorPipeline) GetLastAppliedPipeline() *uint32
func (*ClusterVectorPipeline) GetName ¶ added in v0.0.2
func (vp *ClusterVectorPipeline) GetName() string
func (*ClusterVectorPipeline) GetNamespace ¶ added in v0.0.2
func (vp *ClusterVectorPipeline) GetNamespace() string
func (*ClusterVectorPipeline) GetSpec ¶ added in v0.0.2
func (vp *ClusterVectorPipeline) GetSpec() VectorPipelineSpec
func (*ClusterVectorPipeline) IsDeleted ¶ added in v0.0.2
func (vp *ClusterVectorPipeline) IsDeleted() bool
func (*ClusterVectorPipeline) IsValid ¶ added in v0.0.2
func (vp *ClusterVectorPipeline) IsValid() bool
func (*ClusterVectorPipeline) SetConfigCheck ¶ added in v0.0.2
func (vp *ClusterVectorPipeline) SetConfigCheck(value bool)
func (*ClusterVectorPipeline) SetLastAppliedPipeline ¶ added in v0.0.2
func (vp *ClusterVectorPipeline) SetLastAppliedPipeline(hash *uint32)
func (*ClusterVectorPipeline) SetReason ¶ added in v0.0.2
func (vp *ClusterVectorPipeline) SetReason(reason *string)
func (*ClusterVectorPipeline) Type ¶ added in v0.0.2
func (vp *ClusterVectorPipeline) Type() string
func (*ClusterVectorPipeline) UpdateStatus ¶ added in v0.0.2
type ClusterVectorPipelineList ¶
type ClusterVectorPipelineList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []ClusterVectorPipeline `json:"items"`
}
ClusterVectorPipelineList contains a list of ClusterVectorPipeline
func (*ClusterVectorPipelineList) DeepCopy ¶
func (in *ClusterVectorPipelineList) DeepCopy() *ClusterVectorPipelineList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterVectorPipelineList.
func (*ClusterVectorPipelineList) DeepCopyInto ¶
func (in *ClusterVectorPipelineList) DeepCopyInto(out *ClusterVectorPipelineList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ClusterVectorPipelineList) DeepCopyObject ¶
func (in *ClusterVectorPipelineList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ConfigCheck ¶ added in v0.0.12
type ConfigCheck struct {
// Image - docker image settings for Vector Agent
// if no specified operator uses default config version
// +optional
Image *string `json:"image,omitempty"`
// Resources container resource request and limits, https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/
// if not specified - default setting will be used
// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Resources",xDescriptors="urn:alm:descriptor:com.tectonic.ui:resourceRequirements"
// +optional
Resources *v1.ResourceRequirements `json:"resources,omitempty"`
// Affinity If specified, the pod's scheduling constraints.
// +optional
Affinity *v1.Affinity `json:"affinity,omitempty"`
// Tolerations If specified, the pod's tolerations.
// +optional
Tolerations *[]v1.Toleration `json:"tolerations,omitempty"`
}
ConfigCheck is the Schema for control params for ConfigCheck pods
func (*ConfigCheck) DeepCopy ¶ added in v0.0.12
func (in *ConfigCheck) DeepCopy() *ConfigCheck
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigCheck.
func (*ConfigCheck) DeepCopyInto ¶ added in v0.0.12
func (in *ConfigCheck) DeepCopyInto(out *ConfigCheck)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Vector ¶
type Vector struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec VectorSpec `json:"spec,omitempty"`
Status VectorStatus `json:"status,omitempty"`
}
Vector is the Schema for the vectors API
func (*Vector) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Vector.
func (*Vector) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Vector) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type VectorAgent ¶
type VectorAgent struct {
// Image - docker image settings for Vector Agent
// if no specified operator uses default config version
// +optional
Image string `json:"image,omitempty"`
// ImagePullSecrets An optional list of references to secrets in the same namespace
// to use for pulling images from registries
// see http://kubernetes.io/docs/user-guide/images#specifying-imagepullsecrets-on-a-pod
// +optional
ImagePullSecrets []v1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
// ImagePullPolicy of pods
ImagePullPolicy v1.PullPolicy `json:"imagePullPolicy,omitempty"`
// Resources container resource request and limits, https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/
// if not specified - default setting will be used
// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Resources",xDescriptors="urn:alm:descriptor:com.tectonic.ui:resourceRequirements"
// +optional
Resources v1.ResourceRequirements `json:"resources,omitempty"`
// Affinity If specified, the pod's scheduling constraints.
// +optional
Affinity *v1.Affinity `json:"affinity,omitempty"`
// Tolerations If specified, the pod's tolerations.
// +optional
Tolerations []v1.Toleration `json:"tolerations,omitempty"`
// SecurityContext holds pod-level security attributes and common container settings.
// This defaults to the default PodSecurityContext.
// +optional
SecurityContext *v1.PodSecurityContext `json:"podSecurityContext,omitempty"`
// SecurityContext holds security configuration that will be applied to a container.
// Some fields are present in both SecurityContext and PodSecurityContext.
// When both are set, the values in SecurityContext take precedence.
// +optional
ContainerSecurityContext *v1.SecurityContext `json:"containerSecurityContext,omitempty"`
// SchedulerName - defines kubernetes scheduler name
// +optional
SchedulerName string `json:"schedulerName,omitempty"`
// RuntimeClassName - defines runtime class for kubernetes pod.
// https://kubernetes.io/docs/concepts/containers/runtime-class/
RuntimeClassName *string `json:"runtimeClassName,omitempty"`
// HostAliases provides mapping between ip and hostnames,
// that would be propagated to pod,
// cannot be used with HostNetwork.
// +optional
HostAliases []v1.HostAlias `json:"host_aliases,omitempty"`
// PodSecurityPolicyName - defines name for podSecurityPolicy
// in case of empty value, prefixedName will be used.
// +optional
PodSecurityPolicyName string `json:"podSecurityPolicyName,omitempty"`
// PriorityClassName assigned to the Pods
// +optional
PriorityClassName string `json:"priorityClassName,omitempty"`
// HostNetwork controls whether the pod may use the node network namespace
// +optional
HostNetwork bool `json:"hostNetwork,omitempty"`
// Env that will be added to Vector pod
Env []v1.EnvVar `json:"env,omitempty"`
DataDir string `json:"dataDir,omitempty"`
Api ApiSpec `json:"api,omitempty"`
// Enable internal metrics exporter
// +optional
InternalMetrics bool `json:"internalMetrics,omitempty"`
// List of volumes that can be mounted by containers belonging to the pod.
// +optional
Volumes []v1.Volume `json:"volumes,omitempty"`
// Periodic probe of container service readiness. Container will be removed from service endpoints if the probe fails.
// +optional
ReadinessProbe *v1.Probe `json:"readinessProbe,omitempty"`
// Periodic probe of container liveness. Container will be restarted if the probe fails.
// +optional
LivenessProbe *v1.Probe `json:"livenessProbe,omitempty"`
// Pod volumes to mount into the container's filesystem.
// +optional
VolumeMounts []v1.VolumeMount `json:"volumeMounts,omitempty"`
ConfigCheck ConfigCheck `json:"configCheck,omitempty"`
// Compress config file
CompressConfigFile bool `json:"compressConfigFile,omitempty"`
ConfigReloaderImage string `json:"configReloaderImage,omitempty"`
ConfigReloaderResources v1.ResourceRequirements `json:"configReloaderResources,omitempty"`
}
VectorAgent is the Schema for the Vector Agent
func (*VectorAgent) DeepCopy ¶
func (in *VectorAgent) DeepCopy() *VectorAgent
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAgent.
func (*VectorAgent) DeepCopyInto ¶
func (in *VectorAgent) DeepCopyInto(out *VectorAgent)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VectorAggregator ¶
type VectorAggregator struct {
Enable bool `json:"enable,omitempty"`
// +kubebuilder:default:="timberio/vector:0.24.0-distroless-libc"
Image string `json:"image,omitempty"`
Replicas int `json:"replicas,omitempty"`
}
VectorAggregator is the Schema for the Vector Aggregator
func (*VectorAggregator) DeepCopy ¶
func (in *VectorAggregator) DeepCopy() *VectorAggregator
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAggregator.
func (*VectorAggregator) DeepCopyInto ¶
func (in *VectorAggregator) DeepCopyInto(out *VectorAggregator)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VectorList ¶
type VectorList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []Vector `json:"items"`
}
VectorList contains a list of Vector
func (*VectorList) DeepCopy ¶
func (in *VectorList) DeepCopy() *VectorList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorList.
func (*VectorList) DeepCopyInto ¶
func (in *VectorList) DeepCopyInto(out *VectorList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*VectorList) DeepCopyObject ¶
func (in *VectorList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type VectorPipeline ¶
type VectorPipeline struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec VectorPipelineSpec `json:"spec,omitempty"`
Status VectorPipelineStatus `json:"status,omitempty"`
}
VectorPipeline is the Schema for the vectorpipelines API
func (*VectorPipeline) DeepCopy ¶
func (in *VectorPipeline) DeepCopy() *VectorPipeline
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipeline.
func (*VectorPipeline) DeepCopyInto ¶
func (in *VectorPipeline) DeepCopyInto(out *VectorPipeline)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*VectorPipeline) DeepCopyObject ¶
func (in *VectorPipeline) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*VectorPipeline) GetConfigCheckResult ¶ added in v0.0.8
func (vp *VectorPipeline) GetConfigCheckResult() *bool
func (*VectorPipeline) GetLastAppliedPipeline ¶ added in v0.0.2
func (vp *VectorPipeline) GetLastAppliedPipeline() *uint32
func (*VectorPipeline) GetName ¶ added in v0.0.2
func (vp *VectorPipeline) GetName() string
func (*VectorPipeline) GetNamespace ¶ added in v0.0.2
func (vp *VectorPipeline) GetNamespace() string
func (*VectorPipeline) GetSpec ¶ added in v0.0.2
func (vp *VectorPipeline) GetSpec() VectorPipelineSpec
func (*VectorPipeline) IsDeleted ¶ added in v0.0.2
func (vp *VectorPipeline) IsDeleted() bool
func (*VectorPipeline) IsValid ¶ added in v0.0.2
func (vp *VectorPipeline) IsValid() bool
func (*VectorPipeline) SetConfigCheck ¶ added in v0.0.2
func (vp *VectorPipeline) SetConfigCheck(value bool)
func (*VectorPipeline) SetLastAppliedPipeline ¶ added in v0.0.2
func (vp *VectorPipeline) SetLastAppliedPipeline(hash *uint32)
func (*VectorPipeline) SetReason ¶ added in v0.0.2
func (vp *VectorPipeline) SetReason(reason *string)
func (*VectorPipeline) Type ¶ added in v0.0.2
func (vp *VectorPipeline) Type() string
func (*VectorPipeline) UpdateStatus ¶ added in v0.0.2
type VectorPipelineList ¶
type VectorPipelineList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []VectorPipeline `json:"items"`
}
VectorPipelineList contains a list of VectorPipeline
func (*VectorPipelineList) DeepCopy ¶
func (in *VectorPipelineList) DeepCopy() *VectorPipelineList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineList.
func (*VectorPipelineList) DeepCopyInto ¶
func (in *VectorPipelineList) DeepCopyInto(out *VectorPipelineList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*VectorPipelineList) DeepCopyObject ¶
func (in *VectorPipelineList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type VectorPipelineSpec ¶
type VectorPipelineSpec struct {
// +kubebuilder:pruning:PreserveUnknownFields
Sources *runtime.RawExtension `json:"sources,omitempty"`
// +kubebuilder:pruning:PreserveUnknownFields
Transforms *runtime.RawExtension `json:"transforms,omitempty"`
// +kubebuilder:pruning:PreserveUnknownFields
Sinks *runtime.RawExtension `json:"sinks,omitempty"`
}
VectorPipelineSpec defines the desired state of VectorPipeline
func (*VectorPipelineSpec) DeepCopy ¶
func (in *VectorPipelineSpec) DeepCopy() *VectorPipelineSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSpec.
func (*VectorPipelineSpec) DeepCopyInto ¶
func (in *VectorPipelineSpec) DeepCopyInto(out *VectorPipelineSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VectorPipelineStatus ¶
type VectorPipelineStatus struct {
ConfigCheckResult *bool `json:"configCheckResult,omitempty"`
Reason *string `json:"reason,omitempty"`
LastAppliedPipelineHash *uint32 `json:"LastAppliedPipelineHash,omitempty"`
}
VectorPipelineStatus defines the observed state of VectorPipeline
func (*VectorPipelineStatus) DeepCopy ¶
func (in *VectorPipelineStatus) DeepCopy() *VectorPipelineStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineStatus.
func (*VectorPipelineStatus) DeepCopyInto ¶
func (in *VectorPipelineStatus) DeepCopyInto(out *VectorPipelineStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VectorSpec ¶
type VectorSpec struct {
// DisableAggregation
// DisableAggregation bool `json:"disableAggregation,omitempty"`
// Vector Agent
Agent *VectorAgent `json:"agent,omitempty"`
// Merge kubernetes sources and move selectors processing to transforms.
// +optional
MergeKubernetesSources bool `json:"mergeKubernetesSources,omitempty"`
// Merge kubernetes sink with equal options.
// +optional
MergeSinks bool `json:"mergeSinks,omitempty"`
}
VectorSpec defines the desired state of Vector
func (*VectorSpec) DeepCopy ¶
func (in *VectorSpec) DeepCopy() *VectorSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorSpec.
func (*VectorSpec) DeepCopyInto ¶
func (in *VectorSpec) DeepCopyInto(out *VectorSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VectorStatus ¶
type VectorStatus struct {
ConfigCheckResult *bool `json:"configCheckResult,omitempty"`
Reason *string `json:"reason,omitempty"`
LastAppliedConfigHash *uint32 `json:"LastAppliedConfigHash,omitempty"`
}
VectorStatus defines the observed state of Vector
func (*VectorStatus) DeepCopy ¶
func (in *VectorStatus) DeepCopy() *VectorStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorStatus.
func (*VectorStatus) DeepCopyInto ¶
func (in *VectorStatus) DeepCopyInto(out *VectorStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.