cmd

package
v0.8.0 Latest Latest
Warning

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

Go to latest
Published: Mar 9, 2024 License: Apache-2.0 Imports: 54 Imported by: 0

Documentation

Index

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 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 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 AddHelmRepo(repo string) error

func Ask

func Ask(label string) bool

Ask user for Y/N input. Return true if response is "y"

func ChartName2TarName added in v0.5.1

func ChartName2TarName(chart string, flag int) string

func CheckClusterIfReady

func CheckClusterIfReady(name string, namespace string) bool

func CheckDeployIfReady added in v0.4.5

func CheckDeployIfReady(name string, namespace string) bool

func CheckDirectPVCmdExist

func CheckDirectPVCmdExist() bool

func CheckEndpointsReady added in v0.7.0

func CheckEndpointsReady(name string, namespace string, needReplicas int) (error, bool, *corev1.Endpoints)

func CheckHelmCmdExist

func CheckHelmCmdExist() bool

func CheckHelmReleaseExist added in v0.4.5

func CheckHelmReleaseExist(name string, namespace string) bool

func CheckMainStorageValid added in v0.7.0

func CheckMainStorageValid(ms string) bool

func CheckNineClusterExist

func CheckNineClusterExist(name string, namespace string) (bool, *nineinfrav1alpha1.NineClusterList)

func CheckPGClusterIfReady

func CheckPGClusterIfReady(name string, namespace string) bool

func CheckStoragePoolValid added in v0.5.3

func CheckStoragePoolValid(sp string) bool

func CheckStsIfReady

func CheckStsIfReady(name string, namespace string) bool

func CheckValidClusterName

func CheckValidClusterName(clustername string) error

CheckValidClusterName validates if input clustername complies with expected restrictions.

func CreateIfNotExist

func CreateIfNotExist(resource string, resourceType string, flags string) error

func DisableHelp

func DisableHelp(cmd *cobra.Command) *cobra.Command

DisableHelp disables the help command

func GenDorisSvcName added in v0.5.1

func GenDorisSvcName(name string) string

func GenLocalFile added in v0.8.0

func GenLocalFile(filename string, data []byte) error

func GenPostgresSvcName added in v0.5.0

func GenPostgresSvcName(name string) string

func GenThriftServiceAccountName added in v0.4.8

func GenThriftServiceAccountName(name string) string

func GenThriftSvcName added in v0.4.6

func GenThriftSvcName(name string) string

func GetAirflowPodNames added in v0.8.0

func GetAirflowPodNames(name string, component string, ns string) ([]string, error)

func GetCustomAppRunningPid added in v0.4.8

func GetCustomAppRunningPid(podName string, ns string, prefix string) string

func GetDirectPVClient added in v0.5.0

func GetDirectPVClient(path string) (*directpvv1beta1.DirectpvV1beta1Client, error)

func GetDorisIpAndPort added in v0.5.1

func GetDorisIpAndPort(name string, ns string) (string, int32)

func GetIpFromKubeHost added in v0.4.5

func GetIpFromKubeHost(host string) (string, error)

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 GetKubeHost(path string) (string, error)

func GetNineCLusters added in v0.8.0

func GetNineCLusters(namespace string) (*nineinfrav1alpha1.NineClusterList, error)

func GetNineClusterFeatures added in v0.8.0

func GetNineClusterFeatures(name string, namespace string) (map[string]string, error)

func GetNineClusterStorageType added in v0.8.0

func GetNineClusterStorageType(name string, namespace string) (string, error)

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 GetPodNames(labelSelector string, ns string) ([]string, error)

func GetPostgresIpAndPort added in v0.5.0

func GetPostgresIpAndPort(name string, ns string) (string, int32)

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 GetSvcAccessInfo(svcName string, portName string, ns string) (string, int32)

func GetThriftIpAndPort added in v0.4.5

func GetThriftIpAndPort(name string, ns string) (string, int32)

func GetThriftPodName added in v0.4.6

func GetThriftPodName(name string, ns string) ([]string, error)

func GiveSuggestionsByError added in v0.4.5

func GiveSuggestionsByError(err error) string

func HelmInstall

func HelmInstall(name string, repoName string, chartPath string, chart string, version string, namespace string, flags string) error

func HelmInstallWithParameters added in v0.4.5

func HelmInstallWithParameters(name string, repoName string, chartPath string, chart string, version string, namespace string, parameters ...string) error

func HelmUnInstall

func HelmUnInstall(name string, namespace string, flags string) error

func HumanDuration

func HumanDuration(t time.Time) string

func IfPGReady

func IfPGReady(pg *cnpgv1.Cluster) bool

func InitDirectPV

func InitDirectPV() error

func InitHelm

func InitHelm() error

func InstallDirectPVCmd

func InstallDirectPVCmd() error

func InstallHelmCmd

func InstallHelmCmd() error

func KillCustomAppRunningPid added in v0.4.8

func KillCustomAppRunningPid(podName string, ns string, pid string) error

func New

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 NineResourceName(name string, suffixs ...string) string

func NineWorkLoadName

func NineWorkLoadName(name string, project string) string

func PrintClusterList

func PrintClusterList(clusters *nineinfrav1alpha1.NineClusterList)

func PrintClusterProjectList

func PrintClusterProjectList(cluster *nineinfrav1alpha1.NineCluster)

func PrintClusterProjectWorkloadList added in v0.5.4

func PrintClusterProjectWorkloadList(name string, namespace string, list map[string]string)

func PrintClusterToolList added in v0.4.5

func PrintClusterToolList(name string, namespace string)

func PrintNineCluster

func PrintNineCluster(cluster *nineinfrav1alpha1.NineCluster)

func PrintPGClusterReadyAndAge

func PrintPGClusterReadyAndAge(name string, namespace string) (string, string)

func PrintStsReadyAndAge

func PrintStsReadyAndAge(name string, namespace string) (string, string)

func PrintToolAccessInfo added in v0.4.5

func PrintToolAccessInfo(ninename string, name string, ns string) string

func PrintToolList added in v0.4.5

func PrintToolList(clusters *nineinfrav1alpha1.NineClusterList)

func RemoveHelmRepo

func RemoveHelmRepo(repo string) error

func RunExecCommand added in v0.8.0

func RunExecCommand(pdName string, namespace string, tty bool, cmd []string) (string, error)

func ValidateClusterArgs

func ValidateClusterArgs(cmd string, args []string) error

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 DeleteOptions struct {
	Name string
	NS   string
	// contains filtered or unexported fields
}

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 SqlOptions struct {
	Name      string
	NS        string
	TTY       bool
	Silent    bool
	Statement string
	UserName  string
	Password  string
}

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

type XmlProperty struct {
	Name  string `xml:"name"`
	Value string `xml:"value"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL