v1

package
v0.0.0-...-cfe22c1 Latest Latest
Warning

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

Go to latest
Published: Apr 26, 2024 License: Apache-2.0 Imports: 19 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

View Source
const (
	YtsaurusName = "test-ytsaurus"
	// RemoteResourceName is a name for test remote ytsaurus and nodes.
	// It is short because of error:
	// `Failed to create pod sandbox: failed to construct FQDN from pod hostname and cluster domain, FQDN
	// <...> is too long (64 characters is the max, 67 characters requested)`.
	RemoteResourceName = "tst-rmt"
	// Images should be in sync with TEST_IMAGES variable in Makefile
	// todo: come up with a more elegant solution
	CoreImageFirst   = "ytsaurus/ytsaurus-nightly:dev-23.1-9779e0140ff73f5a786bd5362313ef9a74fcd0de"
	CoreImageSecond  = "ytsaurus/ytsaurus-nightly:dev-23.1-28ccaedbf353b870bedafb6e881ecf386a0a3779"
	CoreImageNextVer = "ytsaurus/ytsaurus-nightly:dev-23.2-9c50056eacfa4fe213798a5b9ee828ae3acb1bca"
)

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 = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

func IsReadyToUpdateClusterState

func IsReadyToUpdateClusterState(clusterState ClusterState) bool

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;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"`
	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"`
}

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 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 CRIJobEnvironmentSpec

type CRIJobEnvironmentSpec struct {
	// Specifies wrapper for CRI service (i.e. containerd) command.
	//+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"`
}

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 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) Default

func (r *Chyt) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Chyt) SetupWebhookWithManager

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

func (*Chyt) ValidateCreate

func (r *Chyt) ValidateCreate() (admission.Warnings, error)

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

func (*Chyt) ValidateDelete

func (r *Chyt) ValidateDelete() (admission.Warnings, error)

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

func (*Chyt) ValidateUpdate

func (r *Chyt) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

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

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"`
	//+kubebuilder:default:=false
	MakeDefault bool `json:"makeDefault"`
}

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 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 ClusterState

type ClusterState string
const (
	ClusterStateCreated         ClusterState = "Created"
	ClusterStateInitializing    ClusterState = "Initializing"
	ClusterStateRunning         ClusterState = "Running"
	ClusterStateReconfiguration ClusterState = "Reconfiguration"
	ClusterStateUpdating        ClusterState = "Updating"
	ClusterStateUpdateFinishing ClusterState = "UpdateFinishing"
	ClusterStateCancelUpdate    ClusterState = "CancelUpdate"
)

type CommonSpec

