components

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: 46 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SysBundle     string = "sys"
	DefaultBundle string = "default"
)
View Source 
const ChytInitClusterJobConfigFileName = "chyt-init-cluster.yson"
View Source 
const ControllerConfigFileName = "strawberry-controller.yson"
View Source 
const (
	JsPrologue string = "module.exports = "
)
View Source 
const (
	// OnDeleteUpdateModeWarningTimeout is the duration after which a warning is logged
	// if the component is still waiting for manual pod deletion in OnDelete mode
	OnDeleteUpdateModeWarningTimeout = 15 * 60 // 15 minutes in seconds
)
View Source 
const UIClustersConfigFileName = "clusters-config.json"
View Source 
const UICustomConfigFileName = "common.js"

Variables

This section is empty.

Functions

func AddAffinity 

func AddAffinity(statefulSet *appsv1.StatefulSet,
	nodeSelectorRequirementKey string,
	nodeSelectorRequirementValues []string)

func AddInitContainersToPodSpec 

func AddInitContainersToPodSpec(initContainers []string, podSpec *corev1.PodSpec) error

func AddSidecarsToPodSpec 

func AddSidecarsToPodSpec(sidecar []string, podSpec *corev1.PodSpec) error

func AppendPathAcl 

func AppendPathAcl(path string, acl yt.ACE) (string, error)

func CheckPathPermission added in v0.32.0 

func CheckPathPermission(path, subject, permission string) string

func CreateTabletCells 

func CreateTabletCells(ctx context.Context, ytClient yt.Client, bundle string, tabletCellCount int) error

func CreateUser 

func CreateUser(ctx context.Context, ytClient yt.Client, userName, token string, isSuperuser bool) error

func DecodeSidecar 

func DecodeSidecar(sidecarSpec string) (corev1.Container, error)

func FindVolumeMountForPath added in v0.34.0 

func FindVolumeMountForPath(volumeMounts []corev1.VolumeMount, path string) *corev1.VolumeMount

FindVolumeMountForPath returns the volume mount that path resides in. Mounts are scanned backward: the kubelet applies mounts in order, so the last mount covering a path is the one visible in the container.

func GetNotGoodTabletCellBundles 

func GetNotGoodTabletCellBundles(ctx context.Context, ytClient yt.Client) ([]string, error)

func IsInstanceCountEqualYTSpec 

func IsInstanceCountEqualYTSpec(ctx context.Context, ytClient yt.Client, componentType consts.ComponentType, expectedCount int32) error

IsInstanceCountEqualYTSpec checks if the number of instances registered in YTsaurus matches the expected instanceCount from the spec.

func IsUpdatingComponent 

func IsUpdatingComponent(ytsaurus *apiproxy.Ytsaurus, component Component) bool

func RunIfCondition 

func RunIfCondition(condition string, commands ...string) string

func RunIfExists 

func RunIfExists(path string, commands ...string) string

func RunIfNonexistent 

func RunIfNonexistent(path string, commands ...string) string

func SetPathAcl 

func SetPathAcl(path string, acl []yt.ACE) (string, error)

func SetWithIgnoreExisting 

func SetWithIgnoreExisting(path string, value string) string

func TimbertruckDeliveryEnabled added in v0.34.0 

func TimbertruckDeliveryEnabled(spec *ytv1.YtsaurusSpec) bool

TimbertruckDeliveryEnabled reports whether any server component in the cluster has timbertruck log delivery enabled. It mirrors the per-component resolution used by serverImpl, so the virtual Timbertruck component (user/queue/export setup) and its update-flow step are created exactly when at least one component will run a timbertruck sidecar.

func WaitTabletCellHealth 

func WaitTabletCellHealth(ctx context.Context, ytClient yt.Client, cellID yt.NodeID) (bool, error)

func WaitTabletStateMounted 

func WaitTabletStateMounted(ctx context.Context, ytClient yt.Client, path ypath.Path) (bool, error)

Types

type BundleController 

type BundleController struct {
	// contains filtered or unexported fields
}

func NewBundleController 

func NewBundleController(
	cfgen *ytconfig.Generator,
	ytsaurus *apiproxy.Ytsaurus,
) *BundleController

func (*BundleController) ArePodsReady added in v0.32.0 

func (c *BundleController) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*BundleController) Exists added in v0.31.0 

func (bc *BundleController) Exists() bool

func (*BundleController) Fetch 

func (bc *BundleController) Fetch(ctx context.Context) error

func (*BundleController) GetImageHeaterTarget added in v0.31.0 

func (c *BundleController) GetImageHeaterTarget() *ImageHeaterTarget

func (*BundleController) NeedSync 

func (c *BundleController) NeedSync() bool

func (*BundleController) NeedUpdate added in v0.31.0 

func (c *BundleController) NeedUpdate() ComponentStatus

func (*BundleController) Sync 

func (bc *BundleController) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type Chyt 

type Chyt struct {
	// contains filtered or unexported fields
}

func NewChyt 

func NewChyt(cfgen *ytconfig.NodeGenerator, chyt *apiproxy.Chyt, ytsaurus *ytv1.Ytsaurus) *Chyt

func (*Chyt) Fetch 

func (c *Chyt) Fetch(ctx context.Context) error

func (*Chyt) Sync 

func (c *Chyt) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type Component 

type Component interface {
	resources.Fetchable

	GetStatus() ComponentStatus
	SetStatus(status ComponentStatus)

	// NeedSync returns true when component is need, able and permitted to sync resources.
	NeedSync() bool

	// NeedUpdate returns SyncStatusNeedUpdate when component needs instance update.
	NeedUpdate() ComponentStatus

	// ArePodsReady returns:
	// - SyncStatusBlocked when component have not enough running pods, or too many pods
	// - SyncStatusStarted when component have enough running pods, but not enough ready pods
	// - SyncStatusReady when component have enough ready pods
	ArePodsReady(ctx context.Context) (ComponentStatus, error)

	Sync(ctx context.Context, dry bool) (ComponentStatus, error)

	GetFullName() string
	GetShortName() string
	GetType() consts.ComponentType
	GetComponent() ytv1.Component

	// Access component status saved as status condition in controller object.
	GetReadyCondition() ComponentStatus
	SetReadyCondition(status ComponentStatus)

	GetLabeller() *labeller.Labeller

	GetImageHeaterTarget() *ImageHeaterTarget

	GetCypressPatch() ypatch.PatchSet
	UpdatePreCheck(ctx context.Context) ComponentStatus
}

type ComponentLoggers 

type ComponentLoggers struct {
	ComponentName     string
	StructuredLoggers []ytv1.StructuredLoggerSpec
	LogsDeliveryPath  string
}

