components

package
v0.31.0 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2026 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ConfigFormatYson               = "yson"
	ConfigFormatJson               = "json"
	ConfigFormatJsonWithJsPrologue = "json_with_js_prologue"
	ConfigFormatToml               = "toml"
)
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 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 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 int) 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 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) 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

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

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
}

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

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

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) 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) 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) 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) *Discovery

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) 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) 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) GetComponent added in v0.31.0 

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

func (*ImageHeater) GetCypressPatch added in v0.31.0 

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

func (*ImageHeater) GetFullName added in v0.31.0 

func (c *ImageHeater) 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 (*ImageHeater) GetHeaterStatus added in v0.31.0 

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

func (*ImageHeater) GetImageHeaterTarget added in v0.31.0 

func (c *ImageHeater) GetImageHeaterTarget() *ImageHeaterTarget

func (*ImageHeater) GetLabeller added in v0.31.0 

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

func (*ImageHeater) GetReadyCondition added in v0.31.0 

func (c *ImageHeater) GetReadyCondition() ComponentStatus

func (*ImageHeater) GetShortName added in v0.31.0 

func (c *ImageHeater) GetShortName() string

func (*ImageHeater) GetStatus added in v0.31.0 

func (c *ImageHeater) GetStatus() ComponentStatus

func (*ImageHeater) GetType added in v0.31.0 

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

func (*ImageHeater) IsUpdatingResources added in v0.31.0 

func (c *ImageHeater) IsUpdatingResources() bool

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) SetReadyCondition added in v0.31.0 

func (c *ImageHeater) SetReadyCondition(status ComponentStatus)

func (*ImageHeater) SetStatus added in v0.31.0 

func (c *ImageHeater) SetStatus(status 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.

func (*ImageHeater) UpdatePreCheck added in v0.31.0 

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

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, configFileName string,
	generator ConfigGeneratorFunc,
	commonSpec *ytv1.CommonSpec,
	commonPodSpec *ytv1.PodSpec,
	instanceSpec *ytv1.InstanceSpec,
) *InitJob

func NewInitJobForYtsaurus 

func NewInitJobForYtsaurus(
	labeller *labeller.Labeller,
	ytsaurus *apiproxy.Ytsaurus,
	name, configFileName string,
	generator ConfigGeneratorFunc,
	instanceSpec *ytv1.InstanceSpec,
) *InitJob

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

func (*InitJob) IsUpdatingResources added in v0.31.0 

func (c *InitJob) IsUpdatingResources() bool

func (*InitJob) SetInitScript 

func (j *InitJob) SetInitScript(script string)

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) 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) *Master

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) GetImageHeaterTarget added in v0.31.0 

func (c *Master) GetImageHeaterTarget() *ImageHeaterTarget

func (*Master) NeedSync 

func (c *Master) NeedSync() bool

func (*Master) NeedUpdate added in v0.31.0 

func (c *Master) NeedUpdate() ComponentStatus

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) *MasterCache

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 MasterHydra 

type MasterHydra struct {
	ReadOnly             bool        `yson:"read_only"`
	LastSnapshotReadOnly bool        `yson:"last_snapshot_read_only"`
	Active               bool        `yson:"active"`
	State                MasterState `yson:"state"`
}

type MasterInfo 

type MasterInfo struct {
	CellID    string   `yson:"cell_id" json:"cellId"`
	Addresses []string `yson:"addresses" json:"addresses"`
}

type MasterState 

type MasterState string
const (
	MasterStateLeading   MasterState = "leading"
	MasterStateFollowing MasterState = "following"
)

type MastersWithMaintenance 

type MastersWithMaintenance struct {
	Address     string `yson:",value"`
	Maintenance bool   `yson:"maintenance,attr"`
}

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

func WithReadinessByContainer(name string) Option

func WithSidecarImage 

func WithSidecarImage(name, image string) Option

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) 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) 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) 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) 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) 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,
	execNodes, tabletNodes []Component,
) *Scheduler

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) 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
	SyncStatusBlocked    SyncStatus = "Blocked"    // Reconciliation is impossible
	SyncStatusPending    SyncStatus = "Pending"    // Reconciliation is possible
	SyncStatusNeedUpdate SyncStatus = "NeedUpdate" // Running, update is required
	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) 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,
	spec ytv1.TabletNodesSpec,
	doInitiailization bool,
) *TabletNode

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) 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 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) Exists added in v0.31.0 

