Documentation ¶
Index ¶
- Constants
- Variables
- func AddHelmRepo(repo string) error
- func Ask(label string) bool
- func ChartName2TarName(chart string, flag int) string
- func CheckClusterIfReady(name string, namespace string) bool
- func CheckDeployIfReady(name string, namespace string) bool
- func CheckDirectPVCmdExist() bool
- func CheckEndpointsReady(name string, namespace string, needReplicas int) (error, bool, *corev1.Endpoints)
- func CheckHelmCmdExist() bool
- func CheckHelmReleaseExist(name string, namespace string) bool
- func CheckMainStorageValid(ms string) bool
- func CheckNineClusterExist(name string, namespace string) (bool, *nineinfrav1alpha1.NineClusterList)
- func CheckPGClusterIfReady(name string, namespace string) bool
- func CheckStoragePoolValid(sp string) bool
- func CheckStsIfReady(name string, namespace string) bool
- func CheckValidClusterName(clustername string) error
- func CreateIfNotExist(resource string, resourceType string, flags string) error
- func DisableHelp(cmd *cobra.Command) *cobra.Command
- func GenDorisSvcName(name string) string
- func GenLocalFile(filename string, data []byte) error
- func GenPostgresSvcName(name string) string
- func GenThriftServiceAccountName(name string) string
- func GenThriftSvcName(name string) string
- func GetAirflowPodNames(name string, component string, ns string) ([]string, error)
- func GetCustomAppRunningPid(podName string, ns string, prefix string) string
- func GetDirectPVClient(path string) (*directpvv1beta1.DirectpvV1beta1Client, error)
- func GetDorisIpAndPort(name string, ns string) (string, int32)
- func GetIpFromKubeHost(host string) (string, error)
- func GetKubeClient(path string) (*kubernetes.Clientset, error)
- func GetKubeClientWithConfig(path string) (*kubernetes.Clientset, *restclient.Config, error)
- func GetKubeConfig() (*restclient.Config, error)
- func GetKubeDynamicClient(path string) (*dynamic.DynamicClient, error)
- func GetKubeHost(path string) (string, error)
- func GetNineCLusters(namespace string) (*nineinfrav1alpha1.NineClusterList, error)
- func GetNineClusterFeatures(name string, namespace string) (map[string]string, error)
- func GetNineClusterStorageType(name string, namespace string) (string, error)
- func GetNineInfraClient(path string) (*nineinfrav1alpha1.Clientset, error)
- func GetPGOperatorClient(path string) (*pgoperatorv1.Clientset, error)
- func GetPodNames(labelSelector string, ns string) ([]string, error)
- func GetPostgresIpAndPort(name string, ns string) (string, int32)
- func GetReadyDirectPVVolumes(dpclient *directpvv1beta1.DirectpvV1beta1Client, ns string, ...) (*directpvv1beta1.DirectPVVolumeList, error)
- func GetReleasedAndDeletePolicyPVList(clientset *kubernetes.Clientset, claimPrefix string) (*corev1.PersistentVolumeList, error)
- func GetReleasedAndDeletePolicyPVListByStorageClass(clientset *kubernetes.Clientset, sc string) (*corev1.PersistentVolumeList, error)
- func GetSvcAccessInfo(svcName string, portName string, ns string) (string, int32)
- func GetThriftIpAndPort(name string, ns string) (string, int32)
- func GetThriftPodName(name string, ns string) ([]string, error)
- func GiveSuggestionsByError(err error) string
- func HelmInstall(name string, repoName string, chartPath string, chart string, version string, ...) error
- func HelmInstallWithParameters(name string, repoName string, chartPath string, chart string, version string, ...) error
- func HelmUnInstall(name string, namespace string, flags string) error
- func HumanDuration(t time.Time) string
- func IfPGReady(pg *cnpgv1.Cluster) bool
- func InitDirectPV() error
- func InitHelm() error
- func InstallDirectPVCmd() error
- func InstallHelmCmd() error
- func KillCustomAppRunningPid(podName string, ns string, pid string) error
- func New(_ genericiooptions.IOStreams) *cobra.Command
- func NineResourceLabels(cluster *nineinfrav1alpha1.NineCluster) map[string]string
- func NineResourceName(name string, suffixs ...string) string
- func NineWorkLoadName(name string, project string) string
- func PrintClusterList(clusters *nineinfrav1alpha1.NineClusterList)
- func PrintClusterProjectList(cluster *nineinfrav1alpha1.NineCluster)
- func PrintClusterProjectWorkloadList(name string, namespace string, list map[string]string)
- func PrintClusterToolList(name string, namespace string)
- func PrintNineCluster(cluster *nineinfrav1alpha1.NineCluster)
- func PrintPGClusterReadyAndAge(name string, namespace string) (string, string)
- func PrintStsReadyAndAge(name string, namespace string) (string, string)
- func PrintToolAccessInfo(ninename string, name string, ns string) string
- func PrintToolList(clusters *nineinfrav1alpha1.NineClusterList)
- func RemoveHelmRepo(repo string) error
- func RunExecCommand(pdName string, namespace string, tty bool, cmd []string) (string, error)
- func ValidateClusterArgs(cmd string, args []string) error
- type ClusterOptions
- type DatabasesConnection
- type DeleteOptions
- type DriveStatus
- type NineInfraStoragePool
- type SqlOptions
- type TPCDSOptions
- type XmlConfiguration
- type XmlProperty
Constants ¶
View Source
const ( PrintFmtStrClusterList = "%-20s\t%-10s\t%-10s\t%-10s\t%-10s\n" PrintFmtStrToolList = "%-20s\t%-10s\t%-10s\t%-10s\t%-10s\n" PrintFmtStrClusterProjectList = "%-40s\t%-10s\t%-10s\t%-10s\t%-10s\n" )
View Source
const ( DefaultNamespace = "nineinfra" DefaultMinioPVCLabelKey = "v1.min.io/tenant" DefaultClusterLabelKey = "cluster" DefaultReleaseLabelKey = "release" DefaultAppLabelKey = "app" DefaultNineSuffix = "-nine" DefaultThriftPortName = "thrift-binary" DefaultCMDHelm = "helm" DefaultCMDDirectPV = "kubectl-directpv" DefaultNineInfraPrefix = "nineinfra" GiMultiplier = 1024 * 1024 * 1024 DefaultSqlAccessUserName = "kyuubi" DefaultSqlAccessPassword = "kyuubi" DefaultClusterSign = "nine" )
View Source
const ( DefaultPGRWSVCNameSuffix = DefaultNineSuffix + "-pg-rw" DefaultPGRWPortName = "postgres" DefaultNineInfraDBUser = "nineinfra" DefaultNineInfraDBPwd = "nineinfra" DefaultNineInfraDBName = "nineinfra" DefaultToolAirflowDBUser = "airflow" DefaultToolAirflowDBPwd = "airflow" DefaultToolAirflowDBName = "airflow" DefaultToolSupersetDBUser = "superset" DefaultToolSupersetDBPwd = "superset" DefaultToolSupersetDBName = "superset" DefaultToolAirflowName = "airflow" DefaultToolSupersetName = "superset" DefaultToolNifiName = "nifi" DefaultToolZookeeperName = "zookeeper" DefaultToolRedisName = "redis" DefaultToolAirflowWebServerSecretKey = "2ae7138d1fc0859df4a2456dd0146785" DefaultToolAirflowDiskSize = "20Gi" DefaultAirflowTierPVCLabelKey = "tier" DefaultToolNifiUserName = "admin" DefaultToolNifiUserPWD = "nineinfraadmin" DefaultZookeeperHLSVCNameSuffix = "zookeeper-headless" DefaultZookeeperClientSvcPort = 2181 DefaultZookeeperClientSvcName = "client" DefaultZookeeperPVCLabelKey = "app.kubernetes.io/instance" DefaultAirflowDagsPath = "/opt/airflow/dags" DefaultHdfsSiteFileName = "hdfs-site.xml" )
View Source
const ( DefaultTPCDSPrefix = DefaultNineInfraPrefix + "-tpcds-spark" DefaultTPCDSAPP = DefaultNineInfraPrefix + "-tpcds-spark" ValidSparkDeployModeList = "client,cluster" SparkDeployModeCluster = "cluster" SparkDriverNameSuffix = "-driver" DefaultSparkUINodePort = 31334 DefaultSparkUIPort = 4040 DefaultSparkUIName = "spark-ui" )
View Source
const ( FeaturesOlapKey = "olap" FeaturesKyuubiHAKey = "kyuubi-ha" FeaturesStorageKey = "storage" FeaturesStorageValueHdfs = "hdfs" FeaturesStorageValueMinio = "minio" FeaturesOlapValueDoris = "doris" FeaturesPostgresqlCDCKey = "postgresql-cdc" )
View Source
const ( DefaultDorisPortName = "query-port" DefaultOlapPVCLabelKey = "app.doris.ownerreference/name" DefaultDorisBENameSuffix = "-doris-be" DefaultDorisFENameSuffix = "-doris-fe" )
View Source
const ( DefaultCMDDirectPVURL = "https://github.com/minio/directpv/releases/download/v4.0.9/kubectl-directpv_4.0.9_linux_amd64" DefaultCMDDirectPVInstallPath = "/usr/local/bin/" )
View Source
const ( DefaultHelmRepoName = "nineinfra" DefaultHelmRepo = "https://nineinfra.github.io/nineinfra-charts/" DefaultHelmCmdURL = "https://raw.githubusercontent.com/helm/helm/main/scripts/get-helm-3" )
View Source
const ( DiskSubCommandDiscover = "discover" DiskSubCommandInit = "init" DiskSubCommandLabel = "label" )
View Source
const (
DefaultHdfsAccessUserName = DefaultSqlAccessUserName
)
Variables ¶
View Source
var ( DefaultToolSupersetSecretFile = "secret" DefaultToolSupersetSDataSourcesFile = "import_datasources.yaml" )
View Source
var ( DEBUG = false DefaultToolNifiSvcNodePort = 31333 DefaultToolSupersetSvcType = "NodePort" DefaultToolNifiSvcType = "NodePort" DefaultToolAirflowSvcType = "NodePort" DefaultToolAirflowRepository = "nineinfra/airflow" DefaultToolAirflowTag = "2.7.3" DefaultStorageClass = "nineinfra-default" DefaultToolNifiSideCarTag = "1.36.1" DefaultAccessHost = "" DefaultDorisAdminUser = "root" DefaultDorisAdminPassword = "" DefaultDorisDatabaseName = "nineinfra" DefaultDorisFERepo = "selectdb/doris.fe-ubuntu" DefaultDorisFEVersion = "2.0.2" DefaultDorisFERepoPullPolicy = "IfNotPresent" DefaultDorisFEStoragePVSize = 20 DefaultDorisBERepo = "selectdb/doris.be-ubuntu" DefaultDorisBEVersion = "2.0.2" DefaultDorisBERepoPullPolicy = "IfNotPresent" DefaultDorisBEStoragePVSize = 100 DefaultKyuubiUserName = "hive" DefaultKyuubiVersion = "1.8.0" DefaultScalaVersion = "2.12" DefaultMinioRepo = "minio/minio" DefaultMinioVersion = "RELEASE.2023-09-07T02-05-02Z" DefaultMinioRepoPullPolicy = "IfNotPresent" DefaultDataBaseVersion = "v16.0.0" )
View Source
var ( OlapsSupported = "doris" MainStorageSupported = []string{FeaturesStorageValueHdfs, FeaturesStorageValueMinio} )
View Source
var ( DorisFeClusterInfo = nineinfrav1alpha1.ClusterInfo{ Type: nineinfrav1alpha1.DorisFEClusterType, Version: DefaultDorisFEVersion, Configs: nineinfrav1alpha1.ClusterConfig{ Image: nineinfrav1alpha1.ImageConfig{ Repository: DefaultDorisFERepo, Tag: DefaultDorisFEVersion, PullPolicy: DefaultDorisFERepoPullPolicy, }, }, Resource: nineinfrav1alpha1.ResourceConfig{ ResourceRequirements: corev1.ResourceRequirements{ Requests: corev1.ResourceList{ "storage": *resource.NewQuantity(int64(DefaultDorisFEStoragePVSize*GiMultiplier), resource.BinarySI), }, }, }, } DorisBeClusterInfo = nineinfrav1alpha1.ClusterInfo{ Type: nineinfrav1alpha1.DorisBEClusterType, Version: DefaultDorisBEVersion, Configs: nineinfrav1alpha1.ClusterConfig{ Image: nineinfrav1alpha1.ImageConfig{ Repository: DefaultDorisBERepo, Tag: DefaultDorisBEVersion, PullPolicy: DefaultDorisBERepoPullPolicy, }, }, Resource: nineinfrav1alpha1.ResourceConfig{ ResourceRequirements: corev1.ResourceRequirements{ Requests: corev1.ResourceList{ "storage": *resource.NewQuantity(int64(DefaultDorisBEStoragePVSize*GiMultiplier), resource.BinarySI), }, }, }, } MinioClusterInfo = nineinfrav1alpha1.ClusterInfo{ Type: nineinfrav1alpha1.MinioClusterType, Version: DefaultMinioVersion, Configs: nineinfrav1alpha1.ClusterConfig{ Image: nineinfrav1alpha1.ImageConfig{ Repository: DefaultMinioRepo, Tag: DefaultMinioVersion, PullPolicy: DefaultMinioRepoPullPolicy, }, }, } PGClusterInfo = nineinfrav1alpha1.ClusterInfo{ Type: nineinfrav1alpha1.DatabaseClusterType, SubType: nineinfrav1alpha1.DbTypePostgres, Version: DefaultDataBaseVersion, Resource: nineinfrav1alpha1.ResourceConfig{ StorageClass: DefaultStorageClass, }, } )
View Source
var DefaultChartList = map[string]string{
"cloudnative-pg": "0.19.1",
"kyuubi-operator": "0.7.0",
"metastore-operator": "0.7.0",
"zookeeper-operator": "0.7.0",
"hdfs-operator": "0.7.0",
"minio-directpv": "4.0.8",
"minio-operator": "5.0.9",
"doris-operator": "1.3.1",
"nineinfra": "0.7.0",
}
View Source
var DefaultToolsChartList = map[string]string{
"airflow": "1.12.0",
"superset": "0.11.2",
"nifi": "1.2.0",
"zookeeper": "12.3.3",
"redis": "0.7.5",
}
View Source
var (
DefaultZookeeperReplicas = 3
)
View Source
var Err2Suggestions = map[string]string{
"connection timed out": "If you run the nine out of the k8s? or if the status of the NineCluster is not ready?",
"the TPC-DS is already exist": "You can stop it by execute the nine TPC-DS stop command",
"No matching resources found": "You can create this resource first",
}
View Source
var NineClusterOlapDorisWorkloadList = map[string]string{
"doris-fe": "statefulset",
"doris-be": "statefulset",
}
View Source
var NineClusterOlapList = map[string]interface{}{ FeaturesOlapValueDoris: NineClusterOlapDorisWorkloadList, }
View Source
var NineClusterProjectNameSuffix = map[string]string{
"kyuubi": "-nine-kyuubi",
"metastore": "-nine-metastore",
"minio": "-nine-ss-0",
"postgresql": "-nine-pg",
"doris-fe": "-nine-doris-fe",
"doris-be": "-nine-doris-be",
"namenode": "-nine-hdfs-namenode",
"datanode": "-nine-hdfs-datanode",
"journalnode": "-nine-hdfs-journalnode",
"zookeeper": "-nine-zookeeper",
}
View Source
var NineClusterProjectWorkloadList = map[string]string{
"kyuubi": "statefulset",
"metastore": "statefulset",
"postgresql": "cluster",
}
View Source
var NineClusterStorageHdfsWorkloadList = map[string]string{
"journalnode": "statefulset",
"datanode": "statefulset",
"namenode": "statefulset",
"zookeeper": "statefulset",
}
View Source
var NineClusterStorageList = map[string]interface{}{ FeaturesStorageValueMinio: NineClusterStorageMinioWorkloadList, FeaturesStorageValueHdfs: NineClusterStorageHdfsWorkloadList, }
View Source
var NineClusterStorageMinioWorkloadList = map[string]string{
"minio": "statefulset",
}
View Source
var NineInfraCrdList = []string{
"hdfsclusters.hdfs.nineinfra.tech",
"kyuubiclusters.kyuubi.nineinfra.tech",
"metastoreclusters.metastore.nineinfra.tech",
"nineclusters.nine.nineinfra.tech",
"zookeeperclusters.zookeeper.nineinfra.tech",
"backups.postgresql.cnpg.io",
"clusters.postgresql.cnpg.io",
"poolers.postgresql.cnpg.io",
"scheduledbackups.postgresql.cnpg.io",
"dorisclusters.doris.selectdb.com",
"directpvdrives.directpv.min.io",
"directpvvolumes.directpv.min.io",
"directpvinitrequests.directpv.min.io",
"directpvnodes.directpv.min.io",
"tenants.minio.min.io",
}
View Source
var NineInfraDeploymentAlias = map[string]string{
"cloudnative-pg": "postgresql-operator",
"kyuubi-operator-deployment": "kyuubi-operator",
"metastore-operator-deployment": "metastore-operator",
"console": "minio-console",
"minio-operator": "minio-operator",
"controller": "directpv-controller",
"nineinfra-deployment": "nineinfra",
"doris-operator": "doris-operator",
"hdfs-operator-deployment": "hdfs-operator",
"zookeeper-operator-deployment": "zookeeper-operator",
}
View Source
var NineToolAirflowWorkloadList = map[string]string{
"airflow-webserver": "deployment",
"airflow-scheduler": "deployment",
"airflow-triggerer": "statefulset",
"airflow-worker": "statefulset",
}
View Source
var NineToolList = map[string]interface{}{ DefaultToolAirflowName: NineToolAirflowWorkloadList, DefaultToolSupersetName: NineToolSupersetloadList, DefaultToolNifiName: NineToolNifiWorkloadList, DefaultToolRedisName: NineToolRedisWorkloadList, DefaultToolZookeeperName: NineToolZookeeperWorkloadList, }
View Source
var NineToolNifiWorkloadList = map[string]string{
"nifi": "statefulset",
}
View Source
var NineToolPortNameList = map[string]string{ DefaultToolAirflowName: "airflow-ui", DefaultToolSupersetName: "http", DefaultToolNifiName: "https", DefaultToolRedisName: "redis", DefaultToolZookeeperName: "tcp-client", }
View Source
var NineToolPortProtocolList = map[string]string{ DefaultToolAirflowName: "http", DefaultToolSupersetName: "http", DefaultToolNifiName: "https", DefaultToolRedisName: "redis", DefaultToolZookeeperName: "", }
View Source
var NineToolRedisWorkloadList = map[string]string{
"redis": "deployment",
}
View Source
var NineToolSupersetloadList = map[string]string{
"superset": "deployment",
"superset-worker": "deployment",
"airflow-triggerer": "statefulset",
"airflow-worker": "statefulset",
}
View Source
var NineToolSvcList = map[string]string{ DefaultToolAirflowName: "airflow-webserver", DefaultToolSupersetName: "superset", DefaultToolNifiName: "nifi", DefaultToolRedisName: "redis", DefaultToolZookeeperName: "zookeeper", }
View Source
var NineToolZookeeperWorkloadList = map[string]string{
"zookeeper": "statefulset",
}
Functions ¶
func AddHelmRepo ¶
func ChartName2TarName ¶ added in v0.5.1
func CheckClusterIfReady ¶
func CheckDeployIfReady ¶ added in v0.4.5
func CheckDirectPVCmdExist ¶
func CheckDirectPVCmdExist() bool
func CheckEndpointsReady ¶ added in v0.7.0
func CheckHelmCmdExist ¶
func CheckHelmCmdExist() bool
func CheckHelmReleaseExist ¶ added in v0.4.5
func CheckMainStorageValid ¶ added in v0.7.0
func CheckNineClusterExist ¶
func CheckNineClusterExist(name string, namespace string) (bool, *nineinfrav1alpha1.NineClusterList)
func CheckPGClusterIfReady ¶
func CheckStoragePoolValid ¶ added in v0.5.3
func CheckStsIfReady ¶
func CheckValidClusterName ¶
CheckValidClusterName validates if input clustername complies with expected restrictions.
func CreateIfNotExist ¶
func DisableHelp ¶
DisableHelp disables the help command
func GenDorisSvcName ¶ added in v0.5.1
func GenLocalFile ¶ added in v0.8.0
func GenPostgresSvcName ¶ added in v0.5.0
func GenThriftServiceAccountName ¶ added in v0.4.8
func GenThriftSvcName ¶ added in v0.4.6
func GetAirflowPodNames ¶ added in v0.8.0
func GetCustomAppRunningPid ¶ added in v0.4.8
func GetDirectPVClient ¶ added in v0.5.0
func GetDirectPVClient(path string) (*directpvv1beta1.DirectpvV1beta1Client, error)
func GetDorisIpAndPort ¶ added in v0.5.1
func GetIpFromKubeHost ¶ added in v0.4.5
func GetKubeClient ¶
func GetKubeClient(path string) (*kubernetes.Clientset, error)
func GetKubeClientWithConfig ¶ added in v0.4.5
func GetKubeClientWithConfig(path string) (*kubernetes.Clientset, *restclient.Config, error)
func GetKubeConfig ¶ added in v0.4.7
func GetKubeConfig() (*restclient.Config, error)
func GetKubeDynamicClient ¶ added in v0.7.0
func GetKubeDynamicClient(path string) (*dynamic.DynamicClient, error)
func GetKubeHost ¶ added in v0.4.5
func GetNineCLusters ¶ added in v0.8.0
func GetNineCLusters(namespace string) (*nineinfrav1alpha1.NineClusterList, error)
func GetNineClusterFeatures ¶ added in v0.8.0
func GetNineClusterStorageType ¶ added in v0.8.0
func GetNineInfraClient ¶
func GetNineInfraClient(path string) (*nineinfrav1alpha1.Clientset, error)
func GetPGOperatorClient ¶
func GetPGOperatorClient(path string) (*pgoperatorv1.Clientset, error)
func GetPodNames ¶ added in v0.8.0
func GetPostgresIpAndPort ¶ added in v0.5.0
func GetReadyDirectPVVolumes ¶ added in v0.5.0
func GetReadyDirectPVVolumes(dpclient *directpvv1beta1.DirectpvV1beta1Client, ns string, podNamePrefix string) (*directpvv1beta1.DirectPVVolumeList, error)
func GetReleasedAndDeletePolicyPVList ¶ added in v0.4.8
func GetReleasedAndDeletePolicyPVList(clientset *kubernetes.Clientset, claimPrefix string) (*corev1.PersistentVolumeList, error)
func GetReleasedAndDeletePolicyPVListByStorageClass ¶ added in v0.7.0
func GetReleasedAndDeletePolicyPVListByStorageClass(clientset *kubernetes.Clientset, sc string) (*corev1.PersistentVolumeList, error)
func GetSvcAccessInfo ¶ added in v0.4.5
func GetThriftIpAndPort ¶ added in v0.4.5
func GetThriftPodName ¶ added in v0.4.6
func GiveSuggestionsByError ¶ added in v0.4.5
func HelmInstall ¶
func HelmInstallWithParameters ¶ added in v0.4.5
func HumanDuration ¶
func InitDirectPV ¶
func InitDirectPV() error
func InstallDirectPVCmd ¶
func InstallDirectPVCmd() error
func InstallHelmCmd ¶
func InstallHelmCmd() error
func KillCustomAppRunningPid ¶ added in v0.4.8
func New ¶
func New(_ genericiooptions.IOStreams) *cobra.Command
New creates a new root command for kubectl-nine
func NineResourceLabels ¶ added in v0.8.0
func NineResourceLabels(cluster *nineinfrav1alpha1.NineCluster) map[string]string
func NineResourceName ¶ added in v0.8.0
func NineWorkLoadName ¶
func PrintClusterList ¶
func PrintClusterList(clusters *nineinfrav1alpha1.NineClusterList)
func PrintClusterProjectList ¶
func PrintClusterProjectList(cluster *nineinfrav1alpha1.NineCluster)
func PrintClusterProjectWorkloadList ¶ added in v0.5.4
func PrintClusterToolList ¶ added in v0.4.5
func PrintNineCluster ¶
func PrintNineCluster(cluster *nineinfrav1alpha1.NineCluster)
func PrintToolAccessInfo ¶ added in v0.4.5
func PrintToolList ¶ added in v0.4.5
func PrintToolList(clusters *nineinfrav1alpha1.NineClusterList)
func RemoveHelmRepo ¶
func RunExecCommand ¶ added in v0.8.0
func ValidateClusterArgs ¶
Types ¶
type ClusterOptions ¶
type ClusterOptions struct { Name string NS string DataVolume int StoragePool string OlapVolume int OlapStoragePool string OlapExecutors int32 EnableKyuubiHA bool MainStorage string MetastoreStoragePool string Olap string }
ClusterOptions encapsulates the CLI options for a NineCluster
func (ClusterOptions) Validate ¶
func (t ClusterOptions) Validate() error
Validate NineCluster Options
type DatabasesConnection ¶ added in v0.4.5
type DatabasesConnection struct { AllowFileUpload bool `yaml:"allow_file_upload"` AllowCTAS bool `yaml:"allow_ctas"` AllowCVAS bool `yaml:"allow_cvas"` DatabaseName string `yaml:"database_name"` Extra string `yaml:"extra"` SqlAlchemyURI string `yaml:"sqlalchemy_uri"` Tables []string `yaml:"tables"` }
type DeleteOptions ¶
type DriveStatus ¶
type DriveStatus string
DriveStatus denotes drive status
const ( // DriveStatusReady denotes drive is ready for volume schedule. DriveStatusReady DriveStatus = "Ready" // DriveStatusLost denotes associated data by FSUUID is lost. DriveStatusLost DriveStatus = "Lost" // DriveStatusError denotes drive is in error state to prevent volume schedule. DriveStatusError DriveStatus = "Error" // DriveStatusRemoved denotes drive is removed. DriveStatusRemoved DriveStatus = "Removed" // DriveStatusMoving denotes drive is moving volumes. DriveStatusMoving DriveStatus = "Moving" )
type NineInfraStoragePool ¶ added in v0.5.0
type NineInfraStoragePool string
const ( NineInfraStoragePoolDefault NineInfraStoragePool = "nineinfra-default" NineInfraStoragePoolHigh NineInfraStoragePool = "nineinfra-high" NineInfraStoragePoolMedium NineInfraStoragePool = "nineinfra-medium" NineInfraStoragePoolLow NineInfraStoragePool = "nineinfra-low" )
Enum of NineInfraStoragePool type.
type SqlOptions ¶
type TPCDSOptions ¶ added in v0.4.7
type TPCDSOptions struct { Name string NS string GenData bool DataBase string TPCDSJar string ScaleFactor int Parallel int Iterations int Executors int ExecutorMemory int ExecutorCores int DriverMemory int DriverCores int Queries []string ResultsDir string StorageClass string ShuffleDiskSize int ShuffleDisks int TTY bool Stop bool Force bool DeployMode string SparkUI int HdfsNameSpace string }
type XmlConfiguration ¶ added in v0.8.0
type XmlConfiguration struct { XmlName xml.Name `xml:"configuration"` Properties []XmlProperty `xml:"property"` }
type XmlProperty ¶ added in v0.8.0
Click to show internal directories.
Click to hide internal directories.