type ComponentStatus 

type ComponentStatus struct {
	Component  string // Set by SetStatus
	SyncStatus SyncStatus
	Message    string
}

func ComponentStatusBlocked 

func ComponentStatusBlocked(format string, a ...any) ComponentStatus

func ComponentStatusBlockedBy 

func ComponentStatusBlockedBy(format string, a ...any) ComponentStatus

func ComponentStatusNeedUpdate 

func ComponentStatusNeedUpdate(format string, a ...any) ComponentStatus

func ComponentStatusPending 

func ComponentStatusPending(format string, a ...any) ComponentStatus

func ComponentStatusReady 

func ComponentStatusReady() ComponentStatus

func ComponentStatusReadyAfter 

func ComponentStatusReadyAfter(format string, a ...any) ComponentStatus

func ComponentStatusSprintf added in v0.31.0 

func ComponentStatusSprintf(status SyncStatus, format string, a ...any) ComponentStatus

func ComponentStatusStarted added in v0.32.0 

func ComponentStatusStarted(format string, a ...any) ComponentStatus

func ComponentStatusUpdateStep 

func ComponentStatusUpdateStep(format string, a ...any) ComponentStatus

func ComponentStatusUpdating 

func ComponentStatusUpdating(format string, a ...any) ComponentStatus

func ComponentStatusWaitingFor 

func ComponentStatusWaitingFor(format string, a ...any) ComponentStatus

func SimpleStatus 

func SimpleStatus(status SyncStatus) ComponentStatus

TODO(khlebnikov): Replace this stub with status with meaningful message.

func (ComponentStatus) Blocker added in v0.31.0 

func (cs ComponentStatus) Blocker() ComponentStatus

func (ComponentStatus) IsNeedUpdate added in v0.31.0 

func (cs ComponentStatus) IsNeedUpdate() bool

func (ComponentStatus) IsReady added in v0.31.0 

func (cs ComponentStatus) IsReady() bool

func (ComponentStatus) IsRunning 

func (cs ComponentStatus) IsRunning() bool

func (ComponentStatus) IsUndefined added in v0.31.0 

func (cs ComponentStatus) IsUndefined() bool

type ConfigFormat 

type ConfigFormat string
const (
	ConfigFormatText               ConfigFormat = "text"
	ConfigFormatYson               ConfigFormat = "yson"
	ConfigFormatJson               ConfigFormat = "json"
	ConfigFormatJsonWithJsPrologue ConfigFormat = "json_with_js_prologue"
	ConfigFormatToml               ConfigFormat = "toml"
	ConfigFormatYaml               ConfigFormat = "yaml"
)

type ConfigGenerator 

type ConfigGenerator struct {
	FileName string
	// Format is the desired serialization format for config map.
	// Note that conversion from YSON to Format (if needed) is performed as a very last
	// step of config generation pipeline.
	Format ConfigFormat
	// Generator must generate config in YSON.
	Generator ConfigGeneratorFunc
}

func TextConfigGenerator added in v0.35.0 

func TextConfigGenerator(fileName string, generator TextGeneratorFunc) ConfigGenerator

func YsonConfigGenerator added in v0.35.0 

func YsonConfigGenerator(fileName string, generator ConfigGeneratorFunc) ConfigGenerator

type ConfigGeneratorFunc 

type ConfigGeneratorFunc func() ([]byte, error)

type ConfigMapBuilder 

type ConfigMapBuilder struct {
	// contains filtered or unexported fields
}

func NewConfigMapBuilder 

func NewConfigMapBuilder(
	labeller *labeller.Labeller,
	apiProxy apiproxy.APIProxy,
	name string,
	configOverrides *corev1.LocalObjectReference,
	generators ...ConfigGenerator,
) *ConfigMapBuilder

func NewJobsSidecarConfig 

func NewJobsSidecarConfig(
	labeller *labeller.Labeller,
	apiProxy apiproxy.APIProxy,
	criConfig *ytconfig.CRIConfigGenerator,
	configOverrides *corev1.LocalObjectReference,
) *ConfigMapBuilder

func (*ConfigMapBuilder) AddGenerator 

func (h *ConfigMapBuilder) AddGenerator(fileName string, format ConfigFormat, generator ConfigGeneratorFunc)

func (*ConfigMapBuilder) Build 

func (h *ConfigMapBuilder) Build() (*corev1.ConfigMap, error)

func (*ConfigMapBuilder) Exists 

func (h *ConfigMapBuilder) Exists() bool

func (*ConfigMapBuilder) Fetch 

func (h *ConfigMapBuilder) Fetch(ctx context.Context) error

func (*ConfigMapBuilder) GetConfigMapName 

func (h *ConfigMapBuilder) GetConfigMapName() string

func (*ConfigMapBuilder) Sync 

func (h *ConfigMapBuilder) Sync(ctx context.Context) error

type ControllerAgent 

type ControllerAgent struct {
	// contains filtered or unexported fields
}

func NewControllerAgent 

func NewControllerAgent(cfgen *ytconfig.Generator, ytsaurus *apiproxy.Ytsaurus, master Component, yc internalYtsaurusClient) *ControllerAgent

func (*ControllerAgent) ArePodsReady added in v0.32.0 

func (c *ControllerAgent) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*ControllerAgent) Exists added in v0.31.0 

func (c *ControllerAgent) Exists() bool

func (*ControllerAgent) Fetch 

func (ca *ControllerAgent) Fetch(ctx context.Context) error

func (*ControllerAgent) GetImageHeaterTarget added in v0.31.0 

func (c *ControllerAgent) GetImageHeaterTarget() *ImageHeaterTarget

func (*ControllerAgent) NeedSync 

func (c *ControllerAgent) NeedSync() bool

func (*ControllerAgent) NeedUpdate added in v0.31.0 

func (c *ControllerAgent) NeedUpdate() ComponentStatus

func (*ControllerAgent) Sync 

func (ca *ControllerAgent) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

func (*ControllerAgent) UpdatePreCheck 

func (ca *ControllerAgent) UpdatePreCheck(ctx context.Context) ComponentStatus

type ControllerAgentsWithMaintenance 

type ControllerAgentsWithMaintenance struct {
	Address     string   `yson:",value"`
	Maintenance bool     `yson:"maintenance,attr"`
	Alerts      []string `yson:"alerts,attr"`
}

type CypressProxy 

type CypressProxy struct {
	// contains filtered or unexported fields
}

func NewCypressProxy 

func NewCypressProxy(cfgen *ytconfig.Generator, ytsaurus *apiproxy.Ytsaurus) *CypressProxy

func (*CypressProxy) ArePodsReady added in v0.32.0 

