cmd

package

Go to main page

Versions in this module

v0

v0.8.0

Mar 9, 2024

Changes in this version

+ const DefaultAirflowDagsPath

+ const DefaultAirflowTierPVCLabelKey

+ const DefaultClusterSign

+ const DefaultHdfsAccessUserName

+ const DefaultHdfsSiteFileName

+ const DefaultNineInfraDBName

+ const DefaultNineInfraDBPwd

+ const DefaultNineInfraDBUser

+ const DefaultReleaseLabelKey

+ const DefaultZookeeperClientSvcName

+ const DefaultZookeeperClientSvcPort

+ const FeaturesPostgresqlCDCKey

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

+ func GetAirflowPodNames(name string, component string, ns 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 GetPodNames(labelSelector string, ns string) ([]string, error)

+ func NineResourceLabels(cluster *nineinfrav1alpha1.NineCluster) map[string]string

+ func NineResourceName(name string, suffixs ...string) string

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

type TPCDSOptions

+ HdfsNameSpace string

+ type XmlConfiguration struct

+ Properties []XmlProperty

+ XmlName xml.Name

+ type XmlProperty struct

+ Name string

+ Value string

v0.7.0

Feb 16, 2024

Changes in this version

+ const DefaultZookeeperHLSVCNameSuffix

+ const FeaturesStorageKey

+ const FeaturesStorageValueHdfs

+ const FeaturesStorageValueMinio

+ var DefaultZookeeperReplicas = 3

+ var MainStorageSupported = []string

+ var NineClusterStorageHdfsWorkloadList = map[string]string

+ var NineClusterStorageList = map[string]interface

+ var NineClusterStorageMinioWorkloadList = map[string]string

+ var NineInfraCrdList = []string

+ var OlapsSupported = "doris"

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

+ func CheckMainStorageValid(ms string) bool

+ func GetKubeDynamicClient(path string) (*dynamic.DynamicClient, error)

+ func GetReleasedAndDeletePolicyPVListByStorageClass(clientset *kubernetes.Clientset, sc string) (*corev1.PersistentVolumeList, error)

type ClusterOptions

+ MainStorage string

v0.6.0

Jan 15, 2024

Changes in this version

+ const DefaultAppLabelKey

+ const DefaultClusterLabelKey

+ const DefaultMinioPVCLabelKey

+ const DefaultSqlAccessPassword

+ const DefaultSqlAccessUserName

+ const FeaturesKyuubiHAKey

type ClusterOptions

+ EnableKyuubiHA bool

type SqlOptions

+ Password string

+ UserName string

v0.5.4

Jan 10, 2024

Changes in this version

+ const FeaturesOlapValueDoris

+ var NineClusterOlapDorisWorkloadList = map[string]string

+ var NineClusterOlapList = map[string]interface

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

type ClusterOptions

+ OlapExecutors int32

v0.5.3

Jan 7, 2024

Changes in this version

+ const DefaultAirflowPVCLabelKey

+ const DefaultDorisBENameSuffix

+ const DefaultDorisFENameSuffix

+ const DefaultOlapPVCLabelKey

+ const DefaultZookeeperPVCLabelKey

+ var DefaultDataBaseVersion = "v16.0.0"

+ var DefaultDorisFERepo = "selectdb/doris.fe-ubuntu"

+ var DefaultDorisFERepoPullPolicy = "IfNotPresent"

+ var DefaultDorisFEStoragePVSize = 20

+ var DefaultDorisFEVersion = "2.0.2"

+ var DefaultMinioRepo = "minio/minio"

+ var DefaultMinioRepoPullPolicy = "IfNotPresent"

+ var DefaultMinioVersion = "RELEASE.2023-09-07T02-05-02Z"

+ var DorisFeClusterInfo = nineinfrav1alpha1.ClusterInfo

+ var MinioClusterInfo = nineinfrav1alpha1.ClusterInfo

+ var PGClusterInfo = nineinfrav1alpha1.ClusterInfo

+ func CheckStoragePoolValid(sp string) bool

type ClusterOptions

+ MetastoreStoragePool string

+ OlapStoragePool string

+ StoragePool string

v0.5.2

Jan 7, 2024

Changes in this version

+ const GiMultiplier

+ var DefaultDorisBERepo = "selectdb/doris.be-ubuntu"

+ var DefaultDorisBERepoPullPolicy = "IfNotPresent"

+ var DefaultDorisBEStoragePVSize = 100

+ var DefaultDorisBEVersion = "2.0.2"

+ var DorisBeClusterInfo = nineinfrav1alpha1.ClusterInfo

type ClusterOptions

+ OlapVolume int

v0.5.1

Jan 6, 2024

Changes in this version

+ const DefaultDorisAdminPassword

+ const DefaultDorisAdminUser

+ const DefaultDorisDatabaseName

+ const DefaultDorisPortName

+ func ChartName2TarName(chart string) string

+ func GenDorisSvcName(name string) string

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

v0.5.0

Jan 6, 2024

Changes in this version

+ const DefaultPGRWPortName

+ const DiskSubCommandDiscover

+ const DiskSubCommandInit

+ const DiskSubCommandLabel

+ const FeaturesOlapKey

+ var DefaultAccessHost = ""

+ func GenPostgresSvcName(name string) string

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

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

+ func GetReadyDirectPVVolumes(dpclient *directpvv1beta1.DirectpvV1beta1Client, ns string, ...) (*directpvv1beta1.DirectPVVolumeList, error)

type ClusterOptions

+ Olap string

+ type NineInfraStoragePool string

+ const NineInfraStoragePoolDefault

+ const NineInfraStoragePoolHigh

+ const NineInfraStoragePoolLow

+ const NineInfraStoragePoolMedium

type TPCDSOptions

+ DriverCores int

+ DriverMemory int

v0.4.8

Dec 30, 2023

Changes in this version

+ const DefaultNineInfraPrefix

+ const DefaultSparkUIName

+ const DefaultSparkUINodePort

+ const DefaultSparkUIPort

+ const DefaultTPCDSAPP

+ const DefaultTPCDSPrefix

+ const SparkDeployModeCluster

+ const SparkDriverNameSuffix

+ const ValidSparkDeployModeList

+ func GenThriftServiceAccountName(name string) string

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

+ func GetReleasedAndDeletePolicyPVList(clientset *kubernetes.Clientset, claimPrefix string) (*corev1.PersistentVolumeList, error)

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

type TPCDSOptions

+ DeployMode string

+ Force bool

+ ShuffleDiskSize int

+ ShuffleDisks int

+ SparkUI int

+ Stop bool

+ StorageClass string

+ TTY bool

v0.4.7

Dec 17, 2023

Changes in this version

+ const DefaultKyuubiVersion

+ const DefaultScalaVersion

+ func GetKubeConfig() (*restclient.Config, error)

+ type TPCDSOptions struct

+ DataBase string

+ ExecutorCores int

+ ExecutorMemory int

+ Executors int

+ GenData bool

+ Iterations int

+ NS string

+ Name string

+ Parallel int

+ Queries []string

+ ResultsDir string

+ ScaleFactor int

+ TPCDSJar string

v0.4.6

Dec 17, 2023

Changes in this version

+ func GenThriftSvcName(name string) string

+ func GetThriftPodName(name string, ns string) (string, error)

type SqlOptions

+ Silent bool

+ TTY bool

v0.4.5

Dec 15, 2023

Changes in this version

+ const DefaultCMDDirectPV

+ const DefaultCMDDirectPVInstallPath

+ const DefaultCMDDirectPVURL

+ const DefaultCMDHelm

+ const DefaultHelmCmdURL

+ const DefaultKyuubiUserName

+ const DefaultPGRWSVCNameSuffix

+ const DefaultRedisSVCName

+ const DefaultToolAirflowDBName

+ const DefaultToolAirflowDBPwd

+ const DefaultToolAirflowDBUser

+ const DefaultToolAirflowDiskSize

+ const DefaultToolAirflowName

+ const DefaultToolAirflowWebServerSecretKey

+ const DefaultToolNifiName

+ const DefaultToolNifiUserName

+ const DefaultToolNifiUserPWD

+ const DefaultToolRedisName

+ const DefaultToolSupersetDBName

+ const DefaultToolSupersetDBPwd

+ const DefaultToolSupersetDBUser

+ const DefaultToolSupersetName

+ const DefaultToolZookeeperName

+ const DefaultToolsNamePrefix

+ const DefaultZookeeperSVCName

+ const PrintFmtStrToolList

+ var DefaultStorageClass = "directpv-min-io"

+ var DefaultToolAirflowRepository = "nineinfra/airflow"

+ var DefaultToolAirflowSvcType = "NodePort"

+ var DefaultToolAirflowTag = "2.7.3"

+ var DefaultToolNifiSideCarTag = "1.36.1"

+ var DefaultToolNifiSvcNodePort = 31333

+ var DefaultToolNifiSvcType = "NodePort"

+ var DefaultToolSupersetSDataSourcesFile = "import_datasources.yaml"

+ var DefaultToolSupersetSecretFile = "secret"

+ var DefaultToolSupersetSvcType = "NodePort"

+ var DefaultToolsChartList = map[string]string

+ var Err2Suggestions = map[string]string

+ var NineToolAirflowWorkloadList = map[string]string

+ var NineToolList = map[string]interface

+ var NineToolNifiWorkloadList = map[string]string

+ var NineToolPortNameList = map[string]string

+ var NineToolPortProtocolList = map[string]string

+ var NineToolRedisWorkloadList = map[string]string

+ var NineToolSupersetloadList = map[string]string

+ var NineToolSvcList = map[string]string

+ var NineToolZookeeperWorkloadList = map[string]string

+ func CheckDeployIfReady(name string, namespace string) bool

+ func CheckHelmReleaseExist(name string, namespace string) bool

+ func GetIpFromKubeHost(host string) string

+ func GetKubeClientWithConfig(path string) (*kubernetes.Clientset, *restclient.Config, error)

+ func GetKubeHost(path string) string

+ func GetSvcAccessInfo(svcName string, portName string, ns string) (string, int32)

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

+ func GiveSuggestionsByError(err error) string

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

+ func NineToolResourceName(suffix string) string

+ func PrintClusterToolList(name string, namespace string)

+ func PrintToolAccessInfo(name string, ns string) string

+ func PrintToolList(clusters *nineinfrav1alpha1.NineClusterList)

+ type DatabasesConnection struct

+ AllowCTAS bool

+ AllowCVAS bool

+ AllowFileUpload bool

+ DatabaseName string

+ Extra string

+ SqlAlchemyURI string

+ Tables []string

v0.4.4

Dec 2, 2023

Changes in this version

+ const CMDDirectPV

+ const CMDDirectPVInstallPath

+ const CMDDirectPVURL

+ const CMDHelm

+ const CMDHelmURL

+ const DefaultHelmRepo

+ const DefaultHelmRepoName

+ const DefaultNamespace

+ const DefaultNineSuffix

+ const DefaultPVCLabelKey

+ const DefaultThriftPortName

+ const PrintFmtStrClusterList

+ const PrintFmtStrClusterProjectList

+ var DEBUG = false

+ var DefaultChartList = []string

+ var NineClusterProjectNameSuffix = map[string]string

+ var NineClusterProjectWorkloadList = map[string]string

+ var NineInfraDeploymentAlias = map[string]string

+ func AddHelmRepo(repo string) error

+ func Ask(label string) bool

+ func CheckClusterIfReady(name string, namespace string) bool

+ func CheckDirectPVCmdExist() bool

+ func CheckHelmCmdExist() bool

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

+ func CheckPGClusterIfReady(name string, namespace string) bool

+ func CheckStsIfReady(name string, namespace string) bool

+ func CheckValidClusterName(clustername string) error

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

+ func DeleteIfExist(resource string, resourceType string, flags string) error

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

+ func GetKubeClient(path string) (*kubernetes.Clientset, error)

+ func GetNineInfraClient(path string) (*nineinfrav1alpha1.Clientset, error)

+ func GetPGOperatorClient(path string) (*pgoperatorv1.Clientset, error)

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

+ func HelmUnInstall(name string, repoName 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 New(_ genericiooptions.IOStreams) *cobra.Command

+ func NineWorkLoadName(name string, project string) string

+ func PrintClusterList(clusters *nineinfrav1alpha1.NineClusterList)

+ func PrintClusterProjectList(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 RemoveHelmRepo(repo string) error

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

+ type ClusterOptions struct

+ DataVolume int

+ NS string

+ Name string

+ func (t ClusterOptions) Validate() error

+ type DeleteOptions struct

+ NS string

+ Name string

+ type DriveStatus string

+ const DriveStatusError

+ const DriveStatusLost

+ const DriveStatusMoving

+ const DriveStatusReady

+ const DriveStatusRemoved

+ type SqlOptions struct

+ NS string

+ Name string

+ Statement string

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