Documentation
¶
Overview ¶
Package v1 contains API Schema definitions for the cluster v1 API group +kubebuilder:object:generate=true +groupName=cluster.ytsaurus.tech
Index ¶
- Variables
- func KnownListTypes() []runtime.Object
- func KnownObjectTypes() []runtime.Object
- type BaseLoggerSpec
- type BootstrapSpec
- type BundleBootstrapSpec
- type BundleControllerInfo
- type BundleControllerSpec
- type BundlesBootstrapSpec
- type CHYTProxySpec
- type CRIJobEnvironmentSpec
- type CRIServiceType
- type CategoriesFilter
- type CategoriesFilterType
- type Chyt
- func (in *Chyt) DeepCopy() *Chyt
- func (in *Chyt) DeepCopyInto(out *Chyt)
- func (in *Chyt) DeepCopyObject() runtime.Object
- func (r *Chyt) GetStatusConditions() []metav1.Condition
- func (r *Chyt) GetStatusObservedGeneration() int64
- func (r *Chyt) SetStatusConditions(conditions []metav1.Condition)
- func (r *Chyt) SetStatusObservedGeneration(generation int64)
- type ChytList
- type ChytReleaseStatus
- type ChytSpec
- type ChytStatus
- type ClusterFeatures
- type ClusterMaintenance
- type ClusterNodesSpec
- type ClusterShutdown
- type ClusterState
- type CommonRemoteNodeStatus
- type CommonSpec
- type Component
- type ComponentClass
- type ComponentOnDeleteUpdateMode
- type ComponentRollingUpdateMode
- type ComponentType
- type ComponentUpdateModeType
- type ComponentUpdateSelector
- type ComponentUpdateStrategy
- type ControllerAgentsSpec
- type CypressProxiesSpec
- type DataNodesSpec
- type DeprecatedSpytSpec
- type DiscoverySpec
- type EmbeddedObjectMetadata
- type EmbeddedPersistentVolumeClaim
- type ExecNodesSpec
- type FileObjectReference
- type GPUInfoProviderType
- type GPUManagerSpec
- type HTTPProxiesSpec
- type HTTPTransportSpec
- type HealthcheckProbeParams
- type HydraPersistenceUploaderSpec
- type InstanceSpec
- type JobEnvironmentSpec
- type JobProxyLogManagerSpec
- type JobProxyLoggingMode
- type JobRuntimeSpec
- type KafkaProxiesSpec
- type LocationSpec
- type LocationType
- type LogCompression
- type LogFormat
- type LogLevel
- type LogRotationPolicy
- type LogWriterType
- type MasterCachesConnectionSpec
- type MasterCachesSpec
- type MasterCellMaintenanceInfo
- type MasterCellRole
- type MasterConnectionSpec
- type MastersSpec
- type MetaxRuntimeSpec
- type MetricExporter
- type MetricShard
- type NvidiaRuntimeSpec
- type OauthServiceSpec
- type OauthUserInfoHandlerSpec
- type OauthUserLoginTransformation
- type OffshoreDataGatewaySpec
- type OffshoreDataGateways
- func (in *OffshoreDataGateways) DeepCopy() *OffshoreDataGateways
- func (in *OffshoreDataGateways) DeepCopyInto(out *OffshoreDataGateways)
- func (in *OffshoreDataGateways) DeepCopyObject() runtime.Object
- func (r *OffshoreDataGateways) GetStatusConditions() []metav1.Condition
- func (r *OffshoreDataGateways) GetStatusObservedGeneration() int64
- func (r *OffshoreDataGateways) SetStatusConditions(conditions []metav1.Condition)
- func (r *OffshoreDataGateways) SetStatusObservedGeneration(generation int64)
- type OffshoreDataGatewaysList
- type OffshoreDataGatewaysSpec
- type OffshoreDataGatewaysStatus
- type PodSpec
- type QueryTrackerSpec
- type QueueAgentSpec
- type RPCProxiesSpec
- type RPCTransportSpec
- type RemoteDataNodes
- func (in *RemoteDataNodes) DeepCopy() *RemoteDataNodes
- func (in *RemoteDataNodes) DeepCopyInto(out *RemoteDataNodes)
- func (in *RemoteDataNodes) DeepCopyObject() runtime.Object
- func (r *RemoteDataNodes) GetStatusConditions() []metav1.Condition
- func (r *RemoteDataNodes) GetStatusObservedGeneration() int64
- func (r *RemoteDataNodes) SetStatusConditions(conditions []metav1.Condition)
- func (r *RemoteDataNodes) SetStatusObservedGeneration(generation int64)
- type RemoteDataNodesList
- type RemoteDataNodesSpec
- type RemoteDataNodesStatus
- type RemoteExecNodes
- func (in *RemoteExecNodes) DeepCopy() *RemoteExecNodes
- func (in *RemoteExecNodes) DeepCopyInto(out *RemoteExecNodes)
- func (in *RemoteExecNodes) DeepCopyObject() runtime.Object
- func (r *RemoteExecNodes) GetStatusConditions() []metav1.Condition
- func (r *RemoteExecNodes) GetStatusObservedGeneration() int64
- func (r *RemoteExecNodes) SetStatusConditions(conditions []metav1.Condition)
- func (r *RemoteExecNodes) SetStatusObservedGeneration(generation int64)
- type RemoteExecNodesList
- type RemoteExecNodesSpec
- type RemoteExecNodesStatus
- type RemoteNodeReleaseStatus
- type RemoteTabletNodes
- func (in *RemoteTabletNodes) DeepCopy() *RemoteTabletNodes
- func (in *RemoteTabletNodes) DeepCopyInto(out *RemoteTabletNodes)
- func (in *RemoteTabletNodes) DeepCopyObject() runtime.Object
- func (r *RemoteTabletNodes) GetStatusConditions() []metav1.Condition
- func (r *RemoteTabletNodes) GetStatusObservedGeneration() int64
- func (r *RemoteTabletNodes) SetStatusConditions(conditions []metav1.Condition)
- func (r *RemoteTabletNodes) SetStatusObservedGeneration(generation int64)
- type RemoteTabletNodesList
- type RemoteTabletNodesSpec
- type RemoteTabletNodesStatus
- type RemoteYtsaurus
- type RemoteYtsaurusList
- type RemoteYtsaurusSpec
- type RemoteYtsaurusStatus
- type SchedulersSpec
- type Spyt
- func (in *Spyt) DeepCopy() *Spyt
- func (in *Spyt) DeepCopyInto(out *Spyt)
- func (in *Spyt) DeepCopyObject() runtime.Object
- func (r *Spyt) GetStatusConditions() []metav1.Condition
- func (r *Spyt) GetStatusObservedGeneration() int64
- func (r *Spyt) SetStatusConditions(conditions []metav1.Condition)
- func (r *Spyt) SetStatusObservedGeneration(generation int64)
- type SpytList
- type SpytReleaseStatus
- type SpytSpec
- type SpytStatus
- type StrawberryControllerSpec
- type StructuredLoggerSpec
- type TCPProxiesSpec
- type TabletBalancerSpec
- type TabletCellBundleInfo
- type TabletNodesSpec
- type TextLoggerSpec
- type TimbertruckSpec
- type TracingSpec
- type UIClusterURLs
- type UISpec
- type UpdateState
- type UpdateStatus
- type Volume
- type VolumeSource
- type YQLAgentSpec
- type YQLDQEngineSpec
- type YQLGatewayAttrSpec
- type Ytsaurus
- func (in *Ytsaurus) DeepCopy() *Ytsaurus
- func (in *Ytsaurus) DeepCopyInto(out *Ytsaurus)
- func (in *Ytsaurus) DeepCopyObject() runtime.Object
- func (r *Ytsaurus) GetStatusConditions() []metav1.Condition
- func (r *Ytsaurus) GetStatusObservedGeneration() int64
- func (r *Ytsaurus) GetUpdatePlan() []ComponentUpdateSelector
- func (r *Ytsaurus) SetStatusConditions(conditions []metav1.Condition)
- func (r *Ytsaurus) SetStatusObservedGeneration(generation int64)
- type YtsaurusList
- type YtsaurusSpec
- type YtsaurusStatus
Constants ¶
This section is empty.
Variables ¶
var ( // GroupVersion is group version used to register these objects GroupVersion = schema.GroupVersion{Group: "cluster.ytsaurus.tech", Version: "v1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme YtsaurusGVK = GroupVersion.WithKind("Ytsaurus") )
Functions ¶
func KnownListTypes ¶
func KnownObjectTypes ¶
Types ¶
type BaseLoggerSpec ¶
type BaseLoggerSpec struct {
//+kubebuilder:validation:MinLength:=1
Name string `json:"name,omitempty"`
//+kubebuilder:default:=plain_text
//+kubebuilder:validation:Enum=plain_text;json;yson
Format LogFormat `json:"format,omitempty"`
//+kubebuilder:validation:Enum=trace;debug;info;warning;error
//+kubebuilder:default:=info
MinLogLevel LogLevel `json:"minLogLevel,omitempty"`
//+kubebuilder:default:=none
//+kubebuilder:validation:Enum=none;gzip;zstd
Compression LogCompression `json:"compression,omitempty"`
//+kubebuilder:default:=false
//+optional
UseTimestampSuffix bool `json:"useTimestampSuffix"`
EnableAnchorProfiling *bool `json:"enableAnchorProfiling,omitempty"`
RotationPolicy *LogRotationPolicy `json:"rotationPolicy,omitempty"`
}
func (*BaseLoggerSpec) DeepCopy ¶
func (in *BaseLoggerSpec) DeepCopy() *BaseLoggerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BaseLoggerSpec.
func (*BaseLoggerSpec) DeepCopyInto ¶
func (in *BaseLoggerSpec) DeepCopyInto(out *BaseLoggerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BootstrapSpec ¶
type BootstrapSpec struct {
TabletCellBundles *BundlesBootstrapSpec `json:"tabletCellBundles,omitempty"`
}
func (*BootstrapSpec) DeepCopy ¶
func (in *BootstrapSpec) DeepCopy() *BootstrapSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BootstrapSpec.
func (*BootstrapSpec) DeepCopyInto ¶
func (in *BootstrapSpec) DeepCopyInto(out *BootstrapSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BundleBootstrapSpec ¶
type BundleBootstrapSpec struct {
SnapshotPrimaryMedium *string `json:"snapshotMedium,omitempty"`
ChangelogPrimaryMedium *string `json:"changelogMedium,omitempty"`
//+kubebuilder:default:=1
TabletCellCount int `json:"tabletCellCount,omitempty"`
NodeTagFilter *string `json:"nodeTagFilter,omitempty"`
}
func (*BundleBootstrapSpec) DeepCopy ¶
func (in *BundleBootstrapSpec) DeepCopy() *BundleBootstrapSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BundleBootstrapSpec.
func (*BundleBootstrapSpec) DeepCopyInto ¶
func (in *BundleBootstrapSpec) DeepCopyInto(out *BundleBootstrapSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BundleControllerInfo ¶
type BundleControllerInfo struct {
Disabled *bool `json:"disabled,omitempty"`
}
func (*BundleControllerInfo) DeepCopy ¶
func (in *BundleControllerInfo) DeepCopy() *BundleControllerInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BundleControllerInfo.
func (*BundleControllerInfo) DeepCopyInto ¶
func (in *BundleControllerInfo) DeepCopyInto(out *BundleControllerInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BundleControllerSpec ¶
type BundleControllerSpec struct {
InstanceSpec `json:",inline"`
}
func (*BundleControllerSpec) DeepCopy ¶
func (in *BundleControllerSpec) DeepCopy() *BundleControllerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BundleControllerSpec.
func (*BundleControllerSpec) DeepCopyInto ¶
func (in *BundleControllerSpec) DeepCopyInto(out *BundleControllerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BundlesBootstrapSpec ¶
type BundlesBootstrapSpec struct {
Sys *BundleBootstrapSpec `json:"sys,omitempty"`
Default *BundleBootstrapSpec `json:"default,omitempty"`
}
func (*BundlesBootstrapSpec) DeepCopy ¶
func (in *BundlesBootstrapSpec) DeepCopy() *BundlesBootstrapSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BundlesBootstrapSpec.
func (*BundlesBootstrapSpec) DeepCopyInto ¶
func (in *BundlesBootstrapSpec) DeepCopyInto(out *BundlesBootstrapSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CHYTProxySpec ¶
type CHYTProxySpec struct {
//+kubebuilder:default:=8123
HttpPort *int32 `json:"httpPort,omitempty"`
HttpNodePort *int32 `json:"httpNodePort,omitempty"`
//+kubebuilder:default:=8443
HttpsPort *int32 `json:"httpsPort,omitempty"`
HttpsNodePort *int32 `json:"httpsNodePort,omitempty"`
}
func (*CHYTProxySpec) DeepCopy ¶
func (in *CHYTProxySpec) DeepCopy() *CHYTProxySpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CHYTProxySpec.
func (*CHYTProxySpec) DeepCopyInto ¶
func (in *CHYTProxySpec) DeepCopyInto(out *CHYTProxySpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CRIJobEnvironmentSpec ¶
type CRIJobEnvironmentSpec struct {
// CRI service: containerd (default), crio, none.
//+optional
//+kubebuilder:validation:Enum={"containerd","crio","none"}
CRIService *CRIServiceType `json:"criService,omitempty"`
// CRI service monitoring port, default is 10026, set 0 to disable.
// +optional
MonitoringPort *int32 `json:"monitoringPort,omitempty"`
// Specifies wrapper for CRI service command, default: ["tini", "--"].
//+optional
EntrypointWrapper []string `json:"entrypointWrapper,omitempty"`
// Sandbox (pause) image.
//+optional
SandboxImage *string `json:"sandboxImage,omitempty"`
// Timeout for retrying CRI API calls.
//+optional
APIRetryTimeoutSeconds *int32 `json:"apiRetryTimeoutSeconds,omitempty"`
// CRI namespace for jobs containers.
//+optional
CRINamespace *string `json:"criNamespace,omitempty"`
// Base cgroup for jobs.
//+optional
BaseCgroup *string `json:"baseCgroup,omitempty"`
// For containerd: https://github.com/containerd/containerd/blob/main/docs/hosts.md
//+optional
RegistryConfigPath *string `json:"registryConfigPath,omitempty"`
// Initial estimation for space required for pulling image into cache.
//+optional
ImageSizeEstimation *int64 `json:"imageSizeEstimation,omitempty"`
// Multiplier for image size to account space used by unpacked images.
//+optional
ImageCompressionRatioEstimation *int32 `json:"imageCompressionRatioEstimation,omitempty"`
// Always pull "latest" images.
//+optional
AlwaysPullLatestImage *bool `json:"alwaysPullLatestImage,omitempty"`
// Pull images periodically.
//+optional
ImagePullPeriodSeconds *int32 `json:"imagePullPeriodSeconds,omitempty"`
// For CRI-O: credentials for pulling job images, "jobImage", "sandboxImage": secret type "kubernetes.io/dockerconfigjson".
// This is used if operation spec contains no "secure_vault/docker_auth".
//+optional
ImagePullSecret *corev1.LocalObjectReference `json:"imagePullSecret,omitempty"`
}
func (*CRIJobEnvironmentSpec) DeepCopy ¶
func (in *CRIJobEnvironmentSpec) DeepCopy() *CRIJobEnvironmentSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CRIJobEnvironmentSpec.
func (*CRIJobEnvironmentSpec) DeepCopyInto ¶
func (in *CRIJobEnvironmentSpec) DeepCopyInto(out *CRIJobEnvironmentSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CRIServiceType ¶
type CRIServiceType string
const ( CRIServiceNone CRIServiceType = "none" CRIServiceContainerd CRIServiceType = "containerd" CRIServiceCRIO CRIServiceType = "crio" )
type CategoriesFilter ¶
type CategoriesFilter struct {
//+kubebuilder:validation:Enum=exclude;include
Type CategoriesFilterType `json:"type,omitempty"`
//+kubebuilder:validation:MinItems=1
Values []string `json:"values,omitempty"`
}
func (*CategoriesFilter) DeepCopy ¶
func (in *CategoriesFilter) DeepCopy() *CategoriesFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CategoriesFilter.
func (*CategoriesFilter) DeepCopyInto ¶
func (in *CategoriesFilter) DeepCopyInto(out *CategoriesFilter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CategoriesFilterType ¶
type CategoriesFilterType string
CategoriesFilterType string describes types of possible log CategoriesFilter. +enum
const ( CategoriesFilterTypeExclude CategoriesFilterType = "exclude" CategoriesFilterTypeInclude CategoriesFilterType = "include" )
type Chyt ¶
type Chyt struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec ChytSpec `json:"spec,omitempty"`
Status ChytStatus `json:"status,omitempty"`
}
Chyt is the Schema for the chyts API
func (*Chyt) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Chyt.
func (*Chyt) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Chyt) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Chyt) GetStatusConditions ¶
func (*Chyt) GetStatusObservedGeneration ¶
FIXME: Add ObservedGeneration.
func (*Chyt) SetStatusConditions ¶
func (*Chyt) SetStatusObservedGeneration ¶
type ChytList ¶
type ChytList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []Chyt `json:"items"`
}
ChytList contains a list of Chyt
func (*ChytList) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChytList.
func (*ChytList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ChytList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ChytReleaseStatus ¶
type ChytReleaseStatus string
const ( ChytReleaseStatusCreatingUserSecret ChytReleaseStatus = "CreatingUserSecret" ChytReleaseStatusCreatingUser ChytReleaseStatus = "CreatingUser" ChytReleaseStatusUploadingIntoCypress ChytReleaseStatus = "UploadingIntoCypress" ChytReleaseStatusCreatingChPublicClique ChytReleaseStatus = "CreatingChPublicClique" ChytReleaseStatusFinished ChytReleaseStatus = "Finished" )
type ChytSpec ¶
type ChytSpec struct {
ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
Ytsaurus *corev1.LocalObjectReference `json:"ytsaurus,omitempty"`
Image string `json:"image,omitempty"`
// Mark specified image as default for cliques.
//+kubebuilder:default:=false
MakeDefault bool `json:"makeDefault"`
// Create ch_public clique, which is used by default when running CHYT queries.
CreatePublicClique *bool `json:"createPublicClique,omitempty"`
}
ChytSpec defines the desired state of Chyt
func (*ChytSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChytSpec.
func (*ChytSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ChytStatus ¶
type ChytStatus struct {
Conditions []metav1.Condition `json:"conditions,omitempty"`
ReleaseStatus ChytReleaseStatus `json:"releaseStatus,omitempty"`
}
ChytStatus defines the observed state of Chyt
func (*ChytStatus) DeepCopy ¶
func (in *ChytStatus) DeepCopy() *ChytStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChytStatus.
func (*ChytStatus) DeepCopyInto ¶
func (in *ChytStatus) DeepCopyInto(out *ChytStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterFeatures ¶
type ClusterFeatures struct {
// RPC proxies have "public_rpc" address. Required for separated internal/public TLS CA.
RPCProxyHavePublicAddress bool `json:"rpcProxyHavePublicAddress,omitempty"`
// HTTP proxies have "chyt_http_server" and "chyt_https_server". Opens ports for access to chyt via HTTP proxy.
HTTPProxyHaveChytAddress bool `json:"httpProxyHaveChytAddress,omitempty"`
// HTTP proxies have "https" address. Use HTTPS for all communications.
HTTPProxyHaveHTTPSAddress bool `json:"httpProxyHaveHttpsAddress,omitempty"`
// Validate that only secure transports are allowed for cluster connections.
SecureClusterTransports bool `json:"secureClusterTransports,omitempty"`
// Pull required images to all selected nodes before cluster initialization and update.
// Alternatively ImageHeater could be enlisted in update plan for all or selected components.
EnableImageHeater bool `json:"enableImageHeater,omitempty"`
// Enable logging anchor profiling by default for loggers that don't explicitly disable it.
EnableAnchorProfilingByDefault bool `json:"enableAnchorProfilingByDefault,omitempty"`
}
func (*ClusterFeatures) DeepCopy ¶
func (in *ClusterFeatures) DeepCopy() *ClusterFeatures
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterFeatures.
func (*ClusterFeatures) DeepCopyInto ¶
func (in *ClusterFeatures) DeepCopyInto(out *ClusterFeatures)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterMaintenance ¶ added in v0.32.0
type ClusterMaintenance struct {
// Shutdown defines which components are scaled down to zero replicas during cluster maintenance.
// Component configs are not changed: cluster functions are degraded accordingly.
//+kubebuilder:validation:Enum={"Compute","Everything","ExceptMasters","Tablets"}
Shutdown ClusterShutdown `json:"shutdown"`
// Trigger master cells roles assignment.
// +optional
AssignMasterCellsRoles bool `json:"assignMasterCellsRoles,omitempty"`
}
func (*ClusterMaintenance) DeepCopy ¶ added in v0.32.0
func (in *ClusterMaintenance) DeepCopy() *ClusterMaintenance
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterMaintenance.
func (*ClusterMaintenance) DeepCopyInto ¶ added in v0.32.0
func (in *ClusterMaintenance) DeepCopyInto(out *ClusterMaintenance)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterNodesSpec ¶
type ClusterNodesSpec struct {
// List of the node tags.
Tags []string `json:"tags,omitempty"`
// Name of the node rack.
Rack string `json:"rack,omitempty"`
}
ClusterNodesSpec is a common part of spec for nodes of all flavors.
func (*ClusterNodesSpec) DeepCopy ¶
func (in *ClusterNodesSpec) DeepCopy() *ClusterNodesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterNodesSpec.
func (*ClusterNodesSpec) DeepCopyInto ¶
func (in *ClusterNodesSpec) DeepCopyInto(out *ClusterNodesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterShutdown ¶ added in v0.32.0
type ClusterShutdown string
const ( ClusterShutdownNone ClusterShutdown = "" // Shutdown compute plane: exec nodes and YQL agents. ClusterShutdownCompute ClusterShutdown = "Compute" // Shutdown everything. ClusterShutdownEverything ClusterShutdown = "Everything" // Shutdown everything except masters. Prepare for master cells reconfiguration. ClusterShutdownExceptMasters ClusterShutdown = "ExceptMasters" // Shutdown tablet nodes. ClusterShutdownTablets ClusterShutdown = "Tablets" )
type ClusterState ¶
type ClusterState string
const ( ClusterStateCreated ClusterState = "Created" ClusterStateInitializing ClusterState = "Initializing" ClusterStatePreparing ClusterState = "Preparing" ClusterStateRunning ClusterState = "Running" ClusterStateReconfiguration ClusterState = "Reconfiguration" ClusterStateMaintenance ClusterState = "Maintenance" ClusterStateUpdating ClusterState = "Updating" ClusterStateUpdateCanceled ClusterState = "UpdateCanceled" ClusterStateUpdateBlocked ClusterState = "UpdateBlocked" ClusterStateUpdateFinished ClusterState = "UpdateFinished" )
type CommonRemoteNodeStatus ¶
type CommonRemoteNodeStatus struct {
Conditions []metav1.Condition `json:"conditions,omitempty"`
// Reflects resource generation which was used for updating status.
ObservedGeneration int64 `json:"observedGeneration,omitempty"`
ReleaseStatus RemoteNodeReleaseStatus `json:"releaseStatus,omitempty"`
}
CommonRemoteNodeStatus is a set of fields shared between `Remote*NodesStatus`. It is inlined in these specs.
func (*CommonRemoteNodeStatus) DeepCopy ¶
func (in *CommonRemoteNodeStatus) DeepCopy() *CommonRemoteNodeStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CommonRemoteNodeStatus.
func (*CommonRemoteNodeStatus) DeepCopyInto ¶
func (in *CommonRemoteNodeStatus) DeepCopyInto(out *CommonRemoteNodeStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CommonSpec ¶
type CommonSpec struct {
CoreImage string `json:"coreImage,omitempty"`
ClusterFeatures *ClusterFeatures `json:"clusterFeatures,omitempty"`
// Controls cluster maintenance.
ClusterMaintenance *ClusterMaintenance `json:"clusterMaintenance,omitempty"`
// Default docker image for user jobs.
//+optional
JobImage *string `json:"jobImage,omitempty"`
// Cluster-wide timbertruck sidecar settings (image, logs delivery path) used by any component
// that enables log delivery via a structured logger's enableDelivery flag.
// Per-component overrides (e.g. primaryMasters.timbertruck) take precedence field-by-field.
//+optional
Timbertruck *TimbertruckSpec `json:"timbertruck,omitempty"`
// Reference to trusted root certificates. Default kind="ConfigMap", key="ca-certificates.crt".
// Will replace system CA root bundle for all server and job containers.
//+optional
CARootBundle *FileObjectReference `json:"caRootBundle,omitempty"`
// Reference to trusted native transport certificates. Default kind="ConfigMap", key="ca.crt".
// By default will use system CA bundle, which could be set by caRootBundle.
//+optional
CABundle *FileObjectReference `json:"caBundle,omitempty"`
// Common config for native RPC bus transport.
//+optional
NativeTransport *RPCTransportSpec `json:"nativeTransport,omitempty"`
// Common tracing configuration for all YTsaurus server components.
//+optional
Tracing *TracingSpec `json:"tracing,omitempty"`
// Allow prioritizing performance over data safety. Useful for tests and experiments.
//+kubebuilder:default:=false
//+optional
EphemeralCluster bool `json:"ephemeralCluster,omitempty"`
//+kubebuilder:default:=false
//+optional
UseIPv6 bool `json:"useIpv6"`
//+kubebuilder:default:=false
//+optional
UseIPv4 bool `json:"useIpv4"`
//+optional
KeepSocket *bool `json:"keepSocket,omitempty"`
//+optional
ForceTCP *bool `json:"forceTcp,omitempty"`
// Do not add resource name into names of resources under control.
// When enabled resource should not share namespace with other Ytsaurus.
//+kubebuilder:default:=true
//+optional
UseShortNames bool `json:"useShortNames"`
//+kubebuilder:default:=false
//+optional
UsePorto bool `json:"usePorto"`
// Deprecated: Despite its name, it adds annotations to all resources. Use podAnnotations instead.
ExtraPodAnnotations map[string]string `json:"extraPodAnnotations,omitempty"`
ConfigOverrides *corev1.LocalObjectReference `json:"configOverrides,omitempty"`
// Credentials for pulling "coreImage" and "image" set for components.
ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
}
CommonSpec is a set of fields shared between `YtsaurusSpec` and `Remote*NodesSpec`. It is inlined in these specs.
func (*CommonSpec) DeepCopy ¶
func (in *CommonSpec) DeepCopy() *CommonSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CommonSpec.
func (*CommonSpec) DeepCopyInto ¶
func (in *CommonSpec) DeepCopyInto(out *CommonSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Component ¶
type Component struct {
Type ComponentType `json:"type,omitempty"`
Name string `json:"name,omitempty"`
}
func (*Component) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Component.
func (*Component) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ComponentClass ¶
type ComponentClass string
const ( ComponentClassUnspecified ComponentClass = "" // ComponentClassNothing includes no components. ComponentClassNothing ComponentClass = "Nothing" // ComponentClassEverything includes all components. ComponentClassEverything ComponentClass = "Everything" // ComponentClassStateless includes all except master, data and tablet nodes. ComponentClassStateless ComponentClass = "Stateless" )
type ComponentOnDeleteUpdateMode ¶
type ComponentOnDeleteUpdateMode struct {
}
func (*ComponentOnDeleteUpdateMode) DeepCopy ¶
func (in *ComponentOnDeleteUpdateMode) DeepCopy() *ComponentOnDeleteUpdateMode
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ComponentOnDeleteUpdateMode.
func (*ComponentOnDeleteUpdateMode) DeepCopyInto ¶
func (in *ComponentOnDeleteUpdateMode) DeepCopyInto(out *ComponentOnDeleteUpdateMode)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ComponentRollingUpdateMode ¶
type ComponentRollingUpdateMode struct {
}
ComponentRollingUpdateMode configures the rolling update strategy. The maxUnavailable budget is derived from the component's minReadyInstanceCount: maxUnavailable = max(1, instanceCount - minReadyInstanceCount).
func (*ComponentRollingUpdateMode) DeepCopy ¶
func (in *ComponentRollingUpdateMode) DeepCopy() *ComponentRollingUpdateMode
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ComponentRollingUpdateMode.
func (*ComponentRollingUpdateMode) DeepCopyInto ¶
func (in *ComponentRollingUpdateMode) DeepCopyInto(out *ComponentRollingUpdateMode)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ComponentType ¶
type ComponentType string
const ( BundleControllerType ComponentType = "BundleController" ControllerAgentType ComponentType = "ControllerAgent" ChytType ComponentType = "CHYT" ClusterConnectionType ComponentType = "ClusterConnection" CypressProxyType ComponentType = "CypressProxy" DataNodeType ComponentType = "DataNode" DiscoveryType ComponentType = "Discovery" ExecNodeType ComponentType = "ExecNode" HttpProxyType ComponentType = "HttpProxy" ImageHeaterType ComponentType = "ImageHeater" KafkaProxyType ComponentType = "KafkaProxy" MasterCacheType ComponentType = "MasterCache" MasterType ComponentType = "Master" NativeClientConfigType ComponentType = "NativeClientConfig" OffshoreDataGatewayType ComponentType = "OffshoreDataGateway" QueryTrackerType ComponentType = "QueryTracker" QueueAgentType ComponentType = "QueueAgent" RpcProxyType ComponentType = "RpcProxy" SchedulerType ComponentType = "Scheduler" SpytType ComponentType = "SPYT" StrawberryControllerType ComponentType = "StrawberryController" TabletBalancerType ComponentType = "TabletBalancer" TabletNodeType ComponentType = "TabletNode" TcpProxyType ComponentType = "TcpProxy" TimbertruckType ComponentType = "Timbertruck" UIType ComponentType = "UI" YqlAgentType ComponentType = "YqlAgent" YtsaurusClientType ComponentType = "YtsaurusClient" )
NOTE: In alphabetical order.
type ComponentUpdateModeType ¶
type ComponentUpdateModeType string
const ( ComponentUpdateModeTypeBulkUpdate ComponentUpdateModeType = "BulkUpdate" ComponentUpdateModeTypeRollingUpdate ComponentUpdateModeType = "RollingUpdate" ComponentUpdateModeTypeOnDelete ComponentUpdateModeType = "OnDelete" )
type ComponentUpdateSelector ¶
type ComponentUpdateSelector struct {
// Selects components by class: Nothing, Everything, Stateless (except Master, DataNode, TabletNode).
//+kubebuilder:validation:Enum={"","Nothing","Stateless","Everything"}
Class ComponentClass `json:"class,omitempty"`
// Selects components by type and/or instance group name.
Component Component `json:"component,omitempty"`
// Limits count of instance groups updated concurrently.
//+kubebuilder:validation:Minimum=0
Concurrency *int32 `json:"concurrency,omitempty"`
// Defines update strategy for selected instance groups.
Strategy *ComponentUpdateStrategy `json:"strategy,omitempty"`
}
func (*ComponentUpdateSelector) DeepCopy ¶
func (in *ComponentUpdateSelector) DeepCopy() *ComponentUpdateSelector
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ComponentUpdateSelector.
func (*ComponentUpdateSelector) DeepCopyInto ¶
func (in *ComponentUpdateSelector) DeepCopyInto(out *ComponentUpdateSelector)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ComponentUpdateSelector) GetUpdateStrategyType ¶
func (selector *ComponentUpdateSelector) GetUpdateStrategyType() ComponentUpdateModeType
type ComponentUpdateStrategy ¶
type ComponentUpdateStrategy struct {
RunPreChecks *bool `json:"runPreChecks,omitempty"`
RollingUpdate *ComponentRollingUpdateMode `json:"rollingUpdate,omitempty"`
OnDelete *ComponentOnDeleteUpdateMode `json:"onDelete,omitempty"`
}
func (*ComponentUpdateStrategy) DeepCopy ¶
func (in *ComponentUpdateStrategy) DeepCopy() *ComponentUpdateStrategy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ComponentUpdateStrategy.
func (*ComponentUpdateStrategy) DeepCopyInto ¶
func (in *ComponentUpdateStrategy) DeepCopyInto(out *ComponentUpdateStrategy)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ComponentUpdateStrategy) Type ¶
func (m *ComponentUpdateStrategy) Type() ComponentUpdateModeType
type ControllerAgentsSpec ¶
type ControllerAgentsSpec struct {
// label filter (for daemonset)
InstanceSpec `json:",inline"`
}
func (*ControllerAgentsSpec) DeepCopy ¶
func (in *ControllerAgentsSpec) DeepCopy() *ControllerAgentsSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ControllerAgentsSpec.
func (*ControllerAgentsSpec) DeepCopyInto ¶
func (in *ControllerAgentsSpec) DeepCopyInto(out *ControllerAgentsSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CypressProxiesSpec ¶
type CypressProxiesSpec struct {
InstanceSpec `json:",inline"`
Disable *bool `json:"disable,omitempty"`
}
func (*CypressProxiesSpec) DeepCopy ¶
func (in *CypressProxiesSpec) DeepCopy() *CypressProxiesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CypressProxiesSpec.
func (*CypressProxiesSpec) DeepCopyInto ¶
func (in *CypressProxiesSpec) DeepCopyInto(out *CypressProxiesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DataNodesSpec ¶
type DataNodesSpec struct {
InstanceSpec `json:",inline"`
// Common part of the cluster node spec.
ClusterNodesSpec `json:",inline"`
//+kubebuilder:default:=default
//+kubebuilder:validation:MinLength:=1
Name string `json:"name,omitempty"`
}
func (*DataNodesSpec) DeepCopy ¶
func (in *DataNodesSpec) DeepCopy() *DataNodesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DataNodesSpec.
func (*DataNodesSpec) DeepCopyInto ¶
func (in *DataNodesSpec) DeepCopyInto(out *DataNodesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeprecatedSpytSpec ¶
type DeprecatedSpytSpec struct {
SparkVersion string `json:"sparkVersion,omitempty"`
SpytVersion string `json:"spytVersion,omitempty"`
}
func (*DeprecatedSpytSpec) DeepCopy ¶
func (in *DeprecatedSpytSpec) DeepCopy() *DeprecatedSpytSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeprecatedSpytSpec.
func (*DeprecatedSpytSpec) DeepCopyInto ¶
func (in *DeprecatedSpytSpec) DeepCopyInto(out *DeprecatedSpytSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DiscoverySpec ¶
type DiscoverySpec struct {
// label filter (for daemonset)
InstanceSpec `json:",inline"`
}
func (*DiscoverySpec) DeepCopy ¶
func (in *DiscoverySpec) DeepCopy() *DiscoverySpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DiscoverySpec.
func (*DiscoverySpec) DeepCopyInto ¶
func (in *DiscoverySpec) DeepCopyInto(out *DiscoverySpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EmbeddedObjectMetadata ¶
type EmbeddedObjectMetadata struct {
// Name must be unique within a namespace. Is required when creating resources, although
// some resources may allow a client to request the generation of an appropriate name
// automatically. Name is primarily intended for creation idempotence and configuration
// definition.
// Cannot be updated.
// More info: http://kubernetes.io/docs/user-guide/identifiers#names
// +optional
Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
// Map of string keys and values that can be used to organize and categorize
// (scope and select) objects. May match selectors of replication controllers
// and services.
// More info: http://kubernetes.io/docs/user-guide/labels
// +optional
Labels map[string]string `json:"labels,omitempty" protobuf:"bytes,11,rep,name=labels"`
// Annotations is an unstructured key value map stored with a resource that may be
// set by external tools to store and retrieve arbitrary metadata. They are not
// queryable and should be preserved when modifying objects.
// More info: http://kubernetes.io/docs/user-guide/annotations
// +optional
Annotations map[string]string `json:"annotations,omitempty" protobuf:"bytes,12,rep,name=annotations"`
}
EmbeddedObjectMetadata contains a subset of the fields included in k8s.io/apimachinery/pkg/apis/meta/v1.ObjectMeta Only fields which are relevant to embedded resources are included.
func (*EmbeddedObjectMetadata) DeepCopy ¶
func (in *EmbeddedObjectMetadata) DeepCopy() *EmbeddedObjectMetadata
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmbeddedObjectMetadata.
func (*EmbeddedObjectMetadata) DeepCopyInto ¶
func (in *EmbeddedObjectMetadata) DeepCopyInto(out *EmbeddedObjectMetadata)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EmbeddedPersistentVolumeClaim ¶
type EmbeddedPersistentVolumeClaim struct {
metav1.TypeMeta `json:",inline"`
// EmbeddedMetadata contains metadata relevant to an EmbeddedResource.
EmbeddedObjectMetadata `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// Spec defines the desired characteristics of a volume requested by a pod author.
// More info: https://kubernetes.io/docs/concepts/storage/persistent-volumes#persistentvolumeclaims
// +optional
Spec corev1.PersistentVolumeClaimSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
}
EmbeddedPersistentVolumeClaim is an embedded version of k8s.io/api/core/v1.PersistentVolumeClaim. It contains TypeMeta and a reduced ObjectMeta.
func (*EmbeddedPersistentVolumeClaim) DeepCopy ¶
func (in *EmbeddedPersistentVolumeClaim) DeepCopy() *EmbeddedPersistentVolumeClaim
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmbeddedPersistentVolumeClaim.
func (*EmbeddedPersistentVolumeClaim) DeepCopyInto ¶
func (in *EmbeddedPersistentVolumeClaim) DeepCopyInto(out *EmbeddedPersistentVolumeClaim)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ExecNodesSpec ¶
type ExecNodesSpec struct {
// label filter (for daemonset)
InstanceSpec `json:",inline"`
// Common part of the cluster node spec.
ClusterNodesSpec `json:",inline"`
//+kubebuilder:default:=default
//+kubebuilder:validation:MinLength:=1
Name string `json:"name,omitempty"`
// List of init containers as yaml of core/v1 Container.
InitContainers []string `json:"initContainers,omitempty"`
// List of sidecar containers as yaml of core/v1 Container.
Sidecars []string `json:"sidecars,omitempty"`
//+kubebuilder:default:=true
//+optional
Privileged bool `json:"privileged"`
//+optional
GPUManager *GPUManagerSpec `json:"gpuManager,omitempty"`
JobProxyLoggers []TextLoggerSpec `json:"jobProxyLoggers,omitempty"`
//+optional
JobProxyLogManager *JobProxyLogManagerSpec `json:"jobProxyLogManager,omitempty"`
// Resources dedicated for running jobs. Capacity is defined by requests, or limits for zero requests. Default: same limits as exec node with zero requests.
//+optional
JobResources *corev1.ResourceRequirements `json:"jobResources,omitempty"`
//+optional
JobEnvironment *JobEnvironmentSpec `json:"jobEnvironment,omitempty"`
}
func (*ExecNodesSpec) DeepCopy ¶
func (in *ExecNodesSpec) DeepCopy() *ExecNodesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExecNodesSpec.
func (*ExecNodesSpec) DeepCopyInto ¶
func (in *ExecNodesSpec) DeepCopyInto(out *ExecNodesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type FileObjectReference ¶
type FileObjectReference struct {
// Kind is the type of resource: ConfigMap or Secret.
//+kubebuilder:validation:Enum=ConfigMap;Secret
Kind string `json:"kind,omitempty"`
// Name is the name of resource being referenced
Name string `json:"name,omitempty"`
// Key is the name of entry in ConfigMap or Secret.
Key string `json:"key,omitempty"`
// Items defines entries in ConfigMap or Secret, default: if Key is defined map to Path: "ca-certificates.crt".
Items []corev1.KeyToPath `json:"items,omitempty"`
}
A reference to a specific 'key' within a ConfigMap or Secret resource.
func (*FileObjectReference) DeepCopy ¶
func (in *FileObjectReference) DeepCopy() *FileObjectReference
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FileObjectReference.
func (*FileObjectReference) DeepCopyInto ¶
func (in *FileObjectReference) DeepCopyInto(out *FileObjectReference)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type GPUInfoProviderType ¶
type GPUInfoProviderType string
GPU information provider. +enum
const ( GPUInfoProviderNvidiaSMI GPUInfoProviderType = "nvidia_smi" GPUInfoProviderGPUAgent GPUInfoProviderType = "gpu_agent" GPUInfoProviderNvGpuManager GPUInfoProviderType = "nv_gpu_manager" )
type GPUManagerSpec ¶
type GPUManagerSpec struct {
GPUInfoProvider *GPUInfoProviderType `json:"gpuInfoProvider,omitempty"`
}
func (*GPUManagerSpec) DeepCopy ¶
func (in *GPUManagerSpec) DeepCopy() *GPUManagerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GPUManagerSpec.
func (*GPUManagerSpec) DeepCopyInto ¶
func (in *GPUManagerSpec) DeepCopyInto(out *GPUManagerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type HTTPProxiesSpec ¶
type HTTPProxiesSpec struct {
InstanceSpec `json:",inline"`
//+kubebuilder:default:=NodePort
ServiceType corev1.ServiceType `json:"serviceType,omitempty"`
//+kubebuilder:default:=80
HttpPort *int32 `json:"httpPort,omitempty"`
//+kubebuilder:default:=443
HttpsPort *int32 `json:"httpsPort,omitempty"`
HttpNodePort *int32 `json:"httpNodePort,omitempty"`
HttpsNodePort *int32 `json:"httpsNodePort,omitempty"`
ChytProxy *CHYTProxySpec `json:"chytProxy,omitempty"`
//+kubebuilder:default:=default
//+kubebuilder:validation:MinLength:=1
Role string `json:"role,omitempty"`
//+optional
Transport HTTPTransportSpec `json:"transport,omitempty"`
}
func (*HTTPProxiesSpec) DeepCopy ¶
func (in *HTTPProxiesSpec) DeepCopy() *HTTPProxiesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HTTPProxiesSpec.
func (*HTTPProxiesSpec) DeepCopyInto ¶
func (in *HTTPProxiesSpec) DeepCopyInto(out *HTTPProxiesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type HTTPTransportSpec ¶
type HTTPTransportSpec struct {
// Reference to kubernetes.io/tls secret.
//+optional
HTTPSSecret *corev1.LocalObjectReference `json:"httpsSecret,omitempty"`
//+optional
DisableHTTP bool `json:"disableHttp,omitempty"`
}
func (*HTTPTransportSpec) DeepCopy ¶
func (in *HTTPTransportSpec) DeepCopy() *HTTPTransportSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HTTPTransportSpec.
func (*HTTPTransportSpec) DeepCopyInto ¶
func (in *HTTPTransportSpec) DeepCopyInto(out *HTTPTransportSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type HealthcheckProbeParams ¶
type HealthcheckProbeParams struct {
//+optional
InitialDelaySeconds int32 `json:"initialDelaySeconds,omitempty"`
//+optional
TimeoutSeconds int32 `json:"timeoutSeconds,omitempty"`
//+optional
PeriodSeconds int32 `json:"periodSeconds,omitempty"`
//+optional
SuccessThreshold int32 `json:"successThreshold,omitempty"`
//+optional
FailureThreshold int32 `json:"failureThreshold,omitempty"`
}
func (*HealthcheckProbeParams) DeepCopy ¶
func (in *HealthcheckProbeParams) DeepCopy() *HealthcheckProbeParams
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HealthcheckProbeParams.
func (*HealthcheckProbeParams) DeepCopyInto ¶
func (in *HealthcheckProbeParams) DeepCopyInto(out *HealthcheckProbeParams)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type HydraPersistenceUploaderSpec ¶
type HydraPersistenceUploaderSpec struct {
Image *string `json:"image,omitempty"`
}
func (*HydraPersistenceUploaderSpec) DeepCopy ¶
func (in *HydraPersistenceUploaderSpec) DeepCopy() *HydraPersistenceUploaderSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HydraPersistenceUploaderSpec.
func (*HydraPersistenceUploaderSpec) DeepCopyInto ¶
func (in *HydraPersistenceUploaderSpec) DeepCopyInto(out *HydraPersistenceUploaderSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type InstanceSpec ¶
type InstanceSpec struct {
PodSpec `json:",inline"`
// Overrides coreImage for component.
//+optional
Image *string `json:"image,omitempty"`
// Specifies wrapper for component container command.
//+optional
EntrypointWrapper []string `json:"entrypointWrapper,omitempty"`
Volumes []Volume `json:"volumes,omitempty"`
VolumeMounts []corev1.VolumeMount `json:"volumeMounts,omitempty"`
//+optional
ReadinessProbeParams *HealthcheckProbeParams `json:"readinessProbeParams,omitempty"`
// Resources dedicated for component. Capacity is defined by requests, or limits for zero requests.
Resources corev1.ResourceRequirements `json:"resources,omitempty"`
// Desired count of replicas. Default: 0.
//+kubebuilder:default:=0
//+kubebuilder:validation:Minimum:=0
InstanceCount int32 `json:"instanceCount,omitempty"`
// Required count of replicas. Defaulted and bounded by instanceCount.
//+kubebuilder:validation:Minimum:=0
MinReadyInstanceCount *int32 `json:"minReadyInstanceCount,omitempty"`
Locations []LocationSpec `json:"locations,omitempty"`
VolumeClaimTemplates []EmbeddedPersistentVolumeClaim `json:"volumeClaimTemplates,omitempty"`
// Deprecated: use Affinity.PodAntiAffinity instead.
EnableAntiAffinity *bool `json:"enableAntiAffinity,omitempty"`
//+optional
MonitoringPort *int32 `json:"monitoringPort,omitempty"`
MetricExporter *MetricExporter `json:"metricExporter,omitempty"`
Loggers []TextLoggerSpec `json:"loggers,omitempty"`
StructuredLoggers []StructuredLoggerSpec `json:"structuredLoggers,omitempty"`
Affinity *corev1.Affinity `json:"affinity,omitempty"`
// Component config for native RPC bus transport.
//+optional
NativeTransport *RPCTransportSpec `json:"nativeTransport,omitempty"`
}
func (*InstanceSpec) DeepCopy ¶
func (in *InstanceSpec) DeepCopy() *InstanceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InstanceSpec.
func (*InstanceSpec) DeepCopyInto ¶
func (in *InstanceSpec) DeepCopyInto(out *InstanceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JobEnvironmentSpec ¶
type JobEnvironmentSpec struct {
// Isolate job execution environment from exec node or not, by default true when possible.
//+optional
Isolated *bool `json:"isolated,omitempty"`
// Count of slots for user jobs on each exec node, default is 5 per CPU.
//+optional
UserSlots *int `json:"userSlots,omitempty"`
// CRI service configuration for running jobs in sidecar container.
//+optional
CRI *CRIJobEnvironmentSpec `json:"cri,omitempty"`
// Pass artifacts as read-only bind-mounts rather than symlinks.
//+optional
UseArtifactBinds *bool `json:"useArtifactBinds,omitempty"`
// Do not use slot user id for running jobs.
//+optional
DoNotSetUserId *bool `json:"doNotSetUserId,omitempty"`
// Container Runtime configuration for CRI service. Default: runc.
//+optional
Runtime *JobRuntimeSpec `json:"runtime,omitempty"`
}
func (*JobEnvironmentSpec) DeepCopy ¶
func (in *JobEnvironmentSpec) DeepCopy() *JobEnvironmentSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobEnvironmentSpec.
func (*JobEnvironmentSpec) DeepCopyInto ¶
func (in *JobEnvironmentSpec) DeepCopyInto(out *JobEnvironmentSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JobProxyLogManagerSpec ¶ added in v0.34.0
type JobProxyLogManagerSpec struct {
// How the exec node stores job proxy logs.
//+kubebuilder:default:=simple
Mode JobProxyLoggingMode `json:"mode,omitempty"`
// TTL for logs of finished jobs: job logs are removed when they become
// older than this period.
LogsStoragePeriodMilliseconds *int64 `json:"logsStoragePeriodMilliseconds,omitempty"`
// How many directories are checked at the same time during logs cleanup.
//+kubebuilder:validation:Minimum=1
//+kubebuilder:validation:Maximum=8
DirectoryTraversalConcurrency *int `json:"directoryTraversalConcurrency,omitempty"`
// Directory with symlinks to job log directories on all locations.
JobProxyLogSymlinksPath *string `json:"jobProxyLogSymlinksPath,omitempty"`
}
func (*JobProxyLogManagerSpec) DeepCopy ¶ added in v0.34.0
func (in *JobProxyLogManagerSpec) DeepCopy() *JobProxyLogManagerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobProxyLogManagerSpec.
func (*JobProxyLogManagerSpec) DeepCopyInto ¶ added in v0.34.0
func (in *JobProxyLogManagerSpec) DeepCopyInto(out *JobProxyLogManagerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JobProxyLoggingMode ¶ added in v0.34.0
type JobProxyLoggingMode string
JobProxyLoggingMode describes how the exec node stores job-proxy logs. +kubebuilder:validation:Enum=simple;per_job_directory
const ( // All jobs write logs into common log files in the exec node log directory. JobProxyLoggingModeSimple JobProxyLoggingMode = "simple" // Each job writes logs into its own directory `<location>/<shard>/<job-id>`. // Locations here are exec node locations with type JobProxyLogs. // Requires YTsaurus >= 26.1. JobProxyLoggingModePerJobDirectory JobProxyLoggingMode = "per_job_directory" )
type JobRuntimeSpec ¶
type JobRuntimeSpec struct {
// Use NVIDIA Container Runtime.
//+optional
Nvidia *NvidiaRuntimeSpec `json:"nvidia,omitempty"`
// Use METAX Container Runtime.
//+optional
Metax *MetaxRuntimeSpec `json:"metax,omitempty"`
}
func (*JobRuntimeSpec) DeepCopy ¶
func (in *JobRuntimeSpec) DeepCopy() *JobRuntimeSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobRuntimeSpec.
func (*JobRuntimeSpec) DeepCopyInto ¶
func (in *JobRuntimeSpec) DeepCopyInto(out *JobRuntimeSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaProxiesSpec ¶
type KafkaProxiesSpec struct {
InstanceSpec `json:",inline"`
ServiceType *corev1.ServiceType `json:"serviceType,omitempty"`
//+kubebuilder:default:=default
//+kubebuilder:validation:MinLength:=1
Role string `json:"role,omitempty"`
}
func (*KafkaProxiesSpec) DeepCopy ¶
func (in *KafkaProxiesSpec) DeepCopy() *KafkaProxiesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaProxiesSpec.
func (*KafkaProxiesSpec) DeepCopyInto ¶
func (in *KafkaProxiesSpec) DeepCopyInto(out *KafkaProxiesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LocationSpec ¶
type LocationSpec struct {
LocationType LocationType `json:"locationType,omitempty"`
//+kubebuilder:validation:MinLength:=1
Path string `json:"path,omitempty"`
//+kubebuilder:default:=default
Medium string `json:"medium,omitempty"`
// Disk space quota, default is size of related volume.
//+optional
Quota *resource.Quantity `json:"quota,omitempty"`
// Limit above which the volume is considered to be non-full.
//+optional
LowWatermark *resource.Quantity `json:"lowWatermark,omitempty"`
// Max TTL of trash in milliseconds.
//+kubebuilder:validation:Minimum:=60000
MaxTrashMilliseconds *int64 `json:"maxTrashMilliseconds,omitempty"`
}
func FindAllLocations ¶
func FindAllLocations(locations []LocationSpec, locationType LocationType) []LocationSpec
func FindFirstLocation ¶
func FindFirstLocation(locations []LocationSpec, locationType LocationType) *LocationSpec
func (*LocationSpec) DeepCopy ¶
func (in *LocationSpec) DeepCopy() *LocationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LocationSpec.
func (*LocationSpec) DeepCopyInto ¶
func (in *LocationSpec) DeepCopyInto(out *LocationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LocationType ¶
type LocationType string
LocationType string describes types of disk locations for YT components. +enum
const ( LocationTypeChunkStore LocationType = "ChunkStore" LocationTypeChunkCache LocationType = "ChunkCache" LocationTypeSlots LocationType = "Slots" LocationTypeLogs LocationType = "Logs" LocationTypeMasterChangelogs LocationType = "MasterChangelogs" LocationTypeMasterSnapshots LocationType = "MasterSnapshots" LocationTypeImageCache LocationType = "ImageCache" LocationTypeJobProxyLogs LocationType = "JobProxyLogs" LocationTypeInitJobLogs LocationType = "InitJobLogs" )
type LogCompression ¶
type LogCompression string
const ( LogCompressionNone LogCompression = "none" LogCompressionGzip LogCompression = "gzip" LogCompressionZstd LogCompression = "zstd" )
type LogLevel ¶
type LogLevel string
LogLevel string describes possible Ytsaurus logging level. +enum
type LogRotationPolicy ¶
type LogRotationPolicy struct {
RotationPeriodMilliseconds *int64 `json:"rotationPeriodMilliseconds,omitempty"`
MaxSegmentSize *resource.Quantity `json:"maxSegmentSize,omitempty"`
MaxTotalSizeToKeep *resource.Quantity `json:"maxTotalSizeToKeep,omitempty"`
MaxSegmentCountToKeep *int64 `json:"maxSegmentCountToKeep,omitempty"`
}
func (*LogRotationPolicy) DeepCopy ¶
func (in *LogRotationPolicy) DeepCopy() *LogRotationPolicy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LogRotationPolicy.
func (*LogRotationPolicy) DeepCopyInto ¶
func (in *LogRotationPolicy) DeepCopyInto(out *LogRotationPolicy)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LogWriterType ¶
type LogWriterType string
LogWriterType string describes types of possible log writers. +enum
const ( LogWriterTypeFile LogWriterType = "file" LogWriterTypeStderr LogWriterType = "stderr" )
type MasterCachesConnectionSpec ¶
type MasterCachesConnectionSpec struct {
//+listType=set
HostAddresses []string `json:"hostAddresses,omitempty"`
}
func (*MasterCachesConnectionSpec) DeepCopy ¶
func (in *MasterCachesConnectionSpec) DeepCopy() *MasterCachesConnectionSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MasterCachesConnectionSpec.
func (*MasterCachesConnectionSpec) DeepCopyInto ¶
func (in *MasterCachesConnectionSpec) DeepCopyInto(out *MasterCachesConnectionSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MasterCachesSpec ¶
type MasterCachesSpec struct {
InstanceSpec `json:",inline"`
MasterCachesConnectionSpec `json:",inline"`
HostAddressLabel string `json:"hostAddressesLabel,omitempty"`
// Deprecated: have no effect.
CellTagMasterCaches uint16 `json:"cellTagMasterCaches,omitempty"`
// Deprecated: use hostAddresses instead.
HostAddressesMasterCaches []string `json:"hostAddressesMasterCaches,omitempty"`
}
func (*MasterCachesSpec) DeepCopy ¶
func (in *MasterCachesSpec) DeepCopy() *MasterCachesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MasterCachesSpec.
func (*MasterCachesSpec) DeepCopyInto ¶
func (in *MasterCachesSpec) DeepCopyInto(out *MasterCachesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MasterCellMaintenanceInfo ¶ added in v0.35.0
type MasterCellMaintenanceInfo struct {
CellTag uint16 `json:"cellTag"`
Unregistered bool `json:"unregistered"`
}
func (*MasterCellMaintenanceInfo) DeepCopy ¶ added in v0.35.0
func (in *MasterCellMaintenanceInfo) DeepCopy() *MasterCellMaintenanceInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MasterCellMaintenanceInfo.
func (*MasterCellMaintenanceInfo) DeepCopyInto ¶ added in v0.35.0
func (in *MasterCellMaintenanceInfo) DeepCopyInto(out *MasterCellMaintenanceInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MasterCellRole ¶ added in v0.32.0
type MasterCellRole string
Other roles are allowed and handled as opaque strings, only naming convention is validated. Link: https://ytsaurus.tech/docs/en/admin-guide/cell-addition +kubebuilder:validation:Pattern:=`^[a-z_]+$`
const ( // Handling cypress tree or sub-tree (portal). Default role for both primary and secondary cells. MasterCellRoleCypressNodeHost MasterCellRole = "cypress_node_host" // Handling transactions. Default role for primary cell. MasterCellRoleTransactionCoordinator MasterCellRole = "transaction_coordinator" // Handling chunk metadata. Default role for secondary cells and for primary if there is no secondary cells. MasterCellRoleChunkHost MasterCellRole = "chunk_host" // Handling chunk metadata for explicit placement via external_cell_tag. MasterCellRoleDedicatedChunkHost MasterCellRole = "dedicated_chunk_host" )
func GetMasterCellRoles ¶ added in v0.32.0
func GetMasterCellRoles(roles *[]MasterCellRole, isPrimary, isMulticell bool) []MasterCellRole
Returns default set of master cell roles if not defined explicitly.
type MasterConnectionSpec ¶
type MasterConnectionSpec struct {
// Cell tag is an immutable identifier for particular cell of YTsaurus cluster.
// Must be unique among all connected clusters to prevent object ids from colliding.
//+kubebuilder:validation:Required
//+kubebuilder:validation:Minimum:=1
//+kubebuilder:validation:Maximum:=61440
CellTag uint16 `json:"cellTag"`
//+listType=set
HostAddresses []string `json:"hostAddresses,omitempty"`
}
func (*MasterConnectionSpec) DeepCopy ¶
func (in *MasterConnectionSpec) DeepCopy() *MasterConnectionSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MasterConnectionSpec.
func (*MasterConnectionSpec) DeepCopyInto ¶
func (in *MasterConnectionSpec) DeepCopyInto(out *MasterConnectionSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MastersSpec ¶
type MastersSpec struct {
InstanceSpec `json:",inline"`
MasterConnectionSpec `json:",inline"`
// Roles assigned to this master cell. Explicit enlisting is preferred, because defaults could change.
// In general, assigned or default roles cannot be removed later without risk of data loss.
//+listType=set
Roles *[]MasterCellRole `json:"roles,omitempty"`
HostAddressLabel string `json:"hostAddressLabel,omitempty"`
MaxSnapshotCountToKeep *int `json:"maxSnapshotCountToKeep,omitempty"`
MaxChangelogCountToKeep *int `json:"maxChangelogCountToKeep,omitempty"`
HydraPersistenceUploader *HydraPersistenceUploaderSpec `json:"hydraPersistenceUploader,omitempty"`
Timbertruck *TimbertruckSpec `json:"timbertruck,omitempty"`
// List of sidecar containers as yaml of core/v1 Container.
Sidecars []string `json:"sidecars,omitempty"`
}
func (*MastersSpec) DeepCopy ¶
func (in *MastersSpec) DeepCopy() *MastersSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MastersSpec.
func (*MastersSpec) DeepCopyInto ¶
func (in *MastersSpec) DeepCopyInto(out *MastersSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MetaxRuntimeSpec ¶ added in v0.32.0
type MetaxRuntimeSpec struct{}
func (*MetaxRuntimeSpec) DeepCopy ¶ added in v0.32.0
func (in *MetaxRuntimeSpec) DeepCopy() *MetaxRuntimeSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetaxRuntimeSpec.
func (*MetaxRuntimeSpec) DeepCopyInto ¶ added in v0.32.0
func (in *MetaxRuntimeSpec) DeepCopyInto(out *MetaxRuntimeSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MetricExporter ¶
type MetricExporter struct {
Host *string `json:"host,omitempty"`
InstanceTags map[string]string `json:"instanceTags,omitempty"`
Shards map[string]MetricShard `json:"shards,omitempty"`
GridStep int32 `json:"gridStep,omitempty"`
}
func (*MetricExporter) DeepCopy ¶
func (in *MetricExporter) DeepCopy() *MetricExporter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetricExporter.
func (*MetricExporter) DeepCopyInto ¶
func (in *MetricExporter) DeepCopyInto(out *MetricExporter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MetricShard ¶
type MetricShard struct {
Filter []string `json:"filter,omitempty"`
GridStep int32 `json:"gridStep,omitempty"`
}
func (*MetricShard) DeepCopy ¶
func (in *MetricShard) DeepCopy() *MetricShard
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetricShard.
func (*MetricShard) DeepCopyInto ¶
func (in *MetricShard) DeepCopyInto(out *MetricShard)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NvidiaRuntimeSpec ¶
type NvidiaRuntimeSpec struct{}
func (*NvidiaRuntimeSpec) DeepCopy ¶
func (in *NvidiaRuntimeSpec) DeepCopy() *NvidiaRuntimeSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NvidiaRuntimeSpec.
func (*NvidiaRuntimeSpec) DeepCopyInto ¶
func (in *NvidiaRuntimeSpec) DeepCopyInto(out *NvidiaRuntimeSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OauthServiceSpec ¶
type OauthServiceSpec struct {
//+kubebuilder:validation:MinLength:=1
Host string `json:"host,omitempty"`
//+kubebuilder:default:=80
Port int `json:"port,omitempty"`
//+kubebuilder:default:=false
Secure bool `json:"secure,omitempty"`
UserInfo OauthUserInfoHandlerSpec `json:"userInfoHandler,omitempty"`
// If DisableUserCreation is set, proxies will NOT create non-existing users with OAuth authentication.
DisableUserCreation *bool `json:"disableUserCreation,omitempty"`
}
func (*OauthServiceSpec) DeepCopy ¶
func (in *OauthServiceSpec) DeepCopy() *OauthServiceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OauthServiceSpec.
func (*OauthServiceSpec) DeepCopyInto ¶
func (in *OauthServiceSpec) DeepCopyInto(out *OauthServiceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OauthUserInfoHandlerSpec ¶
type OauthUserInfoHandlerSpec struct {
//+kubebuilder:default:=user/info
Endpoint string `json:"endpoint,omitempty"`
//+kubebuilder:default:=nickname
LoginField string `json:"loginField,omitempty"`
ErrorField *string `json:"errorField,omitempty"`
// LoginTransformations will be applied to the login field consequentially if set.
// Result of the transformations is treated as YTsaurus OAuth user's username.
LoginTransformations []OauthUserLoginTransformation `json:"loginTransformations,omitempty"`
}
func (*OauthUserInfoHandlerSpec) DeepCopy ¶
func (in *OauthUserInfoHandlerSpec) DeepCopy() *OauthUserInfoHandlerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OauthUserInfoHandlerSpec.
func (*OauthUserInfoHandlerSpec) DeepCopyInto ¶
func (in *OauthUserInfoHandlerSpec) DeepCopyInto(out *OauthUserInfoHandlerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OauthUserLoginTransformation ¶
type OauthUserLoginTransformation struct {
// MatchPattern expects RE2 (https://github.com/google/re2/wiki/syntax) syntax.
MatchPattern string `json:"matchPattern,omitempty"`
Replacement string `json:"replacement,omitempty"`
}
func (*OauthUserLoginTransformation) DeepCopy ¶
func (in *OauthUserLoginTransformation) DeepCopy() *OauthUserLoginTransformation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OauthUserLoginTransformation.
func (*OauthUserLoginTransformation) DeepCopyInto ¶
func (in *OauthUserLoginTransformation) DeepCopyInto(out *OauthUserLoginTransformation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OffshoreDataGatewaySpec ¶
type OffshoreDataGatewaySpec struct {
// label filter (for daemonset)
InstanceSpec `json:",inline"`
}
func (*OffshoreDataGatewaySpec) DeepCopy ¶
func (in *OffshoreDataGatewaySpec) DeepCopy() *OffshoreDataGatewaySpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OffshoreDataGatewaySpec.
func (*OffshoreDataGatewaySpec) DeepCopyInto ¶
func (in *OffshoreDataGatewaySpec) DeepCopyInto(out *OffshoreDataGatewaySpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OffshoreDataGateways ¶
type OffshoreDataGateways struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec OffshoreDataGatewaysSpec `json:"spec,omitempty"`
Status OffshoreDataGatewaysStatus `json:"status,omitempty"`
}
OffshoreDataGateways is the Schema for the OffshoreDataGateways API Be careful: this component is experimental and is not part of the public API yet, so there are no guarantees it will work even when configured TODO(pavel-bash): remove this warning when the component is released to open-source
func (*OffshoreDataGateways) DeepCopy ¶
func (in *OffshoreDataGateways) DeepCopy() *OffshoreDataGateways
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OffshoreDataGateways.
func (*OffshoreDataGateways) DeepCopyInto ¶
func (in *OffshoreDataGateways) DeepCopyInto(out *OffshoreDataGateways)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*OffshoreDataGateways) DeepCopyObject ¶
func (in *OffshoreDataGateways) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*OffshoreDataGateways) GetStatusConditions ¶
func (r *OffshoreDataGateways) GetStatusConditions() []metav1.Condition
func (*OffshoreDataGateways) GetStatusObservedGeneration ¶
func (r *OffshoreDataGateways) GetStatusObservedGeneration() int64
func (*OffshoreDataGateways) SetStatusConditions ¶
func (r *OffshoreDataGateways) SetStatusConditions(conditions []metav1.Condition)
func (*OffshoreDataGateways) SetStatusObservedGeneration ¶
func (r *OffshoreDataGateways) SetStatusObservedGeneration(generation int64)
type OffshoreDataGatewaysList ¶
type OffshoreDataGatewaysList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []OffshoreDataGateways `json:"items"`
}
OffshoreDataGatewaysList contains a list of OffshoreDataGateways
func (*OffshoreDataGatewaysList) DeepCopy ¶
func (in *OffshoreDataGatewaysList) DeepCopy() *OffshoreDataGatewaysList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OffshoreDataGatewaysList.
func (*OffshoreDataGatewaysList) DeepCopyInto ¶
func (in *OffshoreDataGatewaysList) DeepCopyInto(out *OffshoreDataGatewaysList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*OffshoreDataGatewaysList) DeepCopyObject ¶
func (in *OffshoreDataGatewaysList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type OffshoreDataGatewaysSpec ¶
type OffshoreDataGatewaysSpec struct {
RemoteClusterSpec *corev1.LocalObjectReference `json:"remoteClusterSpec"`
CommonSpec `json:",inline"`
OffshoreDataGatewaySpec `json:",inline"`
}
OffshoreDataGatewaysSpec defines the desired state of OffshoreDataGateways
func (*OffshoreDataGatewaysSpec) DeepCopy ¶
func (in *OffshoreDataGatewaysSpec) DeepCopy() *OffshoreDataGatewaysSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OffshoreDataGatewaysSpec.
func (*OffshoreDataGatewaysSpec) DeepCopyInto ¶
func (in *OffshoreDataGatewaysSpec) DeepCopyInto(out *OffshoreDataGatewaysSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OffshoreDataGatewaysStatus ¶
type OffshoreDataGatewaysStatus struct {
CommonRemoteNodeStatus `json:",inline"`
}
OffshoreDataGatewaysStatus defines the observed state of OffshoreDataGateways
func (*OffshoreDataGatewaysStatus) DeepCopy ¶
func (in *OffshoreDataGatewaysStatus) DeepCopy() *OffshoreDataGatewaysStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OffshoreDataGatewaysStatus.
func (*OffshoreDataGatewaysStatus) DeepCopyInto ¶
func (in *OffshoreDataGatewaysStatus) DeepCopyInto(out *OffshoreDataGatewaysStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PodSpec ¶
type PodSpec struct {
// Labels for instance pods.
PodLabels map[string]string `json:"podLabels,omitempty"`
// Annotations for instance pods.
PodAnnotations map[string]string `json:"podAnnotations,omitempty"`
// Node selector for instance and init job pods.
NodeSelector map[string]string `json:"nodeSelector,omitempty"`
// Tolerations for instance and init job pods.
Tolerations []corev1.Toleration `json:"tolerations,omitempty"`
// Runtime class for instance pods.
RuntimeClassName *string `json:"runtimeClassName,omitempty"`
// Optional duration in seconds the pod needs to terminate gracefully. Defaults to 30 seconds.
//+optional
TerminationGracePeriodSeconds *int64 `json:"terminationGracePeriodSeconds,omitempty"`
// Use the host's network namespace.
HostNetwork *bool `json:"hostNetwork,omitempty"`
// SetHostnameAsFQDN indicates whether to set the hostname as FQDN.
//+kubebuilder:default:=true
SetHostnameAsFQDN *bool `json:"setHostnameAsFqdn,omitempty"`
// DNSPolicy defines how DNS will be configured.
DNSPolicy *corev1.DNSPolicy `json:"dnsPolicy,omitempty"`
// DNSConfig allows customizing the DNS settings.
DNSConfig *corev1.PodDNSConfig `json:"dnsConfig,omitempty"`
}
func (*PodSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodSpec.
func (*PodSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type QueryTrackerSpec ¶
type QueryTrackerSpec struct {
InstanceSpec `json:",inline"`
}
func (*QueryTrackerSpec) DeepCopy ¶
func (in *QueryTrackerSpec) DeepCopy() *QueryTrackerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueryTrackerSpec.
func (*QueryTrackerSpec) DeepCopyInto ¶
func (in *QueryTrackerSpec) DeepCopyInto(out *QueryTrackerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type QueueAgentSpec ¶
type QueueAgentSpec struct {
InstanceSpec `json:",inline"`
}
func (*QueueAgentSpec) DeepCopy ¶
func (in *QueueAgentSpec) DeepCopy() *QueueAgentSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueAgentSpec.
func (*QueueAgentSpec) DeepCopyInto ¶
func (in *QueueAgentSpec) DeepCopyInto(out *QueueAgentSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RPCProxiesSpec ¶
type RPCProxiesSpec struct {
InstanceSpec `json:",inline"`
ServiceType *corev1.ServiceType `json:"serviceType,omitempty"`
NodePort *int32 `json:"nodePort,omitempty"`
//+kubebuilder:default:=default
//+kubebuilder:validation:MinLength:=1
Role string `json:"role,omitempty"`
//+optional
Transport RPCTransportSpec `json:"transport,omitempty"`
}
func (*RPCProxiesSpec) DeepCopy ¶
func (in *RPCProxiesSpec) DeepCopy() *RPCProxiesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RPCProxiesSpec.
func (*RPCProxiesSpec) DeepCopyInto ¶
func (in *RPCProxiesSpec) DeepCopyInto(out *RPCProxiesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RPCTransportSpec ¶
type RPCTransportSpec struct {
// Server certificate. Reference to kubernetes.io/tls secret.
//+optional
TLSSecret *corev1.LocalObjectReference `json:"tlsSecret,omitempty"`
// Client certificate. Reference to kubernetes.io/tls secret.
//+optional
TLSClientSecret *corev1.LocalObjectReference `json:"tlsClientSecret,omitempty"`
// Require secure TLS connections by server, otherwise only by client.
//+optional
TLSRequired bool `json:"tlsRequired,omitempty"`
// Disable client certificate verification when TLS is required, if not required - verify neither.
//+optional
TLSInsecure bool `json:"tlsInsecure,omitempty"`
// Define alternative host name for certificate verification.
//+optional
TLSPeerAlternativeHostName string `json:"tlsPeerAlternativeHostName,omitempty"`
}
func (*RPCTransportSpec) DeepCopy ¶
func (in *RPCTransportSpec) DeepCopy() *RPCTransportSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RPCTransportSpec.
func (*RPCTransportSpec) DeepCopyInto ¶
func (in *RPCTransportSpec) DeepCopyInto(out *RPCTransportSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RemoteDataNodes ¶
type RemoteDataNodes struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec RemoteDataNodesSpec `json:"spec,omitempty"`
Status RemoteDataNodesStatus `json:"status,omitempty"`
}
RemoteDataNodes is the Schema for the remotedatanodes API
func (*RemoteDataNodes) DeepCopy ¶
func (in *RemoteDataNodes) DeepCopy() *RemoteDataNodes
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteDataNodes.
func (*RemoteDataNodes) DeepCopyInto ¶
func (in *RemoteDataNodes) DeepCopyInto(out *RemoteDataNodes)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RemoteDataNodes) DeepCopyObject ¶
func (in *RemoteDataNodes) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*RemoteDataNodes) GetStatusConditions ¶
func (r *RemoteDataNodes) GetStatusConditions() []metav1.Condition
func (*RemoteDataNodes) GetStatusObservedGeneration ¶
func (r *RemoteDataNodes) GetStatusObservedGeneration() int64
func (*RemoteDataNodes) SetStatusConditions ¶
func (r *RemoteDataNodes) SetStatusConditions(conditions []metav1.Condition)
func (*RemoteDataNodes) SetStatusObservedGeneration ¶
func (r *RemoteDataNodes) SetStatusObservedGeneration(generation int64)
type RemoteDataNodesList ¶
type RemoteDataNodesList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []RemoteDataNodes `json:"items"`
}
RemoteDataNodesList contains a list of RemoteDataNodes
func (*RemoteDataNodesList) DeepCopy ¶
func (in *RemoteDataNodesList) DeepCopy() *RemoteDataNodesList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteDataNodesList.
func (*RemoteDataNodesList) DeepCopyInto ¶
func (in *RemoteDataNodesList) DeepCopyInto(out *RemoteDataNodesList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RemoteDataNodesList) DeepCopyObject ¶
func (in *RemoteDataNodesList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type RemoteDataNodesSpec ¶
type RemoteDataNodesSpec struct {
RemoteClusterSpec *corev1.LocalObjectReference `json:"remoteClusterSpec"`
CommonSpec `json:",inline"`
DataNodesSpec `json:",inline"`
}
RemoteDataNodesSpec defines the desired state of RemoteDataNodes
func (*RemoteDataNodesSpec) DeepCopy ¶
func (in *RemoteDataNodesSpec) DeepCopy() *RemoteDataNodesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteDataNodesSpec.
func (*RemoteDataNodesSpec) DeepCopyInto ¶
func (in *RemoteDataNodesSpec) DeepCopyInto(out *RemoteDataNodesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RemoteDataNodesStatus ¶
type RemoteDataNodesStatus struct {
CommonRemoteNodeStatus `json:",inline"`
}
RemoteDataNodesStatus defines the observed state of RemoteDataNodes
func (*RemoteDataNodesStatus) DeepCopy ¶
func (in *RemoteDataNodesStatus) DeepCopy() *RemoteDataNodesStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteDataNodesStatus.
func (*RemoteDataNodesStatus) DeepCopyInto ¶
func (in *RemoteDataNodesStatus) DeepCopyInto(out *RemoteDataNodesStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RemoteExecNodes ¶
type RemoteExecNodes struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec RemoteExecNodesSpec `json:"spec,omitempty"`
Status RemoteExecNodesStatus `json:"status,omitempty"`
}
RemoteExecNodes is the Schema for the remoteexecnodes API
func (*RemoteExecNodes) DeepCopy ¶
func (in *RemoteExecNodes) DeepCopy() *RemoteExecNodes
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteExecNodes.
func (*RemoteExecNodes) DeepCopyInto ¶
func (in *RemoteExecNodes) DeepCopyInto(out *RemoteExecNodes)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RemoteExecNodes) DeepCopyObject ¶
func (in *RemoteExecNodes) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*RemoteExecNodes) GetStatusConditions ¶
func (r *RemoteExecNodes) GetStatusConditions() []metav1.Condition
func (*RemoteExecNodes) GetStatusObservedGeneration ¶
func (r *RemoteExecNodes) GetStatusObservedGeneration() int64
func (*RemoteExecNodes) SetStatusConditions ¶
func (r *RemoteExecNodes) SetStatusConditions(conditions []metav1.Condition)
func (*RemoteExecNodes) SetStatusObservedGeneration ¶
func (r *RemoteExecNodes) SetStatusObservedGeneration(generation int64)
type RemoteExecNodesList ¶
type RemoteExecNodesList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []RemoteExecNodes `json:"items"`
}
RemoteExecNodesList contains a list of RemoteExecNodes
func (*RemoteExecNodesList) DeepCopy ¶
func (in *RemoteExecNodesList) DeepCopy() *RemoteExecNodesList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteExecNodesList.
func (*RemoteExecNodesList) DeepCopyInto ¶
func (in *RemoteExecNodesList) DeepCopyInto(out *RemoteExecNodesList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RemoteExecNodesList) DeepCopyObject ¶
func (in *RemoteExecNodesList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type RemoteExecNodesSpec ¶
type RemoteExecNodesSpec struct {
RemoteClusterSpec *corev1.LocalObjectReference `json:"remoteClusterSpec"`
CommonSpec `json:",inline"`
ExecNodesSpec `json:",inline"`
}
RemoteExecNodesSpec defines the desired state of RemoteExecNodes
func (*RemoteExecNodesSpec) DeepCopy ¶
func (in *RemoteExecNodesSpec) DeepCopy() *RemoteExecNodesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteExecNodesSpec.
func (*RemoteExecNodesSpec) DeepCopyInto ¶
func (in *RemoteExecNodesSpec) DeepCopyInto(out *RemoteExecNodesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RemoteExecNodesStatus ¶
type RemoteExecNodesStatus struct {
CommonRemoteNodeStatus `json:",inline"`
}
RemoteExecNodesStatus defines the observed state of RemoteExecNodes
func (*RemoteExecNodesStatus) DeepCopy ¶
func (in *RemoteExecNodesStatus) DeepCopy() *RemoteExecNodesStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteExecNodesStatus.
func (*RemoteExecNodesStatus) DeepCopyInto ¶
func (in *RemoteExecNodesStatus) DeepCopyInto(out *RemoteExecNodesStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RemoteNodeReleaseStatus ¶
type RemoteNodeReleaseStatus string
const ( RemoteNodeReleaseStatusPending RemoteNodeReleaseStatus = "Pending" RemoteNodeReleaseStatusRunning RemoteNodeReleaseStatus = "Running" )
type RemoteTabletNodes ¶
type RemoteTabletNodes struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec RemoteTabletNodesSpec `json:"spec,omitempty"`
Status RemoteTabletNodesStatus `json:"status,omitempty"`
}
RemoteTabletNodes is the Schema for the remotetabletnodes API
func (*RemoteTabletNodes) DeepCopy ¶
func (in *RemoteTabletNodes) DeepCopy() *RemoteTabletNodes
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteTabletNodes.
func (*RemoteTabletNodes) DeepCopyInto ¶
func (in *RemoteTabletNodes) DeepCopyInto(out *RemoteTabletNodes)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RemoteTabletNodes) DeepCopyObject ¶
func (in *RemoteTabletNodes) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*RemoteTabletNodes) GetStatusConditions ¶
func (r *RemoteTabletNodes) GetStatusConditions() []metav1.Condition
func (*RemoteTabletNodes) GetStatusObservedGeneration ¶
func (r *RemoteTabletNodes) GetStatusObservedGeneration() int64
func (*RemoteTabletNodes) SetStatusConditions ¶
func (r *RemoteTabletNodes) SetStatusConditions(conditions []metav1.Condition)
func (*RemoteTabletNodes) SetStatusObservedGeneration ¶
func (r *RemoteTabletNodes) SetStatusObservedGeneration(generation int64)
type RemoteTabletNodesList ¶
type RemoteTabletNodesList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []RemoteTabletNodes `json:"items"`
}
RemoteTabletNodesList contains a list of RemoteTabletNodes
func (*RemoteTabletNodesList) DeepCopy ¶
func (in *RemoteTabletNodesList) DeepCopy() *RemoteTabletNodesList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteTabletNodesList.
func (*RemoteTabletNodesList) DeepCopyInto ¶
func (in *RemoteTabletNodesList) DeepCopyInto(out *RemoteTabletNodesList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RemoteTabletNodesList) DeepCopyObject ¶
func (in *RemoteTabletNodesList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type RemoteTabletNodesSpec ¶
type RemoteTabletNodesSpec struct {
RemoteClusterSpec *corev1.LocalObjectReference `json:"remoteClusterSpec"`
CommonSpec `json:",inline"`
TabletNodesSpec `json:",inline"`
}
RemoteTabletNodesSpec defines the desired state of RemoteTabletNodes
func (*RemoteTabletNodesSpec) DeepCopy ¶
func (in *RemoteTabletNodesSpec) DeepCopy() *RemoteTabletNodesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteTabletNodesSpec.
func (*RemoteTabletNodesSpec) DeepCopyInto ¶
func (in *RemoteTabletNodesSpec) DeepCopyInto(out *RemoteTabletNodesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RemoteTabletNodesStatus ¶
type RemoteTabletNodesStatus struct {
CommonRemoteNodeStatus `json:",inline"`
}
RemoteTabletNodesStatus defines the observed state of RemoteTabletNodes
func (*RemoteTabletNodesStatus) DeepCopy ¶
func (in *RemoteTabletNodesStatus) DeepCopy() *RemoteTabletNodesStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteTabletNodesStatus.
func (*RemoteTabletNodesStatus) DeepCopyInto ¶
func (in *RemoteTabletNodesStatus) DeepCopyInto(out *RemoteTabletNodesStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RemoteYtsaurus ¶
type RemoteYtsaurus struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec RemoteYtsaurusSpec `json:"spec,omitempty"`
Status RemoteYtsaurusStatus `json:"status,omitempty"`
}
RemoteYtsaurus is the Schema for the remoteytsauruses API
func (*RemoteYtsaurus) DeepCopy ¶
func (in *RemoteYtsaurus) DeepCopy() *RemoteYtsaurus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteYtsaurus.
func (*RemoteYtsaurus) DeepCopyInto ¶
func (in *RemoteYtsaurus) DeepCopyInto(out *RemoteYtsaurus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RemoteYtsaurus) DeepCopyObject ¶
func (in *RemoteYtsaurus) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type RemoteYtsaurusList ¶
type RemoteYtsaurusList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []RemoteYtsaurus `json:"items"`
}
RemoteYtsaurusList contains a list of RemoteYtsaurus
func (*RemoteYtsaurusList) DeepCopy ¶
func (in *RemoteYtsaurusList) DeepCopy() *RemoteYtsaurusList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteYtsaurusList.
func (*RemoteYtsaurusList) DeepCopyInto ¶
func (in *RemoteYtsaurusList) DeepCopyInto(out *RemoteYtsaurusList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RemoteYtsaurusList) DeepCopyObject ¶
func (in *RemoteYtsaurusList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type RemoteYtsaurusSpec ¶
type RemoteYtsaurusSpec struct {
//+optional
PrimaryMaster *MasterConnectionSpec `json:"primaryMaster,omitempty"`
//+kubebuilder:validation:MaxItems:=48
SecondaryMasters []MasterConnectionSpec `json:"secondaryMasters,omitempty"`
//+optional
MasterCaches *MasterCachesConnectionSpec `json:"masterCaches,omitempty"`
// Deprecated: use primaryMaster.cellTag instead.
//+kubebuilder:validation:Minimum:=1
//+kubebuilder:validation:Maximum:=61440
CellTag uint16 `json:"cellTag,omitempty"`
// Deprecated: use primaryMaster.hostAddresses instead.
HostAddresses []string `json:"hostAddresses,omitempty"`
// Deprecated: have no effect.
CellTagMasterCaches uint16 `json:"cellTagMasterCaches,omitempty"`
// Deprecated: use masterCaches.hostAddresses instead.
HostAddressesMasterCaches []string `json:"hostAddressesMasterCaches,omitempty"`
}
RemoteYtsaurusSpec defines the desired state of RemoteYtsaurus +kubebuilder:validation:XValidation:rule="has(self.cellTag) || (has(self.primaryMaster) && has(self.primaryMaster.cellTag))",message="either cellTag or primaryMaster.cellTag must be set" +kubebuilder:validation:XValidation:rule="!(has(self.cellTag) && has(self.primaryMaster) && has(self.primaryMaster.cellTag)) || self.cellTag == self.primaryMaster.cellTag",message="cellTag and primaryMaster.cellTag must match when both are set"
func (*RemoteYtsaurusSpec) DeepCopy ¶
func (in *RemoteYtsaurusSpec) DeepCopy() *RemoteYtsaurusSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteYtsaurusSpec.
func (*RemoteYtsaurusSpec) DeepCopyInto ¶
func (in *RemoteYtsaurusSpec) DeepCopyInto(out *RemoteYtsaurusSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RemoteYtsaurusStatus ¶
type RemoteYtsaurusStatus struct {
}
RemoteYtsaurusStatus defines the observed state of RemoteYtsaurus
func (*RemoteYtsaurusStatus) DeepCopy ¶
func (in *RemoteYtsaurusStatus) DeepCopy() *RemoteYtsaurusStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RemoteYtsaurusStatus.
func (*RemoteYtsaurusStatus) DeepCopyInto ¶
func (in *RemoteYtsaurusStatus) DeepCopyInto(out *RemoteYtsaurusStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SchedulersSpec ¶
type SchedulersSpec struct {
// label filter (for daemonset)
InstanceSpec `json:",inline"`
}
func (*SchedulersSpec) DeepCopy ¶
func (in *SchedulersSpec) DeepCopy() *SchedulersSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchedulersSpec.
func (*SchedulersSpec) DeepCopyInto ¶
func (in *SchedulersSpec) DeepCopyInto(out *SchedulersSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Spyt ¶
type Spyt struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec SpytSpec `json:"spec,omitempty"`
Status SpytStatus `json:"status,omitempty"`
}
Spyt is the Schema for the spyts API
func (*Spyt) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Spyt.
func (*Spyt) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Spyt) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Spyt) GetStatusConditions ¶
func (*Spyt) GetStatusObservedGeneration ¶
FIXME: Add ObservedGeneration.
func (*Spyt) SetStatusConditions ¶
func (*Spyt) SetStatusObservedGeneration ¶
type SpytList ¶
type SpytList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []Spyt `json:"items"`
}
SpytList contains a list of Spyt
func (*SpytList) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SpytList.
func (*SpytList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SpytList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type SpytReleaseStatus ¶
type SpytReleaseStatus string
const ( SpytReleaseStatusCreatingUserSecret SpytReleaseStatus = "CreatingUserSecret" SpytReleaseStatusCreatingUser SpytReleaseStatus = "CreatingUser" SpytReleaseStatusUploadingIntoCypress SpytReleaseStatus = "UploadingIntoCypress" SpytReleaseStatusFinished SpytReleaseStatus = "Finished" )
type SpytSpec ¶
type SpytSpec struct {
ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
Ytsaurus *corev1.LocalObjectReference `json:"ytsaurus,omitempty"`
Image string `json:"image,omitempty"`
// If multiple versions are provided, only the first one is used for query tracker dynamic config.
SparkVersions []string `json:"sparkVersions,omitempty"`
// Use only local artifacts for spark distribution setup.
SparkDistribOffline bool `json:"sparkDistribOffline,omitempty"`
}
SpytSpec defines the desired state of Spyt
func (*SpytSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SpytSpec.
func (*SpytSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SpytStatus ¶
type SpytStatus struct {
Conditions []metav1.Condition `json:"conditions,omitempty"`
ReleaseStatus SpytReleaseStatus `json:"releaseStatus,omitempty"`
}
SpytStatus defines the observed state of Spyt
func (*SpytStatus) DeepCopy ¶
func (in *SpytStatus) DeepCopy() *SpytStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SpytStatus.
func (*SpytStatus) DeepCopyInto ¶
func (in *SpytStatus) DeepCopyInto(out *SpytStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StrawberryControllerSpec ¶
type StrawberryControllerSpec struct {
PodSpec `json:",inline"`
Resources corev1.ResourceRequirements `json:"resources,omitempty"`
Image *string `json:"image,omitempty"`
ExternalProxy *string `json:"externalProxy,omitempty"`
// Supported controller families, for example: "chyt", "jupyt", "livy".
ControllerFamilies []string `json:"controllerFamilies,omitempty"`
// The family that will receive requests for domains that are not explicitly specified in http_controller_mappings.
// For example, "chyt" (with `ControllerFamilies` set to {"chyt", "jupyt"} would mean
// that requests to "foo.<domain>" will be processed by chyt controller.
DefaultRouteFamily *string `json:"defaultRouteFamily,omitempty"`
// Write logs to stderr.
LogToStderr bool `json:"logToStderr,omitempty"`
}
func (*StrawberryControllerSpec) DeepCopy ¶
func (in *StrawberryControllerSpec) DeepCopy() *StrawberryControllerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StrawberryControllerSpec.
func (*StrawberryControllerSpec) DeepCopyInto ¶
func (in *StrawberryControllerSpec) DeepCopyInto(out *StrawberryControllerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StructuredLoggerSpec ¶
type StructuredLoggerSpec struct {
BaseLoggerSpec `json:",inline"`
// Exactly one of category and categoriesFilter must be set.
//+optional
Category *string `json:"category,omitempty"`
// Filter for logs spanning several categories. Type must be set.
// Exactly one of category and categoriesFilter must be set.
//+optional
CategoriesFilter *CategoriesFilter `json:"categoriesFilter,omitempty"`
// EnableDelivery turns on timbertruck delivery of this structured log to the cluster log storage.
// Requires a timbertruck image to be configured (spec.timbertruck.image or, for masters, primaryMasters.timbertruck.image).
//+optional
EnableDelivery *bool `json:"enableDelivery,omitempty"`
}
func (*StructuredLoggerSpec) DeepCopy ¶
func (in *StructuredLoggerSpec) DeepCopy() *StructuredLoggerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StructuredLoggerSpec.
func (*StructuredLoggerSpec) DeepCopyInto ¶
func (in *StructuredLoggerSpec) DeepCopyInto(out *StructuredLoggerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TCPProxiesSpec ¶
type TCPProxiesSpec struct {
InstanceSpec `json:",inline"`
ServiceType *corev1.ServiceType `json:"serviceType,omitempty"`
//+kubebuilder:default:=32000
MinPort int32 `json:"minPort"`
// Number of ports to allocate for balancing service.
//+kubebuilder:default:=20
PortCount int32 `json:"portCount"`
//+kubebuilder:default:=default
//+kubebuilder:validation:MinLength:=1
Role string `json:"role,omitempty"`
}
func (*TCPProxiesSpec) DeepCopy ¶
func (in *TCPProxiesSpec) DeepCopy() *TCPProxiesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TCPProxiesSpec.
func (*TCPProxiesSpec) DeepCopyInto ¶
func (in *TCPProxiesSpec) DeepCopyInto(out *TCPProxiesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TabletBalancerSpec ¶
type TabletBalancerSpec struct {
InstanceSpec `json:",inline"`
}
func (*TabletBalancerSpec) DeepCopy ¶
func (in *TabletBalancerSpec) DeepCopy() *TabletBalancerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TabletBalancerSpec.
func (*TabletBalancerSpec) DeepCopyInto ¶
func (in *TabletBalancerSpec) DeepCopyInto(out *TabletBalancerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TabletCellBundleInfo ¶
type TabletCellBundleInfo struct {
Name string `yson:",value" json:"name"`
TabletCellCount int `yson:"tablet_cell_count,attr" json:"tabletCellCount"`
}
func (*TabletCellBundleInfo) DeepCopy ¶
func (in *TabletCellBundleInfo) DeepCopy() *TabletCellBundleInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TabletCellBundleInfo.
func (*TabletCellBundleInfo) DeepCopyInto ¶
func (in *TabletCellBundleInfo) DeepCopyInto(out *TabletCellBundleInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TabletNodesSpec ¶
type TabletNodesSpec struct {
// label filter (for daemonset)
InstanceSpec `json:",inline"`
// Common part of the cluster node spec.
ClusterNodesSpec `json:",inline"`
//+kubebuilder:default:=default
//+kubebuilder:validation:MinLength:=1
Name string `json:"name,omitempty"`
}
func (*TabletNodesSpec) DeepCopy ¶
func (in *TabletNodesSpec) DeepCopy() *TabletNodesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TabletNodesSpec.
func (*TabletNodesSpec) DeepCopyInto ¶
func (in *TabletNodesSpec) DeepCopyInto(out *TabletNodesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TextLoggerSpec ¶
type TextLoggerSpec struct {
BaseLoggerSpec `json:",inline"`
//+kubebuilder:validation:Enum=file;stderr
WriterType LogWriterType `json:"writerType,omitempty"`
CategoriesFilter *CategoriesFilter `json:"categoriesFilter,omitempty"`
}
func (*TextLoggerSpec) DeepCopy ¶
func (in *TextLoggerSpec) DeepCopy() *TextLoggerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TextLoggerSpec.
func (*TextLoggerSpec) DeepCopyInto ¶
func (in *TextLoggerSpec) DeepCopyInto(out *TextLoggerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TimbertruckSpec ¶
type TimbertruckSpec struct {
Image *string `json:"image,omitempty"`
DirectoryPath *string `json:"directoryPath,omitempty"`
}
TimbertruckSpec configures the timbertruck sidecar that delivers structured logs to the cluster log storage. It is used both cluster-wide (spec.timbertruck) and as a per-component override (e.g. primaryMasters.timbertruck).
func (*TimbertruckSpec) DeepCopy ¶
func (in *TimbertruckSpec) DeepCopy() *TimbertruckSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TimbertruckSpec.
func (*TimbertruckSpec) DeepCopyInto ¶
func (in *TimbertruckSpec) DeepCopyInto(out *TimbertruckSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TracingSpec ¶ added in v0.34.0
type TracingSpec struct {
// Address of the tracing collector gRPC endpoint.
//+kubebuilder:validation:MinLength:=1
CollectorAddress string `json:"collectorAddress"`
// Maximum memory occupied by queued spans.
//+optional
MaxMemory *resource.Quantity `json:"maxMemory,omitempty"`
// Tags attached to the tracing process descriptor.
//+optional
ProcessTags map[string]string `json:"processTags,omitempty"`
}
TracingSpec configures distributed tracing for all YTsaurus server components. Component-specific settings can be applied through configOverrides.
func (*TracingSpec) DeepCopy ¶ added in v0.34.0
func (in *TracingSpec) DeepCopy() *TracingSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TracingSpec.
func (*TracingSpec) DeepCopyInto ¶ added in v0.34.0
func (in *TracingSpec) DeepCopyInto(out *TracingSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type UIClusterURLs ¶
type UIClusterURLs struct {
Icon string `json:"icon"`
Icon2x string `json:"icon2x"`
IconBig *string `json:"iconbig,omitempty"`
}
func (*UIClusterURLs) DeepCopy ¶
func (in *UIClusterURLs) DeepCopy() *UIClusterURLs
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UIClusterURLs.
func (*UIClusterURLs) DeepCopyInto ¶
func (in *UIClusterURLs) DeepCopyInto(out *UIClusterURLs)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type UISpec ¶
type UISpec struct {
PodSpec `json:",inline"`
Image *string `json:"image,omitempty"`
//+kubebuilder:default:=NodePort
ServiceType corev1.ServiceType `json:"serviceType,omitempty"`
HttpNodePort *int32 `json:"httpNodePort,omitempty"`
// If defined allows insecure (over http) authentication.
//+kubebuilder:default:=true
//+optional
UseInsecureCookies bool `json:"useInsecureCookies"`
// Use secure connection to the cluster's http-proxies.
//+kubebuilder:default:=false
//+optional
Secure bool `json:"secure"`
Resources corev1.ResourceRequirements `json:"resources,omitempty"`
InstanceCount int32 `json:"instanceCount,omitempty"`
// If defined it will be used for direct heavy url/commands like: read_table, write_table, etc.
//+optional
ExternalProxy *string `json:"externalProxy,omitempty"`
// Odin is a service for monitoring the availability of YTsaurus clusters.
//+optional
OdinBaseUrl *string `json:"odinBaseUrl,omitempty"`
ExtraEnvVariables []corev1.EnvVar `json:"extraEnvVariables,omitempty"`
//+kubebuilder:default:=testing
Environment string `json:"environment,omitempty"`
//+kubebuilder:default:=lavander
Theme string `json:"theme,omitempty"`
Description *string `json:"description,omitempty"`
Group *string `json:"group,omitempty"`
//+optional
URLs *UIClusterURLs `json:"urls,omitempty"`
// When this is set to false, UI will use backend for downloading instead of proxy.
// If this is set to true or omitted, UI use proxies, which is a default behaviour.
//+optional
DirectDownload *bool `json:"directDownload,omitempty"`
}
func (*UISpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UISpec.
func (*UISpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type UpdateState ¶
type UpdateState string
const ( UpdateStateUndefined UpdateState = "" UpdateStateNone UpdateState = "None" UpdateStateWaitingForImageHeater UpdateState = "WaitingForImageHeater" UpdateStatePossibilityCheck UpdateState = "PossibilityCheck" UpdateStateImpossibleToStart UpdateState = "ImpossibleToStart" UpdateStateWaitingForSafeModeEnabled UpdateState = "WaitingForSafeModeEnabled" UpdateStateWaitingForTabletCellsSaving UpdateState = "WaitingForTabletCellsSaving" UpdateStateWaitingForTabletCellsRemovingStart UpdateState = "WaitingForTabletCellsRemovingStart" UpdateStateWaitingForTabletCellsRemoved UpdateState = "WaitingForTabletCellsRemoved" UpdateStateWaitingForImaginaryChunksAbsence UpdateState = "WaitingForImaginaryChunksAbsence" UpdateStateWaitingForSnapshots UpdateState = "WaitingForSnapshots" UpdateStateWaitingForPodsRemoval UpdateState = "WaitingForPodsRemoval" UpdateStateWaitingForPodsCreation UpdateState = "WaitingForPodsCreation" UpdateStateWaitingForMasterReady UpdateState = "WaitingForMasterReady" UpdateStateWaitingForMasterEnterReadOnly UpdateState = "WaitingForMasterEnterReadOnly" UpdateStateWaitingForMasterExitReadOnly UpdateState = "WaitingForMasterExitReadOnly" UpdateStateWaitingForMasterCellsEnterReadOnly UpdateState = "WaitingForMasterCellsEnterReadOnly" UpdateStateWaitingForMasterCellsExitReadOnly UpdateState = "WaitingForMasterCellsExitReadOnly" UpdateStateWaitingForMasterCellsPreparation UpdateState = "WaitingForMasterCellsPreparation" UpdateStateWaitingForMasterCellsAcception UpdateState = "WaitingForMasterCellsAcception" UpdateStateWaitingForMasterCellsRegistration UpdateState = "WaitingForMasterCellsRegistration" UpdateStateWaitingForMasterCellsSettlement UpdateState = "WaitingForMasterCellsSettlement" UpdateStateWaitingForMasterCellsCompletion UpdateState = "WaitingForMasterCellsCompletion" UpdateStateWaitingForCypressPatch UpdateState = "WaitingForCypressPatch" UpdateStateWaitingForTabletCellsRecovery UpdateState = "WaitingForTabletCellsRecovery" UpdateStateWaitingForOpArchiveUpdate UpdateState = "WaitingForOpArchiveUpdate" UpdateStateWaitingForSidecarsInitializingPrepare UpdateState = "WaitingForSidecarsInitializingPrepare" // TODO: Remove, it holds alignment. UpdateStateWaitingForSidecarsInitialize UpdateState = "WaitingForSidecarsInitialize" UpdateStateWaitingForQTStateUpdatingPrepare UpdateState = "WaitingForQTStateUpdatingPrepare" UpdateStateWaitingForQTStateUpdate UpdateState = "WaitingForQTStateUpdate" UpdateStateWaitingForQAStateUpdatingPrepare UpdateState = "WaitingForQAStateUpdatingPrepare" UpdateStateWaitingForQAStateUpdate UpdateState = "WaitingForQAStateUpdate" UpdateStateWaitingForYqlaUpdate UpdateState = "WaitingForYqlaUpdate" UpdateStateWaitingForSafeModeDisabled UpdateState = "WaitingForSafeModeDisabled" UpdateStateWaitingForTimbertruckPrepared UpdateState = "WaitingForTimbertruckPrepared" )
type UpdateStatus ¶
type UpdateStatus struct {
State UpdateState `json:"state,omitempty"`
// Subset of cluster components currently updating.
UpdatingComponents []Component `json:"updatingComponents,omitempty"`
// Summary for kubectl column.
UpdatingComponentsSummary string `json:"updatingComponentsSummary,omitempty"`
// Summary for kubectl column.
BlockedComponentsSummary string `json:"blockedComponentsSummary,omitempty"`
// Update progress.
Conditions []metav1.Condition `json:"conditions,omitempty"`
// State of master cells maintenance.
MasterCellsMaintenance []MasterCellMaintenanceInfo `json:"masterCellsMaintenance,omitempty"`
// Snapshot of tablet cell bundles.
TabletCellBundles []TabletCellBundleInfo `json:"tabletCellBundles,omitempty"`
// Snapshot of bundle controller.
BundleController *BundleControllerInfo `json:"bundleController,omitempty"`
}
func (*UpdateStatus) DeepCopy ¶
func (in *UpdateStatus) DeepCopy() *UpdateStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpdateStatus.
func (*UpdateStatus) DeepCopyInto ¶
func (in *UpdateStatus) DeepCopyInto(out *UpdateStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Volume ¶
type Volume struct {
// name of the volume.
// Must be a DNS_LABEL and unique within the pod.
// More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names
Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
// volumeSource represents the location and type of the mounted volume.
// If not specified, the Volume is implied to be an EmptyDir.
// This implied behavior is deprecated and will be removed in a future version.
VolumeSource `json:",inline" protobuf:"bytes,2,opt,name=volumeSource"`
}
Volume is a reduced version of core/v1 Volume. Represents a named volume in a pod that may be accessed by any container in the pod.
func (*Volume) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Volume.
func (*Volume) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VolumeSource ¶
type VolumeSource struct {
// hostPath represents a pre-existing file or directory on the host
// machine that is directly exposed to the container. This is generally
// used for system agents or other privileged things that are allowed
// to see the host machine. Most containers will NOT need this.
// More info: https://kubernetes.io/docs/concepts/storage/volumes#hostpath
// +optional
HostPath *corev1.HostPathVolumeSource `json:"hostPath,omitempty" protobuf:"bytes,1,opt,name=hostPath"`
// emptyDir represents a temporary directory that shares a pod's lifetime.
// More info: https://kubernetes.io/docs/concepts/storage/volumes#emptydir
// +optional
EmptyDir *corev1.EmptyDirVolumeSource `json:"emptyDir,omitempty" protobuf:"bytes,2,opt,name=emptyDir"`
// secret represents a secret that should populate this volume.
// More info: https://kubernetes.io/docs/concepts/storage/volumes#secret
// +optional
Secret *corev1.SecretVolumeSource `json:"secret,omitempty" protobuf:"bytes,6,opt,name=secret"`
// nfs represents an NFS mount on the host that shares a pod's lifetime
// More info: https://kubernetes.io/docs/concepts/storage/volumes#nfs
// +optional
NFS *corev1.NFSVolumeSource `json:"nfs,omitempty" protobuf:"bytes,7,opt,name=nfs"`
// iscsi represents an ISCSI Disk resource that is attached to a
// kubelet's host machine and then exposed to the pod.
// More info: https://examples.k8s.io/volumes/iscsi/README.md
// +optional
ISCSI *corev1.ISCSIVolumeSource `json:"iscsi,omitempty" protobuf:"bytes,8,opt,name=iscsi"`
// persistentVolumeClaimVolumeSource represents a reference to a
// PersistentVolumeClaim in the same namespace.
// More info: https://kubernetes.io/docs/concepts/storage/persistent-volumes#persistentvolumeclaims
// +optional
PersistentVolumeClaim *corev1.PersistentVolumeClaimVolumeSource `json:"persistentVolumeClaim,omitempty" protobuf:"bytes,10,opt,name=persistentVolumeClaim"`
// downwardAPI represents downward API about the pod that should populate this volume
// +optional
DownwardAPI *corev1.DownwardAPIVolumeSource `json:"downwardAPI,omitempty" protobuf:"bytes,16,opt,name=downwardAPI"`
// fc represents a Fibre Channel resource that is attached to a kubelet's host machine and then exposed to the pod.
// +optional
FC *corev1.FCVolumeSource `json:"fc,omitempty" protobuf:"bytes,17,opt,name=fc"`
// configMap represents a configMap that should populate this volume
// +optional
ConfigMap *corev1.ConfigMapVolumeSource `json:"configMap,omitempty" protobuf:"bytes,19,opt,name=configMap"`
// csi (Container Storage Interface) represents ephemeral storage that is handled by certain external CSI drivers (Beta feature).
// +optional
CSI *corev1.CSIVolumeSource `json:"csi,omitempty" protobuf:"bytes,28,opt,name=csi"`
// ephemeral represents a volume that is handled by a cluster storage driver.
// The volume's lifecycle is tied to the pod that defines it - it will be created before the pod starts,
// and deleted when the pod is removed.
//
// Use this if:
// a) the volume is only needed while the pod runs,
// b) features of normal volumes like restoring from snapshot or capacity
// tracking are needed,
// c) the storage driver is specified through a storage class, and
// d) the storage driver supports dynamic volume provisioning through
// a PersistentVolumeClaim (see EphemeralVolumeSource for more
// information on the connection between this volume type
// and PersistentVolumeClaim).
//
// Use PersistentVolumeClaim or one of the vendor-specific
// APIs for volumes that persist for longer than the lifecycle
// of an individual pod.
//
// Use CSI for light-weight local ephemeral volumes if the CSI driver is meant to
// be used that way - see the documentation of the driver for
// more information.
//
// A pod can use both types of ephemeral volumes and
// persistent volumes at the same time.
//
// +optional
Ephemeral *corev1.EphemeralVolumeSource `json:"ephemeral,omitempty" protobuf:"bytes,29,opt,name=ephemeral"`
// image represents an OCI object (a container image or artifact) pulled and mounted on the kubelet's host machine.
// The volume is resolved at pod startup depending on which PullPolicy value is provided:
//
// - Always: the kubelet always attempts to pull the reference. Container creation will fail If the pull fails.
// - Never: the kubelet never pulls the reference and only uses a local image or artifact. Container creation will fail if the reference isn't present.
// - IfNotPresent: the kubelet pulls if the reference isn't already present on disk. Container creation will fail if the reference isn't present and the pull fails.
//
// The volume gets re-resolved if the pod gets deleted and recreated, which means that new remote content will become available on pod recreation.
// A failure to resolve or pull the image during pod startup will block containers from starting and may add significant latency. Failures will be retried using normal volume backoff and will be reported on the pod reason and message.
// The types of objects that may be mounted by this volume are defined by the container runtime implementation on a host machine and at minimum must include all valid types supported by the container image field.
// The OCI object gets mounted in a single directory (spec.containers[*].volumeMounts.mountPath) by merging the manifest layers in the same way as for container images.
// The volume will be mounted read-only (ro) and non-executable files (noexec).
// Sub path mounts for containers are not supported (spec.containers[*].volumeMounts.subpath).
// The field spec.securityContext.fsGroupChangePolicy has no effect on this volume type.
// +featureGate=ImageVolume
// +optional
Image *corev1.ImageVolumeSource `json:"image,omitempty" protobuf:"bytes,30,opt,name=image"`
}
VolumeSource is a reduced version of core/v1 VolumeSource. Represents the source of a volume to mount. Only one of its members may be specified.
func (*VolumeSource) DeepCopy ¶
func (in *VolumeSource) DeepCopy() *VolumeSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VolumeSource.
func (*VolumeSource) DeepCopyInto ¶
func (in *VolumeSource) DeepCopyInto(out *VolumeSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type YQLAgentSpec ¶
type YQLAgentSpec struct {
InstanceSpec `json:",inline"`
// YQL DQ engine executes simple requests using shared pool of vanilla jobs.
// Tuning for unwired parameters could be done in config overrides and entrypoint wrapper.
DQEngine *YQLDQEngineSpec `json:"dqEngine,omitempty"`
}
func (*YQLAgentSpec) DeepCopy ¶
func (in *YQLAgentSpec) DeepCopy() *YQLAgentSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new YQLAgentSpec.
func (*YQLAgentSpec) DeepCopyInto ¶
func (in *YQLAgentSpec) DeepCopyInto(out *YQLAgentSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type YQLDQEngineSpec ¶ added in v0.32.0
type YQLDQEngineSpec struct {
// DQ max jobs count
MaxJobs *int `json:"maxJobs,omitempty"`
// DQ jobs per operation
JobsPerOperation *int `json:"jobsPerOperation,omitempty"`
// DQ requests per job
WorkerCapacity *int `json:"workerCapacity,omitempty"`
// DQ operation pool
Pool string `json:"pool,omitempty"`
// DQ operation pool_trees
PoolTrees []string `json:"poolTrees,omitempty"`
// DQ operation scheduling_tag_filter
SchedulingTagFilter string `json:"schedulingTagFilter,omitempty"`
// DQ operation cpu_limit
CPULimit *resource.Quantity `json:"cpuLimit,omitempty"`
// DQ operation memory_limit
MemoryLimit *resource.Quantity `json:"memoryLimit,omitempty"`
// DQ operation artifacts cache size
CacheSize *resource.Quantity `json:"cacheSize,omitempty"`
// DQ operation use tmpfs for artifacts
UseTmpFS *bool `json:"useTmpfs,omitempty"`
// DQ artifacts replication_factor
UploadReplicationFactor *int `json:"uploadReplicationFactor,omitempty"`
// DQ gateway default settings
GatewayDefaultSettings []YQLGatewayAttrSpec `json:"gatewayDefaultSettings,omitempty"`
}
func (*YQLDQEngineSpec) DeepCopy ¶ added in v0.32.0
func (in *YQLDQEngineSpec) DeepCopy() *YQLDQEngineSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new YQLDQEngineSpec.
func (*YQLDQEngineSpec) DeepCopyInto ¶ added in v0.32.0
func (in *YQLDQEngineSpec) DeepCopyInto(out *YQLDQEngineSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type YQLGatewayAttrSpec ¶ added in v0.32.0
func (*YQLGatewayAttrSpec) DeepCopy ¶ added in v0.32.0
func (in *YQLGatewayAttrSpec) DeepCopy() *YQLGatewayAttrSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new YQLGatewayAttrSpec.
func (*YQLGatewayAttrSpec) DeepCopyInto ¶ added in v0.32.0
func (in *YQLGatewayAttrSpec) DeepCopyInto(out *YQLGatewayAttrSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Ytsaurus ¶
type Ytsaurus struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec YtsaurusSpec `json:"spec,omitempty"`
Status YtsaurusStatus `json:"status,omitempty"`
}
Ytsaurus is the Schema for the ytsaurus API
func (*Ytsaurus) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Ytsaurus.
func (*Ytsaurus) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Ytsaurus) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Ytsaurus) GetStatusConditions ¶
func (*Ytsaurus) GetStatusObservedGeneration ¶
func (*Ytsaurus) GetUpdatePlan ¶
func (r *Ytsaurus) GetUpdatePlan() []ComponentUpdateSelector
func (*Ytsaurus) SetStatusConditions ¶
func (*Ytsaurus) SetStatusObservedGeneration ¶
type YtsaurusList ¶
type YtsaurusList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []Ytsaurus `json:"items"`
}
YtsaurusList contains a list of Ytsaurus
func (*YtsaurusList) DeepCopy ¶
func (in *YtsaurusList) DeepCopy() *YtsaurusList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new YtsaurusList.
func (*YtsaurusList) DeepCopyInto ¶
func (in *YtsaurusList) DeepCopyInto(out *YtsaurusList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*YtsaurusList) DeepCopyObject ¶
func (in *YtsaurusList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type YtsaurusSpec ¶
type YtsaurusSpec struct {
CommonSpec `json:",inline"`
// Default settings for instance and init job pods.
PodSpec `json:",inline"`
UIImage string `json:"uiImage,omitempty"`
// requiresOperatorVersion is used to lock the YT spec to an Operator version or range.
// Syntax: https://github.com/Masterminds/semver
// Example: "~0.1.2" is equivalent to ">= 0.1.2, < 0.2.0".
//+optional
RequiresOperatorVersion string `json:"requiresOperatorVersion,omitempty"`
// Reference to secret with initial "login", "password", "token" for administrator user.
// If secret is not specified or does not exist default admin/password is no longer set.
AdminCredentials *corev1.LocalObjectReference `json:"adminCredentials,omitempty"`
OauthService *OauthServiceSpec `json:"oauthService,omitempty"`
// Setting to false disables all operator actions. Default: true.
//+kubebuilder:default:=true
IsManaged *bool `json:"isManaged,omitempty"`
// Defines components which are allowed to update.
// Can contain either single "class" item or several "component" items.
// When empty: update nothing
UpdatePlan []ComponentUpdateSelector `json:"updatePlan,omitempty"`
Bootstrap *BootstrapSpec `json:"bootstrap,omitempty"`
Discovery DiscoverySpec `json:"discovery,omitempty"`
PrimaryMasters MastersSpec `json:"primaryMasters,omitempty"`
//+kubebuilder:validation:MaxItems:=48
SecondaryMasters []MastersSpec `json:"secondaryMasters,omitempty"`
//+optional
MasterCaches *MasterCachesSpec `json:"masterCaches,omitempty"`
//+kubebuilder:validation:MinItems:=1
HTTPProxies []HTTPProxiesSpec `json:"httpProxies,omitempty"`
RPCProxies []RPCProxiesSpec `json:"rpcProxies,omitempty"`
TCPProxies []TCPProxiesSpec `json:"tcpProxies,omitempty"`
KafkaProxies []KafkaProxiesSpec `json:"kafkaProxies,omitempty"`
//+kubebuilder:validation:MinItems:=1
DataNodes []DataNodesSpec `json:"dataNodes,omitempty"`
ExecNodes []ExecNodesSpec `json:"execNodes,omitempty"`
Schedulers *SchedulersSpec `json:"schedulers,omitempty"`
ControllerAgents *ControllerAgentsSpec `json:"controllerAgents,omitempty"`
TabletNodes []TabletNodesSpec `json:"tabletNodes,omitempty"`
StrawberryController *StrawberryControllerSpec `json:"strawberry,omitempty"`
QueryTrackers *QueryTrackerSpec `json:"queryTrackers,omitempty"`
Spyt *DeprecatedSpytSpec `json:"spyt,omitempty"`
YQLAgents *YQLAgentSpec `json:"yqlAgents,omitempty"`
QueueAgents *QueueAgentSpec `json:"queueAgents,omitempty"`
CypressProxies *CypressProxiesSpec `json:"cypressProxies,omitempty"`
BundleController *BundleControllerSpec `json:"bundleController,omitempty"`
TabletBalancer *TabletBalancerSpec `json:"tabletBalancers,omitempty"`
UI *UISpec `json:"ui,omitempty"`
}
YtsaurusSpec defines the desired state of Ytsaurus
func (*YtsaurusSpec) DeepCopy ¶
func (in *YtsaurusSpec) DeepCopy() *YtsaurusSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new YtsaurusSpec.
func (*YtsaurusSpec) DeepCopyInto ¶
func (in *YtsaurusSpec) DeepCopyInto(out *YtsaurusSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type YtsaurusStatus ¶
type YtsaurusStatus struct {
//+kubebuilder:default:=Created
State ClusterState `json:"state,omitempty"`
Conditions []metav1.Condition `json:"conditions,omitempty"`
// Reflects resource generation which was used for updating status.
ObservedGeneration int64 `json:"observedGeneration,omitempty"`
UpdateStatus UpdateStatus `json:"updateStatus,omitempty"`
}
YtsaurusStatus defines the observed state of Ytsaurus
func (*YtsaurusStatus) DeepCopy ¶
func (in *YtsaurusStatus) DeepCopy() *YtsaurusStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new YtsaurusStatus.
func (*YtsaurusStatus) DeepCopyInto ¶
func (in *YtsaurusStatus) DeepCopyInto(out *YtsaurusStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.