type CommonSpec struct {
	CoreImage string `json:"coreImage,omitempty"`

	// Default docker image for user jobs.
	//+optional
	JobImage *string `json:"jobImage,omitempty"`

	// Reference to ConfigMap with trusted certificates: "ca.crt".
	//+optional
	CABundle *corev1.LocalObjectReference `json:"caBundle,omitempty"`

	// Common config for native RPC bus transport.
	//+optional
	NativeTransport *RPCTransportSpec `json:"nativeTransport,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"`
	//+kubebuilder:default:=true
	//+optional
	UseShortNames bool `json:"useShortNames"`
	//+kubebuilder:default:=false
	//+optional
	UsePorto bool `json:"usePorto"`
	//+kubebuilder:default:=false
	//+optional
	HostNetwork bool `json:"hostNetwork"`

	ExtraPodAnnotations map[string]string `json:"extraPodAnnotations,omitempty"`

	ConfigOverrides  *corev1.LocalObjectReference  `json:"configOverrides,omitempty"`
	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 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 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 sidecar containers as yaml of corev1.Container.
	Sidecars []string `json:"sidecars,omitempty"`
	//+kubebuilder:default:=true
	//+optional
	Privileged      bool             `json:"privileged"`
	JobProxyLoggers []TextLoggerSpec `json:"jobProxyLoggers,omitempty"`
	// Resources dedicated for running jobs.
	//+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 HTTPProxiesSpec

type HTTPProxiesSpec struct {
	InstanceSpec `json:",inline"`
	//+kubebuilder:default:=NodePort
	ServiceType   corev1.ServiceType `json:"serviceType,omitempty"`
	HttpNodePort  *int32             `json:"httpNodePort,omitempty"`
	HttpsNodePort *int32             `json:"httpsNodePort,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 InstanceSpec

type InstanceSpec struct {
	// Overrides coreImage for component.
	//+optional
	Image *string `json:"image,omitempty"`
	// Specifies wrapper for component container command.
	//+optional
	EntrypointWrapper []string             `json:"entrypointWrapper,omitempty"`
	Volumes           []corev1.Volume      `json:"volumes,omitempty"`
	VolumeMounts      []corev1.VolumeMount `json:"volumeMounts,omitempty"`
	//+optional
	ReadinessProbeParams  *HealthcheckProbeParams         `json:"readinessProbeParams,omitempty"`
	Resources             corev1.ResourceRequirements     `json:"resources,omitempty"`
	InstanceCount         int32                           `json:"instanceCount,omitempty"`
	MinReadyInstanceCount *int                            `json:"minReadyInstanceCount,omitempty"`
	Locations             []LocationSpec                  `json:"locations,omitempty"`
	VolumeClaimTemplates  []EmbeddedPersistentVolumeClaim `json:"volumeClaimTemplates,omitempty"`
	//+optional
	RuntimeClassName *string `json:"runtimeClassName,omitempty"`
	// Deprecated: use Affinity.PodAntiAffinity instead.
	EnableAntiAffinity *bool `json:"enableAntiAffinity,omitempty"`
	//+optional
	MonitoringPort    *int32                 `json:"monitoringPort,omitempty"`
	Loggers           []TextLoggerSpec       `json:"loggers,omitempty"`
	StructuredLoggers []StructuredLoggerSpec `json:"structuredLoggers,omitempty"`
	Affinity          *corev1.Affinity       `json:"affinity,omitempty"`
	NodeSelector      map[string]string      `json:"nodeSelector,omitempty"`
	Tolerations       []corev1.Toleration    `json:"tolerations,omitempty"`
	// Component config for native RPC bus transport.
	//+optional
	NativeTransport *RPCTransportSpec `json:"nativeTransport,omitempty"`
}

func CreateDataNodeInstanceSpec

func CreateDataNodeInstanceSpec(instanceCount int) InstanceSpec

func CreateExecNodeInstanceSpec

func CreateExecNodeInstanceSpec() InstanceSpec

func CreateTabletNodeSpec

func CreateTabletNodeSpec(instanceCount int) InstanceSpec

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"`
}

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 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"`
}

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"
)

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"
	LogLevelError LogLevel = "error"
)

type LogRotationPolicy

type LogRotationPolicy struct {
	RotationPeriodMilliseconds *int64 `json:"rotationPeriodMilliseconds,omitempty" yson:"rotation_period,omitempty"`
	MaxSegmentSize             *int64 `json:"maxSegmentSize,omitempty" yson:"max_segment_size,omitempty"`
	MaxTotalSizeToKeep         *int64 `json:"maxTotalSizeToKeep,omitempty" yson:"max_total_size_to_keep,omitempty"`
	MaxSegmentCountToKeep      *int64 `json:"maxSegmentCountToKeep,omitempty" yson:"max_segment_count_to_keep,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 {
	CellTag       int16    `json:"cellTagMasterCaches"`
	HostAddresses []string `json:"hostAddressesMasterCaches,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"`
}

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 MasterConnectionSpec

type MasterConnectionSpec struct {
	CellTag       int16    `json:"cellTag"`
	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"`

	HostAddressLabel string `json:"hostAddressLabel,omitempty"`

	MaxSnapshotCountToKeep  *int `json:"maxSnapshotCountToKeep,omitempty"`
	MaxChangelogCountToKeep *int `json:"maxChangelogCountToKeep,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 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"`
}

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"`
}

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 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 {
	// Reference to kubernetes.io/tls secret.
	//+optional
	TLSSecret *corev1.LocalObjectReference `json:"tlsSecret,omitempty"`
	// Require encrypted connections, otherwise only when required by peer.
	//+optional
	TLSRequired bool `json:"tlsRequired,omitempty"`
	// Disable TLS certificate verification.
	//+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 RemoteExecNodeReleaseStatus

type RemoteExecNodeReleaseStatus string
const (
	RemoteExecNodeReleaseStatusPending RemoteExecNodeReleaseStatus = "Pending"
	RemoteExecNodeReleaseStatusRunning RemoteExecNodeReleaseStatus = "Running"
)

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.

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 {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "make" to regenerate code after modifying this file
	ReleaseStatus RemoteExecNodeReleaseStatus `json:"releaseStatus,omitempty"`
}

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 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 {
	MasterConnectionSpec `json:",inline"`
	MasterCachesSpec     `json:",inline"`
}

RemoteYtsaurusSpec defines the desired state of RemoteYtsaurus

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) Default

