components

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

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

 Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source 
const ChytInitClusterJobConfigFileName = "chyt-init-cluster.yson"
View Source 
const DefaultBundle string = "default"
View Source 
const (
	JsPrologue string = "module.exports = "
)
View Source 
const SysBundle string = "sys"
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 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 GetNotGoodTabletCellBundles 

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

func IsRunningStatus 

func IsRunningStatus(status SyncStatus) bool

func IsUpdatingComponent 

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

func LocalServerNeedSync 

func LocalServerNeedSync(srv server, ytsaurus *apiproxy.Ytsaurus) 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

func SetWithIgnoreExisting 

func SetWithIgnoreExisting(path string, value string) string

Types

type Chyt 

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

func NewChyt 

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

func (*Chyt) Fetch 

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

func (*Chyt) Status 

func (c *Chyt) Status(ctx context.Context) ComponentStatus

func (*Chyt) Sync 

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

type Component 

type Component interface {
	Fetch(ctx context.Context) error
	Sync(ctx context.Context) error
	Status(ctx context.Context) (ComponentStatus, error)
	GetName() string
	GetType() consts.ComponentType
	SetReadyCondition(status ComponentStatus)

	// TODO(nadya73): refactor it
	IsUpdatable() bool
}

type ComponentStatus 

type ComponentStatus struct {
	SyncStatus SyncStatus
	Message    string
}

func NewComponentStatus 

func NewComponentStatus(status SyncStatus, message string) ComponentStatus

func SimpleStatus 

func SimpleStatus(status SyncStatus) ComponentStatus

func WaitingStatus 

func WaitingStatus(status SyncStatus, event string) ComponentStatus

type ConfigHelper 

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

func NewConfigHelper 

func NewConfigHelper(
	labeller *labeller.Labeller,
	apiProxy apiproxy.APIProxy,
	name string,
	configOverrides *corev1.LocalObjectReference,
	generators map[string]ytconfig.GeneratorDescriptor) *ConfigHelper

func (*ConfigHelper) Build 

func (h *ConfigHelper) Build() *corev1.ConfigMap

func (*ConfigHelper) Exists 

func (h *ConfigHelper) Exists() bool

func (*ConfigHelper) Fetch 

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

func (*ConfigHelper) GetConfigMapName 

func (h *ConfigHelper) GetConfigMapName() string

func (*ConfigHelper) GetFileNames 

func (h *ConfigHelper) GetFileNames() []string

func (*ConfigHelper) NeedInit 

func (h *ConfigHelper) NeedInit() bool

func (*ConfigHelper) NeedReload 

func (h *ConfigHelper) NeedReload() (bool, error)

func (*ConfigHelper) RemoveIfExists 

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

func (*ConfigHelper) Sync 

func (h *ConfigHelper) 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) *ControllerAgent

func (*ControllerAgent) Fetch 

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

func (*ControllerAgent) GetType 

func (ca *ControllerAgent) GetType() consts.ComponentType

func (*ControllerAgent) IsUpdatable 

func (ca *ControllerAgent) IsUpdatable() bool

func (*ControllerAgent) NeedSync 

func (c *ControllerAgent) NeedSync() bool

func (*ControllerAgent) Status 

func (ca *ControllerAgent) Status(ctx context.Context) (ComponentStatus, error)

func (*ControllerAgent) Sync 

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

type DataNode 

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

func NewDataNode 

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

func (*DataNode) Fetch 

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

func (*DataNode) GetType 

func (n *DataNode) GetType() consts.ComponentType

func (*DataNode) IsUpdatable 

func (n *DataNode) IsUpdatable() bool

func (*DataNode) NeedSync 

func (c *DataNode) NeedSync() bool

func (*DataNode) Status 

func (n *DataNode) Status(ctx context.Context) (ComponentStatus, error)

func (*DataNode) Sync 

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

type Discovery 

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

func NewDiscovery 

func NewDiscovery(cfgen *ytconfig.Generator, ytsaurus *apiproxy.Ytsaurus) *Discovery

func (*Discovery) Fetch 

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

func (*Discovery) GetType 

func (d *Discovery) GetType() consts.ComponentType

func (*Discovery) IsUpdatable 

func (d *Discovery) IsUpdatable() bool

func (*Discovery) NeedSync 

func (c *Discovery) NeedSync() bool

func (*Discovery) Status 

func (d *Discovery) Status(ctx context.Context) (ComponentStatus, error)

func (*Discovery) Sync 

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

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,
) *ExecNode

func (*ExecNode) Fetch 

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

func (*ExecNode) GetType 

func (n *ExecNode) GetType() consts.ComponentType

func (*ExecNode) IsJobEnvironmentIsolated 

func (n *ExecNode) IsJobEnvironmentIsolated() bool