func (c *CypressProxy) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*CypressProxy) Exists added in v0.31.0 

func (c *CypressProxy) Exists() bool

func (*CypressProxy) Fetch 

func (cyp *CypressProxy) Fetch(ctx context.Context) error

func (*CypressProxy) GetImageHeaterTarget added in v0.31.0 

func (c *CypressProxy) GetImageHeaterTarget() *ImageHeaterTarget

func (*CypressProxy) NeedSync 

func (c *CypressProxy) NeedSync() bool

func (*CypressProxy) NeedUpdate added in v0.31.0 

func (c *CypressProxy) NeedUpdate() ComponentStatus

func (*CypressProxy) Sync 

func (cyp *CypressProxy) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type DataNode 

type DataNode struct {
	// contains filtered or unexported fields
}

func NewDataNode 

func NewDataNode(
	cfgen *ytconfig.NodeGenerator,
	ytsaurus *apiproxy.Ytsaurus,
	master Component,
	yc internalYtsaurusClient,
	spec ytv1.DataNodesSpec,
) *DataNode

func (*DataNode) ArePodsReady added in v0.32.0 

func (c *DataNode) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*DataNode) Exists added in v0.31.0 

func (c *DataNode) Exists() bool

func (*DataNode) Fetch 

func (n *DataNode) Fetch(ctx context.Context) error

func (*DataNode) GetImageHeaterTarget added in v0.31.0 

func (c *DataNode) GetImageHeaterTarget() *ImageHeaterTarget

func (*DataNode) NeedSync 

func (c *DataNode) NeedSync() bool

func (*DataNode) NeedUpdate added in v0.31.0 

func (c *DataNode) NeedUpdate() ComponentStatus

func (*DataNode) Sync 

func (n *DataNode) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

func (*DataNode) UpdatePreCheck added in v0.31.0 

func (n *DataNode) UpdatePreCheck(ctx context.Context) ComponentStatus

type DataNodeMeta 

type DataNodeMeta struct {
	Name               string `yson:",value"`
	UseImaginaryChunks bool   `yson:"use_imaginary_chunk_locations,attr"`
	State              string `yson:"state,attr"`
}

type Discovery 

type Discovery struct {
	// contains filtered or unexported fields
}

func NewDiscovery 

func NewDiscovery(
	cfgen *ytconfig.Generator,
	ytsaurus *apiproxy.Ytsaurus,
	yc internalYtsaurusClient,
	master Component,
) *Discovery

func (*Discovery) ArePodsReady added in v0.32.0 

func (c *Discovery) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*Discovery) Exists added in v0.31.0 

func (c *Discovery) Exists() bool

func (*Discovery) Fetch 

func (d *Discovery) Fetch(ctx context.Context) error

func (*Discovery) GetImageHeaterTarget added in v0.31.0 

func (c *Discovery) GetImageHeaterTarget() *ImageHeaterTarget

func (*Discovery) NeedSync 

func (c *Discovery) NeedSync() bool

func (*Discovery) NeedUpdate added in v0.31.0 

func (c *Discovery) NeedUpdate() ComponentStatus

func (*Discovery) Sync 

func (d *Discovery) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

func (*Discovery) UpdatePreCheck 

func (d *Discovery) UpdatePreCheck(ctx context.Context) ComponentStatus

type ExecNode 

type ExecNode struct {
	// contains filtered or unexported fields
}

func NewExecNode 

func NewExecNode(
	cfgen *ytconfig.NodeGenerator,
	ytsaurus *apiproxy.Ytsaurus,
	master Component,
	spec ytv1.ExecNodesSpec,
	yc internalYtsaurusClient,
) *ExecNode

func (*ExecNode) Exists added in v0.31.0 

func (n *ExecNode) Exists() bool

func (*ExecNode) Fetch 

func (n *ExecNode) Fetch(ctx context.Context) error

func (*ExecNode) NeedSync added in v0.31.0 

func (n *ExecNode) NeedSync() bool

func (*ExecNode) NeedUpdate added in v0.31.0 

func (n *ExecNode) NeedUpdate() ComponentStatus

func (*ExecNode) Sync 

func (n *ExecNode) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

func (*ExecNode) UpdatePreCheck added in v0.31.0 

func (n *ExecNode) UpdatePreCheck(ctx context.Context) ComponentStatus

type HttpProxy 

type HttpProxy struct {
	// contains filtered or unexported fields
}

func NewHTTPProxy 

func NewHTTPProxy(
	cfgen *ytconfig.Generator,
	ytsaurus *apiproxy.Ytsaurus,
	masterReconciler Component,
	spec ytv1.HTTPProxiesSpec,
) *HttpProxy

func (*HttpProxy) ArePodsReady added in v0.32.0 

func (c *HttpProxy) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*HttpProxy) Exists added in v0.31.0 

func (c *HttpProxy) Exists() bool

func (*HttpProxy) Fetch 

func (hp *HttpProxy) Fetch(ctx context.Context) error

func (*HttpProxy) GetImageHeaterTarget added in v0.31.0 

func (c *HttpProxy) GetImageHeaterTarget() *ImageHeaterTarget

func (*HttpProxy) NeedSync 

func (c *HttpProxy) NeedSync() bool

func (*HttpProxy) NeedUpdate added in v0.31.0 

func (c *HttpProxy) NeedUpdate() ComponentStatus

func (*HttpProxy) Sync 

func (hp *HttpProxy) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type ImageHeater added in v0.31.0 

type ImageHeater struct {
	// contains filtered or unexported fields
}

func NewImageHeater added in v0.31.0 

func NewImageHeater(cfgen *ytconfig.Generator, ytsaurus *apiproxy.Ytsaurus, getAllComponents func() []Component) *ImageHeater

func (*ImageHeater) ArePodsReady added in v0.32.0 

func (c *ImageHeater) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*ImageHeater) Exists added in v0.31.0 

func (ih *ImageHeater) Exists() bool

func (*ImageHeater) Fetch added in v0.31.0 

func (ih *ImageHeater) Fetch(ctx context.Context) error

func (*ImageHeater) GetHeaterStatus added in v0.31.0 

func (ih *ImageHeater) GetHeaterStatus(component ytv1.Component) ComponentStatus

func (*ImageHeater) NeedSync added in v0.31.0 

func (ih *ImageHeater) NeedSync() bool

func (*ImageHeater) NeedUpdate added in v0.31.0 

func (ih *ImageHeater) NeedUpdate() ComponentStatus

func (*ImageHeater) Sync added in v0.31.0 

func (ih *ImageHeater) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

Image heater becomes ready after creation of daemon sets but report progress. Daemon sets are not deleted after completion to warm up new nodes, and not recreated because image heating is not strictly required.

