MCPcopy Create free account

hub / github.com/GreptimeTeam/gtctl / functions

Functions231 in github.com/GreptimeTeam/gtctl

↓ 1 callersFunctionNewPlaygroundCommand
(l logger.Logger)
cmd/gtctl/playground.go:26
↓ 1 callersFunctionNewRootCommand
()
cmd/gtctl/main.go:31
↓ 1 callersFunctionNewScaleClusterCommand
(l logger.Logger)
cmd/gtctl/cluster_scale.go:57
↓ 1 callersFunctionNewSpinner
()
pkg/status/status.go:53
↓ 1 callersFunctionNewVersionCommand
(l logger.Logger)
cmd/gtctl/version.go:26
↓ 1 callersFunctionOperatorName
()
pkg/cluster/kubernetes/create.go:192
↓ 1 callersFunctionPostgresSQL
PostgresSQL connects to a GreptimeDB cluster using postgres protocol.
pkg/connector/postgres.go:45
↓ 1 callersMethodScale
(ctx context.Context, options *opt.ScaleOptions)
pkg/cluster/kubernetes/scale.go:27
↓ 1 callersMethodSetHomeDir
SetHomeDir sets the home directory of the metadata manager.
pkg/metadata/manager.go:43
↓ 1 callersMethodSetVerbosity
(log.Level)
cmd/gtctl/main.go:54
↓ 1 callersFunctionUncompress
Uncompress uncompresses the file to the destination directory.
pkg/utils/file/file.go:103
↓ 1 callersMethodUpdateCluster
(ctx context.Context, namespace string, cluster *greptimev1alpha1.GreptimeDBCluster)
pkg/kube/client.go:203
↓ 1 callersMethodWaitForDeploymentReady
(ctx context.Context, name, namespace string, timeout time.Duration)
pkg/kube/client.go:225
↓ 1 callersMethodWaitForEtcdReady
(ctx context.Context, name, namespace string, timeout time.Duration)
pkg/kube/client.go:247
↓ 1 callersFunctionWithDryRun
WithDryRun enables Cluster to dry run.
pkg/cluster/kubernetes/cluster.go:40
↓ 1 callersFunctionWithEnableCache
(enableCache bool)
pkg/cluster/baremetal/cluster.go:81
↓ 1 callersFunctionWithGreptimeVersion
(version string)
pkg/cluster/baremetal/cluster.go:75
↓ 1 callersFunctionWithHomeDir
(dir string)
pkg/helm/loader.go:80
↓ 1 callersFunctionWithReplaceConfig
WithReplaceConfig replaces current cluster config with given config.
pkg/cluster/baremetal/cluster.go:69
↓ 1 callersFunctionWithTimeout
WithTimeout enables Cluster to have a timeout.
pkg/cluster/kubernetes/cluster.go:47
↓ 1 callersMethodchartFileName
(chartName, version string)
pkg/artifacts/manager.go:364
↓ 1 callersMethodchartIndexFile
chartIndexFile returns the index file of the chart. We use the index file to get the specific version of the latest chart.
pkg/artifacts/manager.go:299
↓ 1 callersMethodcheckEtcdHealth
(etcdBin string)
pkg/cluster/baremetal/create.go:179
↓ 1 callersFunctioncollectClusterInfoFromBareMetal
(data *cfg.BareMetalClusterMetadata)
pkg/cluster/baremetal/get.go:96
↓ 1 callersMethodconfigGetView
(table *tablewriter.Table)
pkg/cluster/baremetal/get.go:78
↓ 1 callersMethodconfigListView
(table *tablewriter.Table)
pkg/cluster/kubernetes/list.go:53
↓ 1 callersMethodconnectMySQL
(cluster *greptimedbclusterv1alpha1.GreptimeDBCluster)
pkg/cluster/kubernetes/connect.go:57
↓ 1 callersMethodconnectPostgres
(cluster *greptimedbclusterv1alpha1.GreptimeDBCluster)
pkg/cluster/kubernetes/connect.go:61
↓ 1 callersFunctioncreateCluster
()
tests/e2e/greptimedbcluster_test.go:142
↓ 1 callersMethoddebug
debug is like print but with a debug log header.
pkg/logger/logger.go:223
↓ 1 callersMethoddebugf
debugf is like printf but with a debug log header.
pkg/logger/logger.go:236
↓ 1 callersMethoddelete
(_ context.Context, baseDir string)
pkg/cluster/baremetal/delete.go:53
↓ 1 callersMethoddeleteCluster
(ctx context.Context, options *opt.DeleteOptions)
pkg/cluster/kubernetes/delete.go:60
↓ 1 callersMethoddeleteEtcdCluster
(ctx context.Context, options *opt.DeleteOptions)
pkg/cluster/kubernetes/delete.go:64
↓ 1 callersMethoddownloadFromHTTP
(ctx context.Context, httpURL string, dest string)
pkg/artifacts/manager.go:234
↓ 1 callersMethoddownloadFromOCI
(registryURL, version, dest string)
pkg/artifacts/manager.go:269
↓ 1 callersMethodetcdBinaryDownloadURL
(version string, fromCNRegion bool)
pkg/artifacts/manager.go:378
↓ 1 callersMethodgenerateManifests
(ctx context.Context, releaseName, namespace string, chart *chart.Chart, values map[string]interface{})
pkg/helm/loader.go:163
↓ 1 callersFunctiongetCluster
()
tests/e2e/greptimedbcluster_test.go:153
↓ 1 callersMethodgetVerbosity
()
pkg/logger/logger.go:281
↓ 1 callersMethodgetVersionInfoFromS3
getVersionInfoFromS3 gets the latest version info from S3.
pkg/artifacts/manager.go:496
↓ 1 callersMethodgreptimeBinaryDownloadURL
(version string, fromCNRegion bool)
pkg/artifacts/manager.go:401
↓ 1 callersMethodinstallBinaries
installBinaries installs the binaries to the installDir.
pkg/artifacts/manager.go:425
↓ 1 callersFunctionisBreakingVersion
TODO(zyy17): This function is just a temporary solution. We will remove it after the download URL of the greptime binary is stable.
pkg/artifacts/manager.go:542
↓ 1 callersMethodisClusterReady
(ctx context.Context, name, namespace string)
pkg/kube/client.go:274
↓ 1 callersMethodisClusterRunning
isClusterRunning checks the current status of cluster by sending signal to process.
pkg/cluster/baremetal/delete.go:58
↓ 1 callersMethodisDeploymentReady
(ctx context.Context, name, namespace string)
pkg/kube/client.go:258
↓ 1 callersMethodisNamespacedResource
()
pkg/kube/client.go:332
↓ 1 callersMethodlatestChartVersion
latestChartVersion returns the latest chart version.
pkg/artifacts/manager.go:348
↓ 1 callersMethodlist
(ctx context.Context)
pkg/cluster/kubernetes/list.go:44
↓ 1 callersMethodlistClusters
(ctx context.Context)
pkg/kube/client.go:318
↓ 1 callersFunctionloadConfig
(path string, ret *BareMetalClusterConfig)
pkg/config/validate_test.go:85
↓ 1 callersFunctionmergeMaps
mergeMaps merges two maps recursively. The function is copied from 'helm/helm/pkg/cli/values/options.go'.
pkg/helm/values.go:86
↓ 1 callersFunctionmysqlCommand
(port string)
pkg/connector/mysql.go:129
↓ 1 callersFunctionnewBufferPool
newBufferPool returns a new bufferPool
pkg/logger/logger.go:291
↓ 1 callersMethodnewHelmClient
(releaseName, namespace string)
pkg/helm/loader.go:183
↓ 1 callersFunctionpostgresSQLCommand
(port string)
pkg/connector/postgres.go:118
↓ 1 callersFunctionprintTips
(l logger.Logger, clusterName string, options *clusterCreateCliOptions)
cmd/gtctl/cluster_create.go:235
↓ 1 callersMethodrenderGetView
(table *tablewriter.Table, data *cfg.BareMetalClusterMetadata)
pkg/cluster/baremetal/get.go:83
↓ 1 callersMethodrenderListView
(table *tablewriter.Table, data *greptimedbclusterv1alpha1.GreptimeDBClusterList)
pkg/cluster/kubernetes/list.go:67
↓ 1 callersMethodresolveLatestVersion
resolveLatestVersion resolves the latest tag to the specific version.
pkg/artifacts/manager.go:465
↓ 1 callersMethodscale
(options *opt.ScaleOptions, cluster *greptimedbclusterv1alpha1.GreptimeDBCluster)
pkg/cluster/kubernetes/scale.go:47
↓ 1 callersFunctionstruct2Values
struct2Values converts the input struct to a helm values map.
pkg/helm/values.go:106
↓ 1 callersFunctionuntar
(file, dst string)
pkg/utils/file/file.go:162
↓ 1 callersFunctionunzip
(file, dst string)
pkg/utils/file/file.go:115
↓ 1 callersMethodvalidate
()
cmd/gtctl/cluster_scale.go:39
↓ 1 callersMethodwait
(_ context.Context)
pkg/cluster/baremetal/create.go:253
↓ 1 callersMethodwrite
synchronized write to the inner writer
pkg/logger/logger.go:191
MethodAllocateArtifactFilePath
(src *artifacts.Source, installBinary bool)
pkg/metadata/manager.go:117
MethodAllocateClusterScopeDirs
(clusterName string)
pkg/metadata/manager.go:99
MethodBuildArgs
BuildArgs build up args for cluster component.
pkg/components/types.go:47
MethodClean
()
pkg/metadata/manager.go:195
MethodConnect
(ctx context.Context, options *opt.ConnectOptions)
pkg/cluster/baremetal/not_implemented.go:34
FunctionCopyFile
CopyFile copies the file from src to dst.
pkg/utils/file/file.go:73
MethodCreate
(ctx context.Context, options *opt.CreateOptions)
pkg/cluster/baremetal/create.go:34
MethodCreate
(ctx context.Context, options *opt.CreateOptions)
pkg/cluster/kubernetes/create.go:34
MethodCreateClusterScopeDirs
(cfg *config.BareMetalClusterConfig)
pkg/metadata/manager.go:136
MethodDelete
(ctx context.Context, options *opt.DeleteOptions)
pkg/cluster/baremetal/delete.go:29
MethodDelete
(ctx context.Context, options *opt.DeleteOptions)
pkg/cluster/kubernetes/delete.go:27
FunctionDeleteDirIfExists
(dir string)
pkg/utils/file/file.go:44
MethodDownloadTo
(ctx context.Context, from *Source, destDir string, opts *DownloadOptions)
pkg/artifacts/manager.go:182
MethodEnabled
Enabled is part of the log.InfoLogger interface.
pkg/logger/logger.go:160
FunctionEnsureDir
EnsureDir ensures the directory exists.
pkg/utils/file/file.go:34
MethodGet
Get obtains a buffer from the pool.
pkg/logger/logger.go:305
MethodGet
(ctx context.Context, options *opt.GetOptions)
pkg/cluster/baremetal/get.go:37
MethodGet
(ctx context.Context, options *opt.GetOptions)
pkg/cluster/kubernetes/get.go:29
MethodGetClusterScopeDirs
()
pkg/metadata/manager.go:191
MethodGetWorkingDir
()
pkg/metadata/manager.go:187
FunctionIsFileExists
(filepath string)
pkg/utils/file/file.go:51
MethodIsRunning
(_ context.Context)
pkg/components/etcd.go:82
MethodIsRunning
(_ context.Context)
pkg/components/frontend.go:118
MethodIsRunning
IsRunning returns the status of current cluster component.
pkg/components/types.go:50
MethodList
(ctx context.Context, options *opt.ListOptions)
pkg/cluster/baremetal/not_implemented.go:26
MethodNewSource
(name, version string, typ ArtifactType, fromCNRegion bool)
pkg/artifacts/manager.go:116
MethodScale
Scale scales the current cluster according to NewReplicas in ScaleOptions, and refill the OldReplicas in ScaleOptions.
pkg/cluster/types.go:37
MethodScale
(ctx context.Context, options *opt.ScaleOptions)
pkg/cluster/baremetal/not_implemented.go:30
MethodSetHomeDir
(dir string)
pkg/metadata/manager.go:182
MethodSetVerbosity
SetVerbosity sets the loggers verbosity.
pkg/logger/logger.go:148
MethodStart
(ctx context.Context, stop context.CancelFunc, binary string)
pkg/components/metasrv.go:57
MethodStart
(ctx context.Context, stop context.CancelFunc, binary string)
pkg/components/etcd.go:48
← previousnext →101–200 of 231, ranked by callers