func (tt *Timbertruck) Exists() bool

func (*Timbertruck) Fetch 

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

func (*Timbertruck) GetComponent added in v0.31.0 

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

func (*Timbertruck) GetCypressPatch added in v0.31.0 

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

func (*Timbertruck) GetDeliveryLoggers 

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

func (*Timbertruck) GetFullName added in v0.31.0 

func (c *Timbertruck) 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 (*Timbertruck) GetImageHeaterTarget added in v0.31.0 

func (c *Timbertruck) GetImageHeaterTarget() *ImageHeaterTarget

func (*Timbertruck) GetLabeller added in v0.31.0 

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

func (*Timbertruck) GetReadyCondition added in v0.31.0 

func (c *Timbertruck) GetReadyCondition() ComponentStatus

func (*Timbertruck) GetShortName added in v0.31.0 

func (c *Timbertruck) GetShortName() string

func (*Timbertruck) GetStatus added in v0.31.0 

func (c *Timbertruck) GetStatus() ComponentStatus

func (*Timbertruck) GetType added in v0.31.0 

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

func (*Timbertruck) IsUpdatingResources added in v0.31.0 

func (c *Timbertruck) IsUpdatingResources() bool

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

func (c *Timbertruck) SetReadyCondition(status ComponentStatus)

func (*Timbertruck) SetStatus added in v0.31.0 

func (c *Timbertruck) SetStatus(status ComponentStatus)

func (*Timbertruck) Sync 

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

func (*Timbertruck) UpdatePreCheck added in v0.31.0 

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

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) 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) 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,
	httpProxy Component,
	getAllComponents func() []Component,

) *YtsaurusClient

func (*YtsaurusClient) AreMasterSnapshotsBuilt 

func (yc *YtsaurusClient) AreMasterSnapshotsBuilt(ctx context.Context, monitoringPaths []string) (bool, 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) BuildMasterSnapshots 

func (yc *YtsaurusClient) BuildMasterSnapshots(ctx context.Context) 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) GetComponent added in v0.31.0 

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

func (*YtsaurusClient) GetCypressPatch 

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

func (*YtsaurusClient) GetFullName added in v0.31.0 

func (c *YtsaurusClient) 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 (*YtsaurusClient) GetImageHeaterTarget added in v0.31.0 

func (c *YtsaurusClient) GetImageHeaterTarget() *ImageHeaterTarget

func (*YtsaurusClient) GetLabeller added in v0.31.0 

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

func (*YtsaurusClient) GetMasterMonitoringPaths 

func (yc *YtsaurusClient) GetMasterMonitoringPaths(ctx context.Context) ([]string, error)

func (*YtsaurusClient) GetReadyCondition added in v0.31.0 

func (c *YtsaurusClient) GetReadyCondition() ComponentStatus

func (*YtsaurusClient) GetShortName added in v0.31.0 

func (c *YtsaurusClient) GetShortName() string

func (*YtsaurusClient) GetStatus added in v0.31.0 

func (c *YtsaurusClient) GetStatus() ComponentStatus

func (*YtsaurusClient) GetTabletCells 

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

func (*YtsaurusClient) GetType added in v0.31.0 

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

func (*YtsaurusClient) GetYtClient 

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

func (*YtsaurusClient) HandlePossibilityCheck 

func (yc *YtsaurusClient) HandlePossibilityCheck(ctx context.Context) (ok bool, msg string, err error)

func (*YtsaurusClient) IsBundleControllerDisabled added in v0.31.0 

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

func (*YtsaurusClient) IsUpdatingResources added in v0.31.0 

func (c *YtsaurusClient) IsUpdatingResources() bool

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) SetBundleControllerDisabled added in v0.31.0 

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

func (*YtsaurusClient) SetReadyCondition 

func (c *YtsaurusClient) SetReadyCondition(status ComponentStatus)

func (*YtsaurusClient) SetStatus added in v0.31.0 

func (c *YtsaurusClient) SetStatus(status ComponentStatus)

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) UpdatePreCheck added in v0.31.0 

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

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.