type ImageHeaterTarget added in v0.31.0 

type ImageHeaterTarget struct {
	Images           map[string]string
	ImagePullSecrets []corev1.LocalObjectReference
	NodeSelector     map[string]string
	Tolerations      []corev1.Toleration
	NodeAffinity     *corev1.NodeAffinity
}

type InitJob 

type InitJob struct {
	// contains filtered or unexported fields
}

func NewInitJob 

func NewInitJob(
	labeller *labeller.Labeller,
	apiProxy apiproxy.APIProxy,
	name string,
	commonSpec *ytv1.CommonSpec,
	commonPodSpec *ytv1.PodSpec,
	instanceSpec *ytv1.InstanceSpec,
	generators ...ConfigGenerator,
) *InitJob

func NewInitJobForYtsaurus 

func NewInitJobForYtsaurus(
	labeller *labeller.Labeller,
	ytsaurus *apiproxy.Ytsaurus,
	name string,
	instanceSpec *ytv1.InstanceSpec,
	generators ...ConfigGenerator,
) *InitJob

func (*InitJob) AddInitJobScript added in v0.35.0 

func (j *InitJob) AddInitJobScript(generator func() string)

TODO: Migrate to AddScript.

func (*InitJob) AddScript added in v0.35.0 

func (j *InitJob) AddScript(fileName string, generator TextGeneratorFunc)

func (*InitJob) Build 

func (j *InitJob) Build() *batchv1.Job

func (*InitJob) Exists added in v0.31.0 

func (j *InitJob) Exists() bool

func (*InitJob) Fetch 

func (j *InitJob) Fetch(ctx context.Context) error

func (*InitJob) GetComponent added in v0.31.0 

func (c *InitJob) GetComponent() ytv1.Component

func (*InitJob) GetCypressPatch 

func (c *InitJob) GetCypressPatch() ypatch.PatchSet

func (*InitJob) GetFullName 

func (c *InitJob) GetFullName() string

GetFullName returns component's name, which is used as an identifier in component management and for mentioning in logs. For example for master component name is "Master", For data node name looks like "DataNode<NameFromSpec>".

func (*InitJob) GetImageHeaterTarget added in v0.31.0 

func (c *InitJob) GetImageHeaterTarget() *ImageHeaterTarget

func (*InitJob) GetLabeller 

func (c *InitJob) GetLabeller() *labeller.Labeller

func (*InitJob) GetReadyCondition added in v0.31.0 

func (c *InitJob) GetReadyCondition() ComponentStatus

func (*InitJob) GetShortName 

func (c *InitJob) GetShortName() string

func (*InitJob) GetStatus added in v0.31.0 

func (c *InitJob) GetStatus() ComponentStatus

func (*InitJob) GetType 

func (c *InitJob) GetType() consts.ComponentType

func (*InitJob) IsCompleted 

func (j *InitJob) IsCompleted() bool

IsCompleted returns true if job spec and config exist and job status condition is "True". NOTE: Not checking job success to allow manual setting condition for failing jobs. NOTE: Removing either job spec, config or condition triggers job restart.

func (*InitJob) IsUpdatingResources added in v0.31.0 

func (c *InitJob) IsUpdatingResources() bool

func (*InitJob) Name added in v0.32.0 

func (j *InitJob) Name() string

func (*InitJob) Restart added in v0.32.0 

func (j *InitJob) Restart()

func (*InitJob) RunScript added in v0.32.0 

func (j *InitJob) RunScript(
	ctx context.Context,
	dry bool,
	reason string,
	scriptFileName string,
	complete func(status *ComponentStatus),
) (ComponentStatus, error)

func (*InitJob) RunUpdateScript added in v0.32.0 

func (j *InitJob) RunUpdateScript(
	ctx context.Context,
	dry bool,
	ytsaurus *apiproxy.Ytsaurus,
	updateState ytv1.UpdateState,
	scriptFileName string,
	complete func(),
) (ComponentStatus, error)

func (*InitJob) SetReadyCondition added in v0.31.0 

func (c *InitJob) SetReadyCondition(status ComponentStatus)

func (*InitJob) SetStatus added in v0.31.0 

func (c *InitJob) SetStatus(status ComponentStatus)

func (*InitJob) Sync 

func (j *InitJob) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

func (*InitJob) UpdatePreCheck 

func (c *InitJob) UpdatePreCheck(ctx context.Context) ComponentStatus

type KafkaProxy 

type KafkaProxy struct {
	// contains filtered or unexported fields
}

func NewKafkaProxy 

func NewKafkaProxy(cfgen *ytconfig.Generator, ytsaurus *apiproxy.Ytsaurus, masterReconciler Component, spec ytv1.KafkaProxiesSpec) *KafkaProxy

func (*KafkaProxy) ArePodsReady added in v0.32.0 

func (c *KafkaProxy) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*KafkaProxy) Exists added in v0.31.0 

func (c *KafkaProxy) Exists() bool

func (*KafkaProxy) Fetch 

func (kp *KafkaProxy) Fetch(ctx context.Context) error

func (*KafkaProxy) GetImageHeaterTarget added in v0.31.0 

func (c *KafkaProxy) GetImageHeaterTarget() *ImageHeaterTarget

func (*KafkaProxy) NeedSync 

func (c *KafkaProxy) NeedSync() bool

func (*KafkaProxy) NeedUpdate added in v0.31.0 

func (c *KafkaProxy) NeedUpdate() ComponentStatus

func (*KafkaProxy) Sync 

func (kp *KafkaProxy) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type Master 

type Master struct {
	// contains filtered or unexported fields
}

func NewMaster 

func NewMaster(
	cfgen *ytconfig.Generator,
	ytsaurus *apiproxy.Ytsaurus,
	mastersSpec *ytv1.MastersSpec,
	secondaryMasters []*Master,
) *Master

func (*Master) ArePodsReady added in v0.32.0 

func (m *Master) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*Master) Exists added in v0.31.0 

func (c *Master) Exists() bool

func (*Master) Fetch 

func (m *Master) Fetch(ctx context.Context) error

func (*Master) GetCypressPatch 

func (m *Master) GetCypressPatch() ypatch.PatchSet

func (*Master) GetCypressPath added in v0.32.0 

func (m *Master) GetCypressPath() ypath.Path

func (*Master) GetImageHeaterTarget added in v0.31.0 

func (c *Master) GetImageHeaterTarget() *ImageHeaterTarget

func (*Master) IsPrimary added in v0.32.0 

func (m *Master) IsPrimary() bool

func (*Master) IsUnregistered added in v0.35.0 

func (m *Master) IsUnregistered() bool

