v1

package
v0.35.0 Latest Latest
Warning

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

Go to latest
Published: Aug 18, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package v1 contains API Schema definitions for the cluster v1 API group +kubebuilder:object:generate=true +groupName=cluster.ytsaurus.tech

Index

Constants

This section is empty.

Variables

View Source
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 KnownListTypes() []runtime.Object

func KnownObjectTypes

func KnownObjectTypes() []runtime.Object

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

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

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

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

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

func (in *Chyt) DeepCopy() *Chyt

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

func (*Chyt) DeepCopyInto

func (in *Chyt) DeepCopyInto(out *Chyt)

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

func (*Chyt) DeepCopyObject

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

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

func (*Chyt) GetStatusConditions

func (r *Chyt) GetStatusConditions() []metav1.Condition

func (*Chyt) GetStatusObservedGeneration

func (r *Chyt) GetStatusObservedGeneration() int64

FIXME: Add ObservedGeneration.

func (*Chyt) SetStatusConditions

func (r *Chyt) SetStatusConditions(conditions []metav1.Condition)

func (*Chyt) SetStatusObservedGeneration

func (r *Chyt) SetStatusObservedGeneration(generation int64)

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

func (in *ChytList) DeepCopy() *ChytList

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

func (*ChytList) DeepCopyInto

func (in *ChytList) DeepCopyInto(out *ChytList)

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

func (*ChytList) DeepCopyObject

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

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

func (in *ChytSpec) DeepCopy() *ChytSpec

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

func (*ChytSpec) DeepCopyInto

func (in *ChytSpec) DeepCopyInto(out *ChytSpec)

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

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

func (in *Component) DeepCopy() *Component

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

func (*Component) DeepCopyInto

func (in *Component) DeepCopyInto(out *Component)

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

func (*Component) String

func (c *Component) String() string

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

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

func (*ComponentOnDeleteUpdateMode) DeepCopyInto

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

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

func (*ComponentRollingUpdateMode) DeepCopyInto

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

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

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

type ControllerAgentsSpec

type ControllerAgentsSpec struct {
	// label filter (for daemonset)
	InstanceSpec `json:",inline"`
}

func (*ControllerAgentsSpec) DeepCopy

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

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

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

func (*EmbeddedPersistentVolumeClaim) DeepCopyInto

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

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

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

func (*HydraPersistenceUploaderSpec) DeepCopyInto

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

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 LogFormat

type LogFormat string
const (
	LogFormatPlainText LogFormat = "plain_text"
	LogFormatYson      LogFormat = "yson"
	LogFormatJson      LogFormat = "json"
)

type LogLevel

type LogLevel string

LogLevel string describes possible Ytsaurus logging level. +enum

const (
	LogLevelTrace   LogLevel = "trace"
	LogLevelDebug   LogLevel = "debug"
	LogLevelInfo    LogLevel = "info"
	LogLevelWarning LogLevel = "warning"
	LogLevelError   LogLevel = "error"
)

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

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

func (*MasterCachesConnectionSpec) DeepCopyInto

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

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

func (*MasterCellMaintenanceInfo) DeepCopyInto added in v0.35.0

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

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

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

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

func (*OauthUserLoginTransformation) DeepCopyInto

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

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

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

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

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

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

func (*OffshoreDataGatewaysStatus) DeepCopyInto

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

func (in *PodSpec) DeepCopy() *PodSpec

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

func (*PodSpec) DeepCopyInto

func (in *PodSpec) DeepCopyInto(out *PodSpec)

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

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

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

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

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

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

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

func (in *Spyt) DeepCopy() *Spyt

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

func (*Spyt) DeepCopyInto

func (in *Spyt) DeepCopyInto(out *Spyt)

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

func (*Spyt) DeepCopyObject

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

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

func (*Spyt) GetStatusConditions

func (r *Spyt) GetStatusConditions() []metav1.Condition

func (*Spyt) GetStatusObservedGeneration

func (r *Spyt) GetStatusObservedGeneration() int64

FIXME: Add ObservedGeneration.

func (*Spyt) SetStatusConditions

func (r *Spyt) SetStatusConditions(conditions []metav1.Condition)

func (*Spyt) SetStatusObservedGeneration

func (r *Spyt) SetStatusObservedGeneration(generation int64)

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

func (in *SpytList) DeepCopy() *SpytList

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

func (*SpytList) DeepCopyInto

func (in *SpytList) DeepCopyInto(out *SpytList)

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

func (*SpytList) DeepCopyObject

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

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

func (in *SpytSpec) DeepCopy() *SpytSpec

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

func (*SpytSpec) DeepCopyInto

func (in *SpytSpec) DeepCopyInto(out *SpytSpec)

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

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

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

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

func (in *UISpec) DeepCopy() *UISpec

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

func (*UISpec) DeepCopyInto

func (in *UISpec) DeepCopyInto(out *UISpec)

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

func (in *Volume) DeepCopy() *Volume

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

func (*Volume) DeepCopyInto

func (in *Volume) DeepCopyInto(out *Volume)

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

type YQLGatewayAttrSpec struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

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

func (in *Ytsaurus) DeepCopy() *Ytsaurus

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

func (*Ytsaurus) DeepCopyInto

func (in *Ytsaurus) DeepCopyInto(out *Ytsaurus)

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

func (*Ytsaurus) DeepCopyObject

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

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

func (*Ytsaurus) GetStatusConditions

func (r *Ytsaurus) GetStatusConditions() []metav1.Condition

func (*Ytsaurus) GetStatusObservedGeneration

func (r *Ytsaurus) GetStatusObservedGeneration() int64

func (*Ytsaurus) GetUpdatePlan

func (r *Ytsaurus) GetUpdatePlan() []ComponentUpdateSelector

func (*Ytsaurus) SetStatusConditions

func (r *Ytsaurus) SetStatusConditions(conditions []metav1.Condition)

func (*Ytsaurus) SetStatusObservedGeneration

func (r *Ytsaurus) SetStatusObservedGeneration(generation int64)

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.

Jump to

Keyboard shortcuts

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