Documentation ¶
Index ¶
- Constants
- func RandString(n int) string
- type AddressList
- type AddressResolver
- type Auth
- type BaseGenerator
- func (g *BaseGenerator) FormatComponentStringWithDefault(base string, name string) string
- func (g *BaseGenerator) GetDiscoveryPodNames() []string
- func (g *BaseGenerator) GetDiscoveryServiceName() string
- func (g *BaseGenerator) GetDiscoveryStatefulSetName() string
- func (g *BaseGenerator) GetMasterCachesPodNames() []string
- func (g *BaseGenerator) GetMasterCachesServiceName() string
- func (g *BaseGenerator) GetMasterCachesStatefulSetName() string
- func (g *BaseGenerator) GetMasterPodNames() []string
- func (g *BaseGenerator) GetMastersServiceName() string
- func (g *BaseGenerator) GetMastersStatefulSetName() string
- func (g *BaseGenerator) GetMaxReplicationFactor() int32
- type BasicServer
- type BindMount
- type BlockCache
- type Bus
- type BusServer
- type Cache
- type CacheLocation
- type ChytInitCluster
- type ClusterConnection
- type ClusterMapping
- type CommonServer
- type ConfigFormat
- type ControllerAgent
- type ControllerAgentServer
- type Coordinator
- type CriExecutor
- type CriJobEnvironment
- type CypressCookieManager
- type CypressManager
- type CypressTokenAuthenticator
- type CypressUserManager
- type DataNode
- type DataNodeServer
- type Discovery
- type DiscoveryConnection
- type DiscoveryServer
- type Driver
- type EncryptionMode
- type ExecNode
- type ExecNodeServer
- type GatewayConfig
- type Generator
- func (g *Generator) GetChytInitClusterConfig() ([]byte, error)
- func (g *Generator) GetClusterConnection() ([]byte, error)
- func (g *Generator) GetControllerAgentConfig(spec *ytv1.ControllerAgentsSpec) ([]byte, error)
- func (g *Generator) GetDiscoveryConfig(spec *ytv1.DiscoverySpec) ([]byte, error)
- func (g *Generator) GetHTTPProxiesAddress(role string) string
- func (g *Generator) GetHTTPProxiesHeadlessServiceName(role string) string
- func (g *Generator) GetHTTPProxiesServiceAddress(role string) string
- func (g *Generator) GetHTTPProxiesServiceName(role string) string
- func (g *Generator) GetHTTPProxiesStatefulSetName(role string) string
- func (g *Generator) GetHTTPProxyConfig(spec ytv1.HTTPProxiesSpec) ([]byte, error)
- func (g *Generator) GetMasterCachesConfig(spec *ytv1.MasterCachesSpec) ([]byte, error)
- func (g *Generator) GetMasterConfig(spec *ytv1.MastersSpec) ([]byte, error)
- func (g *Generator) GetNativeClientConfig() ([]byte, error)
- func (g *Generator) GetQueryTrackerConfig(spec *ytv1.QueryTrackerSpec) ([]byte, error)
- func (g *Generator) GetQueryTrackerServiceName() string
- func (g *Generator) GetQueryTrackerStatefulSetName() string
- func (g *Generator) GetQueueAgentAddresses() []string
- func (g *Generator) GetQueueAgentConfig(spec *ytv1.QueueAgentSpec) ([]byte, error)
- func (g *Generator) GetQueueAgentPodNames() []string
- func (g *Generator) GetQueueAgentServiceName() string
- func (g *Generator) GetQueueAgentStatefulSetName() string
- func (g *Generator) GetRPCProxiesHeadlessServiceName(role string) string
- func (g *Generator) GetRPCProxiesServiceName(role string) string
- func (g *Generator) GetRPCProxiesStatefulSetName(role string) string
- func (g *Generator) GetRPCProxyConfig(spec ytv1.RPCProxiesSpec) ([]byte, error)
- func (g *Generator) GetSchedulerConfig(spec *ytv1.SchedulersSpec) ([]byte, error)
- func (g *Generator) GetSchedulerServiceName() string
- func (g *Generator) GetSchedulerStatefulSetName() string
- func (g *Generator) GetStrawberryControllerConfig() ([]byte, error)
- func (g *Generator) GetStrawberryControllerHeadlessServiceName() string
- func (g *Generator) GetStrawberryControllerServiceAddress() string
- func (g *Generator) GetTCPProxiesHeadlessServiceName(role string) string
- func (g *Generator) GetTCPProxiesServiceName(role string) string
- func (g *Generator) GetTCPProxiesStatefulSetName(role string) string
- func (g *Generator) GetTCPProxyConfig(spec ytv1.TCPProxiesSpec) ([]byte, error)
- func (g *Generator) GetUIClustersConfig() ([]byte, error)
- func (g *Generator) GetUICustomConfig() ([]byte, error)
- func (g *Generator) GetYQLAgentAddresses() []string
- func (g *Generator) GetYQLAgentConfig(spec *ytv1.YQLAgentSpec) ([]byte, error)
- func (g *Generator) GetYQLAgentPodNames() []string
- func (g *Generator) GetYQLAgentServiceName() string
- func (g *Generator) GetYQLAgentStatefulSetName() string
- type GeneratorDescriptor
- type GpuInfoSource
- type GpuInfoSourceType
- type GpuManager
- type HTTPProxyServer
- type HTTPSServer
- type HTTPSServerCredentials
- type HTTPServer
- type HydraManager
- type HydraPeer
- type IOEngine
- type JobController
- type JobEnvironment
- type JobEnvironmentType
- type JobProxy
- type JobResourceLimits
- type JobResourceManager
- type LogFamily
- type Logging
- type LoggingRule
- type LoggingWriter
- type MasterCache
- type MasterCacheServer
- type MasterCell
- type MasterChangelogs
- type MasterServer
- type MasterSnapshots
- type NativeClient
- type NodeFlavor
- type NodeGenerator
- func (g *NodeGenerator) GetContainerdConfig(spec *ytv1.ExecNodesSpec) ([]byte, error)
- func (g *NodeGenerator) GetDataNodeConfig(spec ytv1.DataNodesSpec) ([]byte, error)
- func (g *NodeGenerator) GetDataNodesServiceName(name string) string
- func (g *NodeGenerator) GetDataNodesStatefulSetName(name string) string
- func (g *NodeGenerator) GetExecNodeConfig(spec ytv1.ExecNodesSpec) ([]byte, error)
- func (g *NodeGenerator) GetExecNodesServiceName(name string) string
- func (g *NodeGenerator) GetExecNodesStatefulSetName(name string) string
- func (g *NodeGenerator) GetTabletNodeConfig(spec ytv1.TabletNodesSpec) ([]byte, error)
- func (g *NodeGenerator) GetTabletNodesServiceName(name string) string
- func (g *NodeGenerator) GetTabletNodesStatefulSetName(name string) string
- type NodeServer
- type OauthCookieAuthenticator
- type OauthService
- type OauthTokenAuthenticator
- type OperationsCleaner
- type PemBlob
- type QueryTrackerServer
- type QueueAgent
- type QueueAgentServer
- type RPCProxyServer
- type ResourceLimits
- type RetryingChannel
- type Scheduler
- type SchedulerServer
- type SlotLocation
- type SlotManager
- type StoreLocation
- type Strawberry
- type StrawberryController
- type TCPProxyServer
- type TabletNode
- type TabletNodeServer
- type TimestampProviders
- type UIAuthenticationType
- type UICluster
- type UIClusters
- type UICustom
- type UIPrimaryMaster
- type VerificationMode
- type YQLAgent
- type YQLAgentServer
- type YsonGeneratorFunc
Constants ¶
View Source
const ( ConfigFormatYson = "yson" ConfigFormatJson = "json" ConfigFormatJsonWithJsPrologue = "json_with_js_prologue" ConfigFormatToml = "toml" )
Variables ¶
This section is empty.
Functions ¶
func RandString ¶
Types ¶
type AddressList ¶
type AddressList struct {
Addresses []string `yson:"addresses"`
}
type AddressResolver ¶
type Auth ¶
type Auth struct { CypressCookieManager CypressCookieManager `yson:"cypress_cookie_manager"` CypressUserManager CypressUserManager `yson:"cypress_user_manager"` CypressTokenAuthenticator CypressTokenAuthenticator `yson:"cypress_token_authenticator"` OauthService *OauthService `yson:"oauth_service,omitempty"` OauthCookieAuthenticator *OauthCookieAuthenticator `yson:"oauth_cookie_authenticator,omitempty"` OauthTokenAuthenticator *OauthTokenAuthenticator `yson:"oauth_token_authenticator,omitempty"` RequireAuthentication bool `yson:"require_authentication"` }
type BaseGenerator ¶
type BaseGenerator struct {
// contains filtered or unexported fields
}
func NewLocalBaseGenerator ¶
func NewLocalBaseGenerator( ytsaurus *ytv1.Ytsaurus, clusterDomain string, ) *BaseGenerator
func NewRemoteBaseGenerator ¶
func NewRemoteBaseGenerator( key types.NamespacedName, clusterDomain string, commonSpec ytv1.CommonSpec, masterConnectionSpec ytv1.MasterConnectionSpec, masterCachesSpec *ytv1.MasterCachesSpec, ) *BaseGenerator
func (*BaseGenerator) FormatComponentStringWithDefault ¶
func (g *BaseGenerator) FormatComponentStringWithDefault(base string, name string) string
func (*BaseGenerator) GetDiscoveryPodNames ¶
func (g *BaseGenerator) GetDiscoveryPodNames() []string
func (*BaseGenerator) GetDiscoveryServiceName ¶
func (g *BaseGenerator) GetDiscoveryServiceName() string
func (*BaseGenerator) GetDiscoveryStatefulSetName ¶
func (g *BaseGenerator) GetDiscoveryStatefulSetName() string
func (*BaseGenerator) GetMasterCachesPodNames ¶
func (g *BaseGenerator) GetMasterCachesPodNames() []string
func (*BaseGenerator) GetMasterCachesServiceName ¶
func (g *BaseGenerator) GetMasterCachesServiceName() string
func (*BaseGenerator) GetMasterCachesStatefulSetName ¶
func (g *BaseGenerator) GetMasterCachesStatefulSetName() string
func (*BaseGenerator) GetMasterPodNames ¶
func (g *BaseGenerator) GetMasterPodNames() []string
func (*BaseGenerator) GetMastersServiceName ¶
func (g *BaseGenerator) GetMastersServiceName() string
func (*BaseGenerator) GetMastersStatefulSetName ¶
func (g *BaseGenerator) GetMastersStatefulSetName() string
func (*BaseGenerator) GetMaxReplicationFactor ¶
func (g *BaseGenerator) GetMaxReplicationFactor() int32
type BasicServer ¶
type BasicServer struct { AddressResolver AddressResolver `yson:"address_resolver"` Logging Logging `yson:"logging"` MonitoringPort int32 `yson:"monitoring_port"` RPCPort int32 `yson:"rpc_port"` BusServer *BusServer `yson:"bus_server,omitempty"` }
BasicServer is used as a basic config for basic components, such as clocks or discovery.
type BlockCache ¶
type Bus ¶
type Bus struct { EncryptionMode EncryptionMode `yson:"encryption_mode,omitempty"` CertChain *PemBlob `yson:"cert_chain,omitempty"` PrivateKey *PemBlob `yson:"private_key,omitempty"` CipherList []string `yson:"cipher_list,omitempty"` CA *PemBlob `yson:"ca,omitempty"` VerificationMode VerificationMode `yson:"verification_mode,omitempty"` PeerAlternativeHostName string `yson:"peer_alternative_host_name,omitempty"` }
type CacheLocation ¶
type ChytInitCluster ¶
type ClusterConnection ¶
type ClusterConnection struct { ClusterName string `yson:"cluster_name"` PrimaryMaster MasterCell `yson:"primary_master"` DiscoveryConnection DiscoveryConnection `yson:"discovery_connection,omitempty"` BusClient *Bus `yson:"bus_client,omitempty"` MasterCache MasterCache `yson:"master_cache"` }
type ClusterMapping ¶
type CommonServer ¶
type CommonServer struct { BasicServer TimestampProviders TimestampProviders `yson:"timestamp_provider"` ClusterConnection ClusterConnection `yson:"cluster_connection"` CypressAnnotations map[string]any `yson:"cypress_annotations,omitempty"` }
type ConfigFormat ¶
type ConfigFormat string
type ControllerAgent ¶
type ControllerAgentServer ¶
type ControllerAgentServer struct { CommonServer ControllerAgent ControllerAgent `yson:"controller_agent"` }
type Coordinator ¶
type CriExecutor ¶
type CriExecutor struct { RetryingChannel RuntimeEndpoint string `yson:"runtime_endpoint,omitempty"` ImageEndpoint string `yson:"image_endpoint,omitempty"` Namespace string `yson:"namespace"` BaseCgroup string `yson:"base_cgroup"` RuntimeHandler string `yson:"runtime_handler,omitempty"` CpuPeriod yson.Duration `yson:"cpu_period,omitempty"` }
type CriJobEnvironment ¶
type CriJobEnvironment struct { CriExecutor *CriExecutor `yson:"cri_executor,omitempty"` JobProxyImage string `yson:"job_proxy_image,omitempty"` JobProxyBindMounts []BindMount `yson:"job_proxy_bind_mounts,omitempty"` UseJobProxyFromImage *bool `yson:"use_job_proxy_from_image,omitempty"` }
type CypressCookieManager ¶
type CypressCookieManager struct{}
type CypressManager ¶
type CypressManager struct { DefaultTableReplicationFactor int `yson:"default_table_replication_factor,omitempty"` DefaultFileReplicationFactor int `yson:"default_file_replication_factor,omitempty"` DefaultJournalReplicationFactor int `yson:"default_journal_replication_factor,omitempty"` DefaultJournalReadQuorum int `yson:"default_journal_read_quorum,omitempty"` DefaultJournalWriteQuorum int `yson:"default_journal_write_quorum,omitempty"` }
type CypressTokenAuthenticator ¶
type CypressTokenAuthenticator struct {
Secure bool `yson:"secure"`
}
type CypressUserManager ¶
type CypressUserManager struct{}
type DataNode ¶
type DataNode struct { StoreLocations []StoreLocation `yson:"store_locations"` CacheLocations []CacheLocation `yson:"cache_locations"` BlockCache BlockCache `yson:"block_cache"` BlocksExtCache Cache `yson:"blocks_ext_cache"` ChunkMetaCache Cache `yson:"chunk_meta_cache"` BlockMetaCache Cache `yson:"block_meta_cache"` }
type DataNodeServer ¶
type DataNodeServer struct { NodeServer DataNode DataNode `yson:"data_node"` }
type Discovery ¶
type Discovery struct { // Unfortunately AddressList is not applicable here, since // config field is named differently. Addresses []string `yson:"server_addresses"` }
type DiscoveryConnection ¶
type DiscoveryConnection struct {
AddressList
}
type DiscoveryServer ¶
type DiscoveryServer struct { CommonServer DiscoveryServer Discovery `yson:"discovery_server"` }
type Driver ¶
type Driver struct { TimestampProviders TimestampProviders `yson:"timestamp_provider,omitempty"` PrimaryMaster MasterCell `yson:"primary_master,omitempty"` APIVersion int `yson:"api_version,omitempty"` }
type EncryptionMode ¶
type EncryptionMode string
const ( EncryptionModeDisabled EncryptionMode = "disabled" EncryptionModeOptional EncryptionMode = "optional" EncryptionModeRequired EncryptionMode = "required" )
type ExecNode ¶
type ExecNode struct { SlotManager SlotManager `yson:"slot_manager"` GpuManager GpuManager `yson:"gpu_manager"` JobController JobController `yson:"job_controller"` JobProxy JobProxy `yson:"job_proxy"` JobProxyAuthenticationManagerLegacy *Auth `yson:"job_proxy_authentication_manager,omitempty"` JobProxyLoggingLegacy *Logging `yson:"job_proxy_logging,omitempty"` DoNotSetUserIdLegacy *bool `yson:"do_not_set_user_id,omitempty"` ForwardAllEnvironmentVariablesLegacy *bool `yson:"forward_all_environment_variables,omitempty"` // NOTE: Non-legacy "use_artifact_binds" moved into dynamic config. UseArtifactBindsLegacy *bool `yson:"use_artifact_binds,omitempty"` }
type ExecNodeServer ¶
type ExecNodeServer struct { NodeServer JobResourceManager JobResourceManager `yson:"job_resource_manager"` ExecNode ExecNode `yson:"exec_node"` DataNode DataNode `yson:"data_node"` TabletNode TabletNode `yson:"tablet_node"` CachingObjectService Cache `yson:"caching_object_service"` }
type GatewayConfig ¶
type GatewayConfig struct { MRJobBinary string `yson:"mr_job_bin"` UDFDirectory string `yson:"mr_job_udfs_dir"` ClusterMapping []ClusterMapping `yson:"cluster_mapping"` }
type Generator ¶
type Generator struct { BaseGenerator // contains filtered or unexported fields }
func (*Generator) GetChytInitClusterConfig ¶
func (*Generator) GetClusterConnection ¶
func (*Generator) GetControllerAgentConfig ¶
func (g *Generator) GetControllerAgentConfig(spec *ytv1.ControllerAgentsSpec) ([]byte, error)
func (*Generator) GetDiscoveryConfig ¶
func (g *Generator) GetDiscoveryConfig(spec *ytv1.DiscoverySpec) ([]byte, error)
func (*Generator) GetHTTPProxiesAddress ¶
func (*Generator) GetHTTPProxiesHeadlessServiceName ¶
func (*Generator) GetHTTPProxiesServiceAddress ¶
func (*Generator) GetHTTPProxiesServiceName ¶
func (*Generator) GetHTTPProxiesStatefulSetName ¶
func (*Generator) GetHTTPProxyConfig ¶
func (g *Generator) GetHTTPProxyConfig(spec ytv1.HTTPProxiesSpec) ([]byte, error)
func (*Generator) GetMasterCachesConfig ¶
func (g *Generator) GetMasterCachesConfig(spec *ytv1.MasterCachesSpec) ([]byte, error)
func (*Generator) GetMasterConfig ¶
func (g *Generator) GetMasterConfig(spec *ytv1.MastersSpec) ([]byte, error)
func (*Generator) GetNativeClientConfig ¶
func (*Generator) GetQueryTrackerConfig ¶
func (g *Generator) GetQueryTrackerConfig(spec *ytv1.QueryTrackerSpec) ([]byte, error)
func (*Generator) GetQueryTrackerServiceName ¶
func (*Generator) GetQueryTrackerStatefulSetName ¶
func (*Generator) GetQueueAgentAddresses ¶
func (*Generator) GetQueueAgentConfig ¶
func (g *Generator) GetQueueAgentConfig(spec *ytv1.QueueAgentSpec) ([]byte, error)
func (*Generator) GetQueueAgentPodNames ¶
func (*Generator) GetQueueAgentServiceName ¶
func (*Generator) GetQueueAgentStatefulSetName ¶
func (*Generator) GetRPCProxiesHeadlessServiceName ¶
func (*Generator) GetRPCProxiesServiceName ¶
func (*Generator) GetRPCProxiesStatefulSetName ¶
func (*Generator) GetRPCProxyConfig ¶
func (g *Generator) GetRPCProxyConfig(spec ytv1.RPCProxiesSpec) ([]byte, error)
func (*Generator) GetSchedulerConfig ¶
func (g *Generator) GetSchedulerConfig(spec *ytv1.SchedulersSpec) ([]byte, error)
func (*Generator) GetSchedulerServiceName ¶
func (*Generator) GetSchedulerStatefulSetName ¶
func (*Generator) GetStrawberryControllerConfig ¶
func (*Generator) GetStrawberryControllerHeadlessServiceName ¶
func (*Generator) GetStrawberryControllerServiceAddress ¶
func (*Generator) GetTCPProxiesHeadlessServiceName ¶
func (*Generator) GetTCPProxiesServiceName ¶
func (*Generator) GetTCPProxiesStatefulSetName ¶
func (*Generator) GetTCPProxyConfig ¶
func (g *Generator) GetTCPProxyConfig(spec ytv1.TCPProxiesSpec) ([]byte, error)
func (*Generator) GetUIClustersConfig ¶
func (*Generator) GetUICustomConfig ¶
func (*Generator) GetYQLAgentAddresses ¶
func (*Generator) GetYQLAgentConfig ¶
func (g *Generator) GetYQLAgentConfig(spec *ytv1.YQLAgentSpec) ([]byte, error)
func (*Generator) GetYQLAgentPodNames ¶
func (*Generator) GetYQLAgentServiceName ¶
func (*Generator) GetYQLAgentStatefulSetName ¶
type GeneratorDescriptor ¶
type GeneratorDescriptor struct { // F must generate config in YSON. F YsonGeneratorFunc // Fmt is the desired serialization format for config map. // Note that conversion from YSON to Fmt (if needed) is performed as a very last // step of config generation pipeline. Fmt ConfigFormat }
type GpuInfoSource ¶
type GpuInfoSource struct {
Type GpuInfoSourceType `yson:"type"`
}
type GpuInfoSourceType ¶
type GpuInfoSourceType string
const ( GpuInfoSourceTypeNvGpuManager GpuInfoSourceType = "nv_gpu_manager" GpuInfoSourceTypeNvidiaSmi GpuInfoSourceType = "nvidia_smi" )
type GpuManager ¶
type GpuManager struct {
GpuInfoSource GpuInfoSource `yson:"gpu_info_source"`
}
type HTTPProxyServer ¶
type HTTPProxyServer struct { CommonServer Port int `yson:"port"` Auth Auth `yson:"auth"` Coordinator Coordinator `yson:"coordinator"` Driver Driver `yson:"driver"` Role string `yson:"role"` HTTPSServer *HTTPSServer `yson:"https_server,omitempty"` }
type HTTPSServer ¶
type HTTPSServer struct { HTTPServer Credentials HTTPSServerCredentials `yson:"credentials"` }
type HTTPSServerCredentials ¶
type HTTPServer ¶
type HTTPServer struct {
Port int `yson:"port"`
}
type HydraManager ¶
type JobController ¶
type JobController struct { ResourceLimitsLegacy *JobResourceLimits `yson:"resource_limits,omitempty"` GpuManagerLegacy *GpuManager `yson:"gpu_manager,omitempty"` }
type JobEnvironment ¶
type JobEnvironment struct { Type JobEnvironmentType `yson:"type,omitempty"` StartUID int `yson:"start_uid,omitempty"` // FIXME(khlebnikov): Add "inline" tag into yson or remove polymorphism in config. CriJobEnvironment }
type JobEnvironmentType ¶
type JobEnvironmentType string
const ( JobEnvironmentTypeSimple JobEnvironmentType = "simple" JobEnvironmentTypePorto JobEnvironmentType = "porto" JobEnvironmentTypeCRI JobEnvironmentType = "cri" )
type JobResourceLimits ¶
type JobResourceLimits struct {
UserSlots *int `yson:"user_slots,omitempty"`
}
type JobResourceManager ¶
type JobResourceManager struct {
ResourceLimits JobResourceLimits `yson:"resource_limits"`
}
type Logging ¶
type Logging struct { Writers map[string]LoggingWriter `yson:"writers"` Rules []LoggingRule `yson:"rules"` FlushPeriod int `yson:"flush_period"` }
type LoggingRule ¶
type LoggingWriter ¶
type LoggingWriter struct { WriterType ytv1.LogWriterType `yson:"type,omitempty"` FileName string `yson:"file_name,omitempty"` Format ytv1.LogFormat `yson:"format,omitempty"` CompressionMethod string `yson:"compression_method,omitempty"` EnableCompression bool `yson:"enable_compression,omitempty"` UseTimestampSuffix bool `yson:"use_timestamp_suffix,omitempty"` EnableSystemMessages bool `yson:"enable_system_messages,omitempty"` RotationPolicy *ytv1.LogRotationPolicy `yson:"rotation_policy,omitempty"` }
type MasterCache ¶
type MasterCache struct { AddressList CellID string `yson:"cell_id"` EnableMasterCacheDiscover bool `yson:"enable_master_cache_discovery"` }
type MasterCacheServer ¶
type MasterCacheServer struct {
CommonServer
}
type MasterCell ¶
type MasterCell struct { AddressList Peers []HydraPeer `yson:"peers"` CellID string `yson:"cell_id"` }
type MasterChangelogs ¶
type MasterServer ¶
type MasterServer struct { CommonServer Snapshots MasterSnapshots `yson:"snapshots"` Changelogs MasterChangelogs `yson:"changelogs"` UseNewHydra bool `yson:"use_new_hydra"` HydraManager HydraManager `yson:"hydra_manager"` CypressManager CypressManager `yson:"cypress_manager"` PrimaryMaster MasterCell `yson:"primary_master"` SecondaryMasters []MasterCell `yson:"secondary_masters"` }
type MasterSnapshots ¶
type MasterSnapshots struct {
Path string `yson:"path"`
}
type NativeClient ¶
type NativeClient struct { AddressResolver AddressResolver `yson:"address_resolver"` Logging Logging `yson:"logging"` Driver Driver `yson:"driver"` }
type NodeFlavor ¶
type NodeFlavor string
const ( NodeFlavorData NodeFlavor = "data" NodeFlavorExec NodeFlavor = "exec" NodeFlavorTablet NodeFlavor = "tablet" )
type NodeGenerator ¶
type NodeGenerator struct {
BaseGenerator
}
func NewLocalNodeGenerator ¶
func NewLocalNodeGenerator( ytsaurus *ytv1.Ytsaurus, clusterDomain string, ) *NodeGenerator
func NewRemoteNodeGenerator ¶
func NewRemoteNodeGenerator( key types.NamespacedName, clusterDomain string, commonSpec ytv1.CommonSpec, masterConnectionSpec ytv1.MasterConnectionSpec, masterCachesSpec *ytv1.MasterCachesSpec, ) *NodeGenerator
func (*NodeGenerator) GetContainerdConfig ¶
func (g *NodeGenerator) GetContainerdConfig(spec *ytv1.ExecNodesSpec) ([]byte, error)
func (*NodeGenerator) GetDataNodeConfig ¶
func (g *NodeGenerator) GetDataNodeConfig(spec ytv1.DataNodesSpec) ([]byte, error)
func (*NodeGenerator) GetDataNodesServiceName ¶
func (g *NodeGenerator) GetDataNodesServiceName(name string) string
func (*NodeGenerator) GetDataNodesStatefulSetName ¶
func (g *NodeGenerator) GetDataNodesStatefulSetName(name string) string
func (*NodeGenerator) GetExecNodeConfig ¶
func (g *NodeGenerator) GetExecNodeConfig(spec ytv1.ExecNodesSpec) ([]byte, error)
func (*NodeGenerator) GetExecNodesServiceName ¶
func (g *NodeGenerator) GetExecNodesServiceName(name string) string
func (*NodeGenerator) GetExecNodesStatefulSetName ¶
func (g *NodeGenerator) GetExecNodesStatefulSetName(name string) string
func (*NodeGenerator) GetTabletNodeConfig ¶
func (g *NodeGenerator) GetTabletNodeConfig(spec ytv1.TabletNodesSpec) ([]byte, error)
func (*NodeGenerator) GetTabletNodesServiceName ¶
func (g *NodeGenerator) GetTabletNodesServiceName(name string) string
func (*NodeGenerator) GetTabletNodesStatefulSetName ¶
func (g *NodeGenerator) GetTabletNodesStatefulSetName(name string) string
type NodeServer ¶
type NodeServer struct { CommonServer Flavors []NodeFlavor `yson:"flavors"` ResourceLimits ResourceLimits `yson:"resource_limits,omitempty"` Tags []string `yson:"tags,omitempty"` Rack string `yson:"rack,omitempty"` SkynetHttpPort int32 `yson:"skynet_http_port"` }
type OauthCookieAuthenticator ¶
type OauthCookieAuthenticator struct{}
type OauthService ¶
type OauthTokenAuthenticator ¶
type OauthTokenAuthenticator struct{}
type OperationsCleaner ¶
type OperationsCleaner struct {
EnableOperationArchivation *bool `yson:"enable_operation_archivation,omitempty"`
}
type QueryTrackerServer ¶
type QueryTrackerServer struct { CommonServer User string `yson:"user"` CreateStateTablesOnStartup bool `yson:"create_state_tables_on_startup"` }
type QueueAgent ¶
type QueueAgent struct {
Stage string `yson:"stage"`
}
type QueueAgentServer ¶
type QueueAgentServer struct { CommonServer User string `yson:"user"` QueueAgent QueueAgent `yson:"queue_agent"` }
type RPCProxyServer ¶
type RPCProxyServer struct { CommonServer Role string `yson:"role"` CypressUserManager CypressUserManager `yson:"cypress_user_manager"` CypressTokenAuthenticator CypressTokenAuthenticator `yson:"cypress_token_authenticator"` OauthService *OauthService `yson:"oauth_service,omitempty"` OauthTokenAuthenticator *OauthTokenAuthenticator `yson:"oauth_token_authenticator,omitempty"` RequireAuthentication *bool `yson:"require_authentication,omitempty"` }
type ResourceLimits ¶
type RetryingChannel ¶
type Scheduler ¶
type Scheduler struct {
OperationsCleaner OperationsCleaner `yson:"operations_cleaner"`
}
type SchedulerServer ¶
type SchedulerServer struct { CommonServer Scheduler Scheduler `yson:"scheduler"` }
type SlotLocation ¶
type SlotManager ¶
type SlotManager struct { Locations []SlotLocation `yson:"locations"` JobEnvironment JobEnvironment `yson:"job_environment"` DoNotSetUserId *bool `yson:"do_not_set_user_id,omitempty"` EnableTmpfs *bool `yson:"enable_tmpfs,omitempty"` DetachedTmpfsUmount *bool `yson:"detached_tmpfs_umount,omitempty"` }
type StoreLocation ¶
type StoreLocation struct { Path string `yson:"path"` IOEngine *IOEngine `yson:"io_config,omitempty"` MediumName string `yson:"medium_name"` Quota int64 `yson:"quota,omitempty"` HighWatermark int64 `yson:"high_watermark,omitempty"` LowWatermark int64 `yson:"low_watermark,omitempty"` DisableWritesWatermark int64 `yson:"disable_writes_watermark,omitempty"` }
type Strawberry ¶
type StrawberryController ¶
type StrawberryController struct { LocationProxies []string `yson:"location_proxies"` Strawberry Strawberry `yson:"strawberry"` Controllers map[string]yson.RawValue `yson:"controllers"` HTTPAPIEndpoint string `yson:"http_api_endpoint"` HTTPLocationAliases map[string][]string `yson:"http_location_aliases"` }
type TCPProxyServer ¶
type TCPProxyServer struct { CommonServer Role string `yson:"role"` }
type TabletNode ¶
type TabletNode struct {
VersionedChunkMetaCache Cache `yson:"versioned_chunk_meta_cache"`
}
type TabletNodeServer ¶
type TabletNodeServer struct { NodeServer // TabletNode TabletNode `yson:"tablet_node"` CachingObjectService Cache `yson:"caching_object_service"` }
type TimestampProviders ¶
type TimestampProviders struct {
AddressList
}
type UIAuthenticationType ¶
type UIAuthenticationType string
type UICluster ¶
type UICluster struct { ID string `yson:"id"` Name string `yson:"name"` Proxy string `yson:"proxy"` Secure bool `yson:"secure"` Authentication UIAuthenticationType `yson:"authentication"` Group string `yson:"group"` Theme string `yson:"theme"` Environment string `yson:"environment"` Description string `yson:"description"` PrimaryMaster UIPrimaryMaster `yson:"primaryMaster"` }
type UIClusters ¶
type UIClusters struct {
Clusters []UICluster `yson:"clusters"`
}
type UIPrimaryMaster ¶
type UIPrimaryMaster struct {
CellTag int16 `yson:"cellTag"`
}
type VerificationMode ¶
type VerificationMode string
const ( VerificationModeNone VerificationMode = "none" VerificationModeCa VerificationMode = "ca" VerificationModeFull VerificationMode = "full" )
type YQLAgent ¶
type YQLAgent struct { GatewayConfig GatewayConfig `yson:"gateway_config"` YTTokenPath string `yson:"yt_token_path"` // For backward compatibility. MRJobBinary string `yson:"mr_job_binary"` UDFDirectory string `yson:"udf_directory"` AdditionalClusters map[string]string `yson:"additional_clusters"` DefaultCluster string `yson:"default_cluster"` }
type YQLAgentServer ¶
type YQLAgentServer struct { CommonServer User string `yson:"user"` YQLAgent YQLAgent `yson:"yql_agent"` }
type YsonGeneratorFunc ¶
Click to show internal directories.
Click to hide internal directories.