func (*Master) NeedSync 

func (c *Master) NeedSync() bool

func (*Master) NeedUpdate added in v0.31.0 

func (m *Master) NeedUpdate() ComponentStatus

func (*Master) ServerSync added in v0.35.0 

func (m *Master) ServerSync(ctx context.Context, dry bool) (ComponentStatus, error)

func (*Master) SetUnregistered added in v0.35.0 

func (m *Master) SetUnregistered(unregistered bool)

func (*Master) Sync 

func (m *Master) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type MasterCache 

type MasterCache struct {
	// contains filtered or unexported fields
}

func NewMasterCache 

func NewMasterCache(
	cfgen *ytconfig.Generator,
	ytsaurus *apiproxy.Ytsaurus,
	yc internalYtsaurusClient,
	master Component,
) *MasterCache

func (*MasterCache) ArePodsReady added in v0.32.0 

func (c *MasterCache) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*MasterCache) Exists added in v0.31.0 

func (c *MasterCache) Exists() bool

func (*MasterCache) Fetch 

func (mc *MasterCache) Fetch(ctx context.Context) error

func (*MasterCache) GetImageHeaterTarget added in v0.31.0 

func (c *MasterCache) GetImageHeaterTarget() *ImageHeaterTarget

func (*MasterCache) NeedSync 

func (c *MasterCache) NeedSync() bool

func (*MasterCache) NeedUpdate added in v0.31.0 

func (c *MasterCache) NeedUpdate() ComponentStatus

func (*MasterCache) Sync 

func (mc *MasterCache) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

func (*MasterCache) UpdatePreCheck 

func (mc *MasterCache) UpdatePreCheck(ctx context.Context) ComponentStatus

type Medium 

type Medium struct {
	Name string `yson:"name"`
}

type OffshoreDataGateway 

type OffshoreDataGateway struct {
	// contains filtered or unexported fields
}

func NewOffshoreDataGateways 

func NewOffshoreDataGateways(
	cfgen *ytconfig.NodeGenerator,
	proxy apiproxy.APIProxy,
	spec ytv1.OffshoreDataGatewaySpec,
	commonSpec ytv1.CommonSpec,
) *OffshoreDataGateway

func (*OffshoreDataGateway) ArePodsReady added in v0.32.0 

func (c *OffshoreDataGateway) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*OffshoreDataGateway) Exists added in v0.31.0 

func (c *OffshoreDataGateway) Exists() bool

func (*OffshoreDataGateway) Fetch 

func (p *OffshoreDataGateway) Fetch(ctx context.Context) error

func (*OffshoreDataGateway) GetImageHeaterTarget added in v0.31.0 

func (c *OffshoreDataGateway) GetImageHeaterTarget() *ImageHeaterTarget

func (*OffshoreDataGateway) NeedSync added in v0.31.0 

func (c *OffshoreDataGateway) NeedSync() bool

func (*OffshoreDataGateway) NeedUpdate added in v0.31.0 

func (c *OffshoreDataGateway) NeedUpdate() ComponentStatus

func (*OffshoreDataGateway) Sync 

func (p *OffshoreDataGateway) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type Option 

type Option func(opts *options)

func WithContainerPorts 

func WithContainerPorts(ports ...corev1.ContainerPort) Option

func WithCustomReadinessProbeEndpointPath 

func WithCustomReadinessProbeEndpointPath(path string) Option

func WithCustomReadinessProbeEndpointPort 

func WithCustomReadinessProbeEndpointPort(port int32) Option

func WithSidecarImage 

func WithSidecarImage(name, image string) Option

func WithTimbertruck added in v0.34.0 

func WithTimbertruck(timbertruck *ytv1.TimbertruckSpec) Option

WithTimbertruck sets a per-component override of the cluster-wide timbertruck settings.

type QueryTracker 

type QueryTracker struct {
	// contains filtered or unexported fields
}

func NewQueryTracker 

func NewQueryTracker(
	cfgen *ytconfig.Generator,
	ytsaurus *apiproxy.Ytsaurus,
	yc internalYtsaurusClient,
	tabletNodes []Component,
) *QueryTracker

func (*QueryTracker) ArePodsReady added in v0.32.0 

func (c *QueryTracker) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*QueryTracker) Exists added in v0.31.0 

func (c *QueryTracker) Exists() bool

func (*QueryTracker) Fetch 

func (qt *QueryTracker) Fetch(ctx context.Context) error

func (*QueryTracker) GetImageHeaterTarget added in v0.31.0 

func (c *QueryTracker) GetImageHeaterTarget() *ImageHeaterTarget

func (*QueryTracker) NeedSync 

func (c *QueryTracker) NeedSync() bool

func (*QueryTracker) NeedUpdate added in v0.31.0 

func (c *QueryTracker) NeedUpdate() ComponentStatus

func (*QueryTracker) Sync 

func (qt *QueryTracker) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

func (*QueryTracker) UpdatePreCheck 

func (qt *QueryTracker) UpdatePreCheck(ctx context.Context) ComponentStatus

type QueueAgent 

type QueueAgent struct {
	// contains filtered or unexported fields
}

func NewQueueAgent 

func NewQueueAgent(
	cfgen *ytconfig.Generator,
	ytsaurus *apiproxy.Ytsaurus,
	yc internalYtsaurusClient,
	master Component,
	tabletNodes []Component,
) *QueueAgent

func (*QueueAgent) ArePodsReady added in v0.32.0 

func (c *QueueAgent) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*QueueAgent) Exists added in v0.31.0 

func (c *QueueAgent) Exists() bool

func (*QueueAgent) Fetch 

func (qa *QueueAgent) Fetch(ctx context.Context) error

func (*QueueAgent) GetImageHeaterTarget added in v0.31.0 

func (c *QueueAgent) GetImageHeaterTarget() *ImageHeaterTarget

func (*QueueAgent) NeedSync 

func (c *QueueAgent) NeedSync() bool

func (*QueueAgent) NeedUpdate added in v0.31.0 

func (c *QueueAgent) NeedUpdate() ComponentStatus

func (*QueueAgent) Sync 

func (qa *QueueAgent) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

func (*QueueAgent) UpdatePreCheck 

func (qa *QueueAgent) UpdatePreCheck(ctx context.Context) ComponentStatus

type RemoteDataNode 

type RemoteDataNode struct {
	// contains filtered or unexported fields
}

func NewRemoteDataNodes 

func NewRemoteDataNodes(
	cfgen *ytconfig.NodeGenerator,
	nodes *ytv1.RemoteDataNodes,
	proxy apiproxy.APIProxy,
	spec ytv1.DataNodesSpec,
	commonSpec ytv1.CommonSpec,
) *RemoteDataNode