Returns true if jobs are executed outside of exec node container.

func (*ExecNode) IsUpdatable 

func (n *ExecNode) IsUpdatable() bool

func (*ExecNode) SetReadyCondition 

func (c *ExecNode) SetReadyCondition(status ComponentStatus)

func (*ExecNode) Status 

func (n *ExecNode) Status(ctx context.Context) (ComponentStatus, error)

func (*ExecNode) Sync 

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

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

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

func (*HttpProxy) GetType 

func (hp *HttpProxy) GetType() consts.ComponentType

func (*HttpProxy) IsUpdatable 

func (hp *HttpProxy) IsUpdatable() bool

func (*HttpProxy) NeedSync 

func (c *HttpProxy) NeedSync() bool

func (*HttpProxy) Status 

func (hp *HttpProxy) Status(ctx context.Context) (ComponentStatus, error)

func (*HttpProxy) Sync 

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

type InitJob 

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

func NewInitJob 

func NewInitJob(
	labeller *labeller.Labeller,
	apiProxy apiproxy.APIProxy,
	conditionsManager apiproxy.ConditionManager,
	imagePullSecrets []corev1.LocalObjectReference,
	name, configFileName, image string,
	generator ytconfig.YsonGeneratorFunc) *InitJob

func (*InitJob) Build 

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

func (*InitJob) Fetch 

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

func (*InitJob) GetName 

func (c *InitJob) GetName() string

GetName 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) IsCompleted 

func (j *InitJob) IsCompleted() bool

func (*InitJob) SetInitScript 

func (j *InitJob) SetInitScript(script string)

func (*InitJob) Sync 

func (j *InitJob) 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) Fetch 

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

func (*Master) GetType 

func (m *Master) GetType() consts.ComponentType

func (*Master) IsUpdatable 

func (m *Master) IsUpdatable() bool

func (*Master) NeedSync 

func (c *Master) NeedSync() bool

func (*Master) Status 

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

func (*Master) Sync 

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

type MasterCache 

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

func NewMasterCache 

func NewMasterCache(cfgen *ytconfig.Generator, ytsaurus *apiproxy.Ytsaurus) *MasterCache

func (*MasterCache) Fetch 

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

func (*MasterCache) GetType 

func (mc *MasterCache) GetType() consts.ComponentType

func (*MasterCache) IsUpdatable 

func (mc *MasterCache) IsUpdatable() bool

func (*MasterCache) NeedSync 

func (c *MasterCache) NeedSync() bool

func (*MasterCache) Status 

func (mc *MasterCache) Status(ctx context.Context) (ComponentStatus, error)

func (*MasterCache) Sync 

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

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 Medium 

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

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

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

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

func (*QueryTracker) GetType 

func (qt *QueryTracker) GetType() consts.ComponentType

func (*QueryTracker) IsUpdatable 

func (qt *QueryTracker) IsUpdatable() bool

func (*QueryTracker) NeedSync 

func (c *QueryTracker) NeedSync() bool

func (*QueryTracker) Status 

func (qt *QueryTracker) Status(ctx context.Context) (ComponentStatus, error)

func (*QueryTracker) Sync 

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

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

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

func (*QueueAgent) GetType 

func (qa *QueueAgent) GetType() consts.ComponentType

func (*QueueAgent) IsUpdatable 

func (qa *QueueAgent) IsUpdatable() bool

func (*QueueAgent) NeedSync 

func (c *QueueAgent) NeedSync() bool

func (*QueueAgent) Status 

func (qa *QueueAgent) Status(ctx context.Context) (ComponentStatus, error)

func (*QueueAgent) Sync 

func (qa *QueueAgent) Sync(ctx context.Context) 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) Fetch 

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

func (*RemoteExecNode) GetName 

func (c *RemoteExecNode) GetName() string

GetName 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 (*RemoteExecNode) GetType 

func (n *RemoteExecNode) GetType() consts.ComponentType

func (*RemoteExecNode) IsJobEnvironmentIsolated 

func (n *RemoteExecNode) IsJobEnvironmentIsolated() bool

Returns true if jobs are executed outside of exec node container.

func (*RemoteExecNode) Sync 

func (n *RemoteExecNode) Sync(ctx context.Context) (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) Fetch 

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

func (*RpcProxy) GetType 

func (rp *RpcProxy) GetType() consts.ComponentType

func (*RpcProxy) IsUpdatable 

func (rp *RpcProxy) IsUpdatable() bool

func (*RpcProxy) NeedSync 

func (c *RpcProxy) NeedSync() bool

func (*RpcProxy) Status 

func (rp *RpcProxy) Status(ctx context.Context) (ComponentStatus, error)

func (*RpcProxy) Sync 

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

type Scheduler 

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