func (r *Spyt) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Spyt) SetupWebhookWithManager

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

func (*Spyt) ValidateCreate

func (r *Spyt) ValidateCreate() (admission.Warnings, error)

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

func (*Spyt) ValidateDelete

func (r *Spyt) ValidateDelete() (admission.Warnings, error)

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

func (*Spyt) ValidateUpdate

func (r *Spyt) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

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

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"`
}

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 {
	Resources corev1.ResourceRequirements `json:"resources,omitempty"`
	Image     *string                     `json:"image,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"`
	Category       string `json:"category,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 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 UISpec

type UISpec struct {
	Image *string `json:"image,omitempty"`
	//+kubebuilder:default:=NodePort
	ServiceType  corev1.ServiceType `json:"serviceType,omitempty"`
	HttpNodePort *int32             `json:"httpNodePort,omitempty"`
	//+kubebuilder:default:=true
	//+optional
	UseInsecureCookies bool                        `json:"useInsecureCookies"`
	Resources          corev1.ResourceRequirements `json:"resources,omitempty"`
	InstanceCount      int32                       `json:"instanceCount,omitempty"`

	//+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"`
}

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 UpdateFlow

type UpdateFlow string
const (
	UpdateFlowNone        UpdateFlow = ""
	UpdateFlowStateless   UpdateFlow = "Stateless"
	UpdateFlowMaster      UpdateFlow = "Master"
	UpdateFlowTabletNodes UpdateFlow = "TabletNodes"
	UpdateFlowFull        UpdateFlow = "Full"
)

type UpdateSelector

type UpdateSelector string
const (
	// UpdateSelectorUnspecified means that selector is disabled and would be ignored completely.
	UpdateSelectorUnspecified UpdateSelector = ""
	// UpdateSelectorNothing means that no component could be updated.
	UpdateSelectorNothing UpdateSelector = "Nothing"
	// UpdateSelectorStatelessOnly means that only stateless components (everything but master and tablet nodes)
	// could be updated.
	UpdateSelectorStatelessOnly UpdateSelector = "StatelessOnly"
	// UpdateSelectorMasterOnly means that only master could be updated.
	UpdateSelectorMasterOnly UpdateSelector = "MasterOnly"
	// UpdateSelectorTabletNodesOnly means that only tablet nodes could be updated
	UpdateSelectorTabletNodesOnly UpdateSelector = "TabletNodesOnly"
	// UpdateSelectorExecNodesOnly means that only tablet nodes could be updated
	UpdateSelectorExecNodesOnly UpdateSelector = "ExecNodesOnly"
	// UpdateSelectorEverything means that all components could be updated.
	// With this setting and if master or tablet nodes need update all the components would be updated.
	UpdateSelectorEverything UpdateSelector = "Everything"
)

type UpdateState

type UpdateState string
const (
	UpdateStateNone                               UpdateState = "None"
	UpdateStatePossibilityCheck                   UpdateState = "PossibilityCheck"
	UpdateStateImpossibleToStart                  UpdateState = "ImpossibleToStart"
	UpdateStateWaitingForSafeModeEnabled          UpdateState = "WaitingForSafeModeEnabled"
	UpdateStateWaitingForTabletCellsSaving        UpdateState = "WaitingForTabletCellsSaving"
	UpdateStateWaitingForTabletCellsRemovingStart UpdateState = "WaitingForTabletCellsRemovingStart"
	UpdateStateWaitingForTabletCellsRemoved       UpdateState = "WaitingForTabletCellsRemoved"
	UpdateStateWaitingForSnapshots                UpdateState = "WaitingForSnapshots"
	UpdateStateWaitingForPodsRemoval              UpdateState = "WaitingForPodsRemoval"
	UpdateStateWaitingForPodsCreation             UpdateState = "WaitingForPodsCreation"
	UpdateStateWaitingForMasterExitReadOnly       UpdateState = "WaitingForMasterExitReadOnly"
	UpdateStateWaitingForTabletCellsRecovery      UpdateState = "WaitingForTabletCellsRecovery"
	UpdateStateWaitingForOpArchiveUpdatingPrepare UpdateState = "WaitingForOpArchiveUpdatingPrepare"
	UpdateStateWaitingForOpArchiveUpdate          UpdateState = "WaitingForOpArchiveUpdate"
	UpdateStateWaitingForQTStateUpdatingPrepare   UpdateState = "WaitingForQTStateUpdatingPrepare"
	UpdateStateWaitingForQTStateUpdate            UpdateState = "WaitingForQTStateUpdate"
	UpdateStateWaitingForSafeModeDisabled         UpdateState = "WaitingForSafeModeDisabled"
)

type UpdateStatus

type UpdateStatus struct {
	//+kubebuilder:default:=None
	State      UpdateState `json:"state,omitempty"`
	Components []string    `json:"components,omitempty"`
	// Flow is an internal field that is needed to persist the chosen flow until the end of an update.
	// Flow can be on of ""(unspecified), Stateless, Master, TabletNodes, Full and update cluster stage
	// executes steps corresponding to that update flow.
	Flow                  UpdateFlow             `json:"flow,omitempty"`
	Conditions            []metav1.Condition     `json:"conditions,omitempty"`
	TabletCellBundles     []TabletCellBundleInfo `json:"tabletCellBundles,omitempty"`
	MasterMonitoringPaths []string               `json:"masterMonitoringPaths,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 YQLAgentSpec

type YQLAgentSpec struct {
	InstanceSpec `json:",inline"`
}

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 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 CreateBaseYtsaurusResource

func CreateBaseYtsaurusResource(namespace string) *Ytsaurus

func CreateMinimalYtsaurusResource

func CreateMinimalYtsaurusResource(namespace string) *Ytsaurus

func WithBootstrap

func WithBootstrap(ytsaurus *Ytsaurus) *Ytsaurus

func WithControllerAgents

func WithControllerAgents(ytsaurus *Ytsaurus) *Ytsaurus

func WithDataNodes

func WithDataNodes(ytsaurus *Ytsaurus) *Ytsaurus

TODO (l0kix2): merge with ytconfig build spec helpers.

func WithDataNodesCount

func WithDataNodesCount(ytsaurus *Ytsaurus, count int) *Ytsaurus

func WithExecNodes

func WithExecNodes(ytsaurus *Ytsaurus) *Ytsaurus

func WithQueryTracker

func WithQueryTracker(ytsaurus *Ytsaurus) *Ytsaurus

func WithRPCProxies

func WithRPCProxies(ytsaurus *Ytsaurus) *Ytsaurus

func WithScheduler

func WithScheduler(ytsaurus *Ytsaurus) *Ytsaurus

func WithTabletNodes

func WithTabletNodes(ytsaurus *Ytsaurus) *Ytsaurus

func WithTabletNodesCount

func WithTabletNodesCount(ytsaurus *Ytsaurus, count int) *Ytsaurus

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) Default

func (r *Ytsaurus) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Ytsaurus) SetupWebhookWithManager

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

func (*Ytsaurus) ValidateCreate

func (r *Ytsaurus) ValidateCreate() (admission.Warnings, error)

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

func (*Ytsaurus) ValidateDelete

func (r *Ytsaurus) ValidateDelete() (admission.Warnings, error)

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

func (*Ytsaurus) ValidateUpdate

func (r *Ytsaurus) ValidateUpdate(oldObject runtime.Object) (admission.Warnings, error)

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

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"`
	UIImage    string `json:"uiImage,omitempty"`

	AdminCredentials *corev1.LocalObjectReference `json:"adminCredentials,omitempty"`

	OauthService *OauthServiceSpec `json:"oauthService,omitempty"`

	//+kubebuilder:default:=true
	//+optional
	IsManaged bool `json:"isManaged"`
	//+kubebuilder:default:=true
	//+optional
	EnableFullUpdate bool `json:"enableFullUpdate"`
	//+optional
	//+kubebuilder:validation:Enum={"","Nothing","StatelessOnly","MasterOnly","TabletNodesOnly","ExecNodesOnly","Everything"}
	// UpdateSelector is an experimental field. Behaviour may change.
	// If UpdateSelector is not empty EnableFullUpdate is ignored.
	UpdateSelector UpdateSelector `json:"updateSelector"`

	Bootstrap *BootstrapSpec `json:"bootstrap,omitempty"`

	Discovery        DiscoverySpec `json:"discovery,omitempty"`
	PrimaryMasters   MastersSpec   `json:"primaryMasters,omitempty"`
	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"`
	// +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"`
	DeprecatedChytController *StrawberryControllerSpec `json:"chyt,omitempty"`
	QueryTrackers            *QueryTrackerSpec         `json:"queryTrackers,omitempty"`
	Spyt                     *DeprecatedSpytSpec       `json:"spyt,omitempty"`
	YQLAgents                *YQLAgentSpec             `json:"yqlAgents,omitempty"`
	QueueAgents              *QueueAgentSpec           `json:"queueAgents,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"`

	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