func (*RemoteDataNode) ArePodsReady added in v0.32.0 

func (c *RemoteDataNode) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*RemoteDataNode) Exists added in v0.31.0 

func (c *RemoteDataNode) Exists() bool

func (*RemoteDataNode) Fetch 

func (n *RemoteDataNode) Fetch(ctx context.Context) error

func (*RemoteDataNode) GetImageHeaterTarget added in v0.31.0 

func (c *RemoteDataNode) GetImageHeaterTarget() *ImageHeaterTarget

func (*RemoteDataNode) NeedSync added in v0.31.0 

func (c *RemoteDataNode) NeedSync() bool

func (*RemoteDataNode) NeedUpdate added in v0.31.0 

func (c *RemoteDataNode) NeedUpdate() ComponentStatus

func (*RemoteDataNode) Sync 

func (n *RemoteDataNode) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type RemoteExecNode 

type RemoteExecNode struct {
	// contains filtered or unexported fields
}

func NewRemoteExecNodes 

func NewRemoteExecNodes(
	cfgen *ytconfig.NodeGenerator,
	nodes *ytv1.RemoteExecNodes,
	proxy apiproxy.APIProxy,
	spec ytv1.ExecNodesSpec,
	commonSpec ytv1.CommonSpec,
) *RemoteExecNode

func (*RemoteExecNode) Exists added in v0.31.0 

func (n *RemoteExecNode) Exists() bool

func (*RemoteExecNode) Fetch 

func (n *RemoteExecNode) Fetch(ctx context.Context) error

func (*RemoteExecNode) NeedSync added in v0.31.0 

func (n *RemoteExecNode) NeedSync() bool

func (*RemoteExecNode) NeedUpdate added in v0.31.0 

func (n *RemoteExecNode) NeedUpdate() ComponentStatus

func (*RemoteExecNode) Sync 

func (n *RemoteExecNode) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type RemoteTabletNode 

type RemoteTabletNode struct {
	// contains filtered or unexported fields
}

func NewRemoteTabletNodes 

func NewRemoteTabletNodes(
	cfgen *ytconfig.NodeGenerator,
	nodes *ytv1.RemoteTabletNodes,
	proxy apiproxy.APIProxy,
	spec ytv1.TabletNodesSpec,
	commonSpec ytv1.CommonSpec,
) *RemoteTabletNode

func (*RemoteTabletNode) ArePodsReady added in v0.32.0 

func (c *RemoteTabletNode) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*RemoteTabletNode) Exists added in v0.31.0 

func (c *RemoteTabletNode) Exists() bool

func (*RemoteTabletNode) Fetch 

func (n *RemoteTabletNode) Fetch(ctx context.Context) error

func (*RemoteTabletNode) GetImageHeaterTarget added in v0.31.0 

func (c *RemoteTabletNode) GetImageHeaterTarget() *ImageHeaterTarget

func (*RemoteTabletNode) NeedSync added in v0.31.0 

func (c *RemoteTabletNode) NeedSync() bool

func (*RemoteTabletNode) NeedUpdate added in v0.31.0 

func (c *RemoteTabletNode) NeedUpdate() ComponentStatus

func (*RemoteTabletNode) Sync 

func (n *RemoteTabletNode) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type RpcProxy 

type RpcProxy struct {
	// contains filtered or unexported fields
}

func NewRPCProxy 

func NewRPCProxy(
	cfgen *ytconfig.Generator,
	ytsaurus *apiproxy.Ytsaurus,
	masterReconciler Component,
	spec ytv1.RPCProxiesSpec,
) *RpcProxy

func (*RpcProxy) ArePodsReady added in v0.32.0 

func (c *RpcProxy) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*RpcProxy) Exists added in v0.31.0 

func (c *RpcProxy) Exists() bool

func (*RpcProxy) Fetch 

func (rp *RpcProxy) Fetch(ctx context.Context) error

func (*RpcProxy) GetImageHeaterTarget added in v0.31.0 

func (c *RpcProxy) GetImageHeaterTarget() *ImageHeaterTarget

func (*RpcProxy) NeedSync 

func (c *RpcProxy) NeedSync() bool

func (*RpcProxy) NeedUpdate added in v0.31.0 

func (c *RpcProxy) NeedUpdate() ComponentStatus

func (*RpcProxy) Sync 

func (rp *RpcProxy) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type Scheduler 

type Scheduler struct {
	// contains filtered or unexported fields
}

func NewScheduler 

func NewScheduler(
	cfgen *ytconfig.Generator,
	ytsaurus *apiproxy.Ytsaurus,
	master Component,
	yc internalYtsaurusClient,
	tabletNodes []Component,
) *Scheduler

func (*Scheduler) ArePodsReady added in v0.32.0 

func (c *Scheduler) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*Scheduler) Exists added in v0.31.0 

func (c *Scheduler) Exists() bool

func (*Scheduler) Fetch 

func (s *Scheduler) Fetch(ctx context.Context) error

func (*Scheduler) GetImageHeaterTarget added in v0.31.0 

func (c *Scheduler) GetImageHeaterTarget() *ImageHeaterTarget

func (*Scheduler) NeedSync 

func (c *Scheduler) NeedSync() bool

func (*Scheduler) NeedUpdate added in v0.31.0 

func (c *Scheduler) NeedUpdate() ComponentStatus

func (*Scheduler) Sync 

func (s *Scheduler) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

func (*Scheduler) UpdatePreCheck 

func (s *Scheduler) UpdatePreCheck(ctx context.Context) ComponentStatus

type Spyt 

type Spyt struct {
	// contains filtered or unexported fields
}

func NewSpyt 

func NewSpyt(cfgen *ytconfig.NodeGenerator, spyt *apiproxy.Spyt, ytsaurus *ytv1.Ytsaurus) *Spyt

func (*Spyt) Fetch 

func (s *Spyt) Fetch(ctx context.Context) error

func (*Spyt) Sync 

func (s *Spyt) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type StrawberryController 

type StrawberryController struct {
	// contains filtered or unexported fields
}

func NewStrawberryController 

func NewStrawberryController(
	cfgen *ytconfig.Generator,
	ytsaurus *apiproxy.Ytsaurus,
	master Component,
	scheduler Component,
	dataNodes []Component,
) *StrawberryController

func (*StrawberryController) ArePodsReady added in v0.32.0 

func (c *StrawberryController) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*StrawberryController) Exists added in v0.31.0 

func (c *StrawberryController) Exists() bool

func (*StrawberryController) Fetch 

func (c *StrawberryController) Fetch(ctx context.Context) error

func (*StrawberryController) GetImageHeaterTarget added in v0.31.0 

func (c *StrawberryController) GetImageHeaterTarget() *ImageHeaterTarget

func (*StrawberryController) NeedSync added in v0.31.0 

func (c *StrawberryController) NeedSync() bool

func (*StrawberryController) NeedUpdate added in v0.31.0 

func (c *StrawberryController) NeedUpdate() ComponentStatus

func (*StrawberryController) Sync 

func (c *StrawberryController) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type SyncStatus 

type SyncStatus string
const (
	SyncStatusUndefined  SyncStatus = ""           // Status is unknown
	SyncStatusReady      SyncStatus = "Ready"      // Running, reconciliation is not required
	SyncStatusStarted    SyncStatus = "Started"    // Reconciliation is complete, is not ready yet
	SyncStatusBlocked    SyncStatus = "Blocked"    // Reconciliation is impossible
	SyncStatusPending    SyncStatus = "Pending"    // Reconciliation is possible
	SyncStatusNeedUpdate SyncStatus = "NeedUpdate" // Running, update is required
	// FIXME: Remove, replace with pending.
	SyncStatusUpdating SyncStatus = "Updating" // Update in progress
)

type TabletBalancer 

type TabletBalancer struct {
	// contains filtered or unexported fields
}

func NewTabletBalancer 

func NewTabletBalancer(
	cfgen *ytconfig.Generator,
	ytsaurus *apiproxy.Ytsaurus,
) *TabletBalancer

func (*TabletBalancer) ArePodsReady added in v0.32.0 

func (c *TabletBalancer) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*TabletBalancer) Exists added in v0.31.0 

func (c *TabletBalancer) Exists() bool

func (*TabletBalancer) Fetch 

func (tb *TabletBalancer) Fetch(ctx context.Context) error

func (*TabletBalancer) GetImageHeaterTarget added in v0.31.0 

func (c *TabletBalancer) GetImageHeaterTarget() *ImageHeaterTarget

func (*TabletBalancer) NeedSync 

func (c *TabletBalancer) NeedSync() bool

func (*TabletBalancer) NeedUpdate added in v0.31.0 

func (c *TabletBalancer) NeedUpdate() ComponentStatus

func (*TabletBalancer) Sync 

func (tb *TabletBalancer) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type TabletCellBundleHealth 

type TabletCellBundleHealth struct {
	Name   string `yson:",value" json:"name"`
	Health string `yson:"health,attr" json:"health"`
}

type TabletNode 

type TabletNode struct {
	// contains filtered or unexported fields
}

func NewTabletNode 

func NewTabletNode(
	cfgen *ytconfig.NodeGenerator,
	ytsaurus *apiproxy.Ytsaurus,
	ytsaurusClient internalYtsaurusClient,
	master Component,
	spec ytv1.TabletNodesSpec,
	doInitiailization bool,
) *TabletNode

func (*TabletNode) ArePodsReady added in v0.32.0 

func (c *TabletNode) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*TabletNode) Exists added in v0.31.0 

func (c *TabletNode) Exists() bool

func (*TabletNode) Fetch 

func (tn *TabletNode) Fetch(ctx context.Context) error

func (*TabletNode) GetImageHeaterTarget added in v0.31.0 

func (c *TabletNode) GetImageHeaterTarget() *ImageHeaterTarget

func (*TabletNode) NeedSync 

func (c *TabletNode) NeedSync() bool

func (*TabletNode) NeedUpdate added in v0.31.0 

func (c *TabletNode) NeedUpdate() ComponentStatus

func (*TabletNode) Sync 

func (tn *TabletNode) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type TcpProxy 

type TcpProxy struct {
	// contains filtered or unexported fields
}

func NewTCPProxy 

func NewTCPProxy(cfgen *ytconfig.Generator, ytsaurus *apiproxy.Ytsaurus, masterReconciler Component, spec ytv1.TCPProxiesSpec) *TcpProxy

func (*TcpProxy) ArePodsReady added in v0.32.0 

func (c *TcpProxy) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*TcpProxy) Exists added in v0.31.0 

func (c *TcpProxy) Exists() bool

func (*TcpProxy) Fetch 

func (tp *TcpProxy) Fetch(ctx context.Context) error

func (*TcpProxy) GetImageHeaterTarget added in v0.31.0 

func (c *TcpProxy) GetImageHeaterTarget() *ImageHeaterTarget

func (*TcpProxy) NeedSync 

func (c *TcpProxy) NeedSync() bool

func (*TcpProxy) NeedUpdate added in v0.31.0 

func (c *TcpProxy) NeedUpdate() ComponentStatus

func (*TcpProxy) Sync 

func (tp *TcpProxy) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type TextGeneratorFunc added in v0.32.0 

type TextGeneratorFunc func() ([]string, error)

func CheckAndAppendPathACLGenerator added in v0.32.0 

func CheckAndAppendPathACLGenerator(path string, acl yt.ACE) TextGeneratorFunc

func JoinTextGenerators added in v0.32.0 

func JoinTextGenerators(generators ...TextGeneratorFunc) TextGeneratorFunc

func PlainTextGenerator added in v0.32.0 

func PlainTextGenerator(text ...string) TextGeneratorFunc

func SprintfYsonGenerator added in v0.32.0 

func SprintfYsonGenerator(format string, args ...any) TextGeneratorFunc

type Timbertruck 

type Timbertruck struct {
	// contains filtered or unexported fields
}

func NewTimbertruck 

func NewTimbertruck(
	cfgen *ytconfig.Generator,
	ytsaurus *apiproxy.Ytsaurus,
	tnds []Component,
	yc *YtsaurusClient,
) *Timbertruck

func (*Timbertruck) ArePodsReady added in v0.32.0 

func (c *Timbertruck) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*Timbertruck) Exists added in v0.31.0 

func (tt *Timbertruck) Exists() bool

func (*Timbertruck) Fetch 

func (tt *Timbertruck) Fetch(ctx context.Context) error

func (*Timbertruck) GetDeliveryLoggers 

func (tt *Timbertruck) GetDeliveryLoggers() []ComponentLoggers

GetDeliveryLoggers enumerates every component that has timbertruck delivery enabled, so the virtual Timbertruck component can prepare the YT-side user, queues, producers and exports. The component name and delivery path must match what serverImpl writes into each sidecar config.

func (*Timbertruck) NeedSync added in v0.31.0 

func (tt *Timbertruck) NeedSync() bool

func (*Timbertruck) NeedUpdate added in v0.31.0 

func (tt *Timbertruck) NeedUpdate() ComponentStatus

func (*Timbertruck) Sync 

func (tt *Timbertruck) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type UI 