func NewScheduler 

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

func (*Scheduler) Fetch 

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

func (*Scheduler) GetType 

func (s *Scheduler) GetType() consts.ComponentType

func (*Scheduler) IsUpdatable 

func (s *Scheduler) IsUpdatable() bool

func (*Scheduler) NeedSync 

func (c *Scheduler) NeedSync() bool

func (*Scheduler) Status 

func (s *Scheduler) Status(ctx context.Context) (ComponentStatus, error)

func (*Scheduler) Sync 

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

type Spyt 

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

func NewSpyt 

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

func (*Spyt) Fetch 

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

func (*Spyt) Status 

func (s *Spyt) Status(ctx context.Context) ComponentStatus

func (*Spyt) Sync 

func (s *Spyt) Sync(ctx context.Context) 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) Fetch 

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

func (*StrawberryController) GetType 

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

func (*StrawberryController) IsUpdatable 

func (c *StrawberryController) IsUpdatable() bool

func (*StrawberryController) SetReadyCondition 

func (c *StrawberryController) SetReadyCondition(status ComponentStatus)

func (*StrawberryController) Status 

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

func (*StrawberryController) Sync 

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

type SyncStatus 

type SyncStatus string
const (
	SyncStatusBlocked         SyncStatus = "Blocked"
	SyncStatusNeedLocalUpdate SyncStatus = "NeedLocalUpdate"
	SyncStatusPending         SyncStatus = "Pending"
	SyncStatusReady           SyncStatus = "Ready"
	SyncStatusUpdating        SyncStatus = "Updating"
)

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

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

func (*TabletNode) GetType 

func (tn *TabletNode) GetType() consts.ComponentType

func (*TabletNode) IsUpdatable 

func (tn *TabletNode) IsUpdatable() bool

func (*TabletNode) NeedSync 

func (c *TabletNode) NeedSync() bool

func (*TabletNode) Status 

func (tn *TabletNode) Status(ctx context.Context) (ComponentStatus, error)

func (*TabletNode) Sync 

func (tn *TabletNode) Sync(ctx context.Context) 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) Fetch 

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

func (*TcpProxy) GetType 

func (tp *TcpProxy) GetType() consts.ComponentType

func (*TcpProxy) IsUpdatable 

func (tp *TcpProxy) IsUpdatable() bool

func (*TcpProxy) NeedSync 

func (c *TcpProxy) NeedSync() bool

func (*TcpProxy) Status 

func (tp *TcpProxy) Status(ctx context.Context) (ComponentStatus, error)

func (*TcpProxy) Sync 

func (tp *TcpProxy) Sync(ctx context.Context) 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) Fetch 

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

func (*UI) GetType 

func (u *UI) GetType() consts.ComponentType

func (*UI) IsUpdatable 

func (u *UI) IsUpdatable() bool

func (*UI) SetReadyCondition 

func (c *UI) SetReadyCondition(status ComponentStatus)

func (*UI) Status 

func (u *UI) Status(ctx context.Context) (ComponentStatus, error)

func (*UI) Sync 

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

type YqlAgent 

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

func NewYQLAgent 

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

func (*YqlAgent) Fetch 

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

func (*YqlAgent) GetName 

func (yqla *YqlAgent) GetName() string

func (*YqlAgent) GetType 

func (yqla *YqlAgent) GetType() consts.ComponentType

func (*YqlAgent) IsUpdatable 

func (yqla *YqlAgent) IsUpdatable() bool

func (*YqlAgent) NeedSync 

func (c *YqlAgent) NeedSync() bool

func (*YqlAgent) Status 

func (yqla *YqlAgent) Status(ctx context.Context) (ComponentStatus, error)

func (*YqlAgent) Sync 

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

type YtsaurusClient 

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

func NewYtsaurusClient 

func NewYtsaurusClient(
	cfgen *ytconfig.Generator,
	ytsaurus *apiproxy.Ytsaurus,
	httpProxy 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) DisableSafeMode 

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

func (*YtsaurusClient) EnableSafeMode 

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

func (*YtsaurusClient) Fetch 

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

func (*YtsaurusClient) GetMasterMonitoringPaths 

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

func (*YtsaurusClient) GetTabletCells 

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

func (*YtsaurusClient) GetType 

func (yc *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) IsUpdatable 

func (yc *YtsaurusClient) IsUpdatable() bool

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

func (c *YtsaurusClient) SetReadyCondition(status ComponentStatus)

func (*YtsaurusClient) StartBuildMasterSnapshots 

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

func (*YtsaurusClient) Status 

func (yc *YtsaurusClient) Status(ctx context.Context) (ComponentStatus, error)

func (*YtsaurusClient) Sync 

func (yc *YtsaurusClient) Sync(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.