type UI struct {
	// contains filtered or unexported fields
}

func NewUI 

func NewUI(cfgen *ytconfig.Generator, ytsaurus *apiproxy.Ytsaurus, master Component) *UI

func (*UI) ArePodsReady added in v0.32.0 

func (c *UI) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*UI) Exists added in v0.31.0 

func (u *UI) Exists() bool

func (*UI) Fetch 

func (u *UI) Fetch(ctx context.Context) error

func (*UI) GetImageHeaterTarget added in v0.31.0 

func (c *UI) GetImageHeaterTarget() *ImageHeaterTarget

func (*UI) NeedSync added in v0.31.0 

func (c *UI) NeedSync() bool

func (*UI) NeedUpdate added in v0.31.0 

func (c *UI) NeedUpdate() ComponentStatus

func (*UI) Sync 

func (u *UI) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

type YqlAgent 

type YqlAgent struct {
	// contains filtered or unexported fields
}

func NewYQLAgent 

func NewYQLAgent(cfgen *ytconfig.Generator, ytsaurus *apiproxy.Ytsaurus, yc internalYtsaurusClient, master Component) *YqlAgent

func (*YqlAgent) ArePodsReady added in v0.32.0 

func (c *YqlAgent) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*YqlAgent) Exists added in v0.31.0 

func (c *YqlAgent) Exists() bool

func (*YqlAgent) Fetch 

func (yqla *YqlAgent) Fetch(ctx context.Context) error

func (*YqlAgent) GetCypressPatch 

func (yqla *YqlAgent) GetCypressPatch() ypatch.PatchSet

func (*YqlAgent) GetFullName 

func (yqla *YqlAgent) GetFullName() string

func (*YqlAgent) GetImageHeaterTarget added in v0.31.0 

func (c *YqlAgent) GetImageHeaterTarget() *ImageHeaterTarget

func (*YqlAgent) GetShortName 

func (yqla *YqlAgent) GetShortName() string

func (*YqlAgent) NeedSync 

func (c *YqlAgent) NeedSync() bool

func (*YqlAgent) NeedUpdate added in v0.31.0 

func (c *YqlAgent) NeedUpdate() ComponentStatus

func (*YqlAgent) Sync 

func (yqla *YqlAgent) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

func (*YqlAgent) UpdatePreCheck 

func (yqla *YqlAgent) UpdatePreCheck(ctx context.Context) ComponentStatus

type YtsaurusClient 

type YtsaurusClient struct {
	// contains filtered or unexported fields
}

func NewYtsaurusClient 

func NewYtsaurusClient(
	cfgen *ytconfig.Generator,
	ytsaurus *apiproxy.Ytsaurus,
	master *Master,
	httpProxy Component,
	getAllComponents func() []Component,
) *YtsaurusClient

func (*YtsaurusClient) ArePodsReady added in v0.32.0 

func (c *YtsaurusClient) ArePodsReady(ctx context.Context) (ComponentStatus, error)

func (*YtsaurusClient) AreTabletCellsRemoved 

func (yc *YtsaurusClient) AreTabletCellsRemoved(ctx context.Context) (bool, error)

func (*YtsaurusClient) BuildCypressPatch 

func (yc *YtsaurusClient) BuildCypressPatch(ctx context.Context) (*corev1.ConfigMap, ypatch.PatchSet, error)

func (*YtsaurusClient) DisableSafeMode 

func (yc *YtsaurusClient) DisableSafeMode(ctx context.Context) error

func (*YtsaurusClient) EnableSafeMode 

func (yc *YtsaurusClient) EnableSafeMode(ctx context.Context) error

func (*YtsaurusClient) Exists added in v0.31.0 

func (yc *YtsaurusClient) Exists() bool

func (*YtsaurusClient) Fetch 

func (yc *YtsaurusClient) Fetch(ctx context.Context) error

func (*YtsaurusClient) GetCypressPatch 

func (yc *YtsaurusClient) GetCypressPatch() ypatch.PatchSet

func (*YtsaurusClient) GetTabletCells 

func (yc *YtsaurusClient) GetTabletCells(ctx context.Context) ([]ytv1.TabletCellBundleInfo, error)

func (*YtsaurusClient) GetYtClient 

func (yc *YtsaurusClient) GetYtClient() yt.Client

func (*YtsaurusClient) IsBundleControllerDisabled added in v0.31.0 

func (yc *YtsaurusClient) IsBundleControllerDisabled(ctx context.Context) (*bool, error)

func (*YtsaurusClient) NeedSync added in v0.31.0 

func (yc *YtsaurusClient) NeedSync() bool

func (*YtsaurusClient) NeedSyncCypressPatch 

func (yc *YtsaurusClient) NeedSyncCypressPatch() ComponentStatus

func (*YtsaurusClient) NeedUpdate added in v0.31.0 

func (yc *YtsaurusClient) NeedUpdate() ComponentStatus

func (*YtsaurusClient) RecoverTableCells 

func (yc *YtsaurusClient) RecoverTableCells(ctx context.Context, bundles []ytv1.TabletCellBundleInfo) error

func (*YtsaurusClient) RemoveTabletCells 

func (yc *YtsaurusClient) RemoveTabletCells(ctx context.Context) error

func (*YtsaurusClient) ReportCondition added in v0.32.0 

func (yc *YtsaurusClient) ReportCondition(conditionType string, ok bool, msg string, err error) error

func (*YtsaurusClient) SetBundleControllerDisabled added in v0.31.0 

func (yc *YtsaurusClient) SetBundleControllerDisabled(ctx context.Context, disabled *bool) error

func (*YtsaurusClient) Sync 

func (yc *YtsaurusClient) Sync(ctx context.Context, dry bool) (ComponentStatus, error)

func (*YtsaurusClient) SyncCypressPatch 

func (yc *YtsaurusClient) SyncCypressPatch(ctx context.Context) error

func (*YtsaurusClient) UpdateClusterHealthChecks added in v0.32.0 

func (yc *YtsaurusClient) UpdateClusterHealthChecks(ctx context.Context) (err error)

func (*YtsaurusClient) UpdateCounterHealthCheck added in v0.32.0 

func (yc *YtsaurusClient) UpdateCounterHealthCheck(ctx context.Context, counterPath ypath.Path, conditionType string) error

func (*YtsaurusClient) UpdateMasterQuorumCheck added in v0.32.0 

func (yc *YtsaurusClient) UpdateMasterQuorumCheck(ctx context.Context) error

func (*YtsaurusClient) UpdateTabletCellBundlesHealthCheck added in v0.32.0 

func (yc *YtsaurusClient) UpdateTabletCellBundlesHealthCheck(ctx context.Context) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.