collection

Feb 1, 2024

Changes in this version

type Args

+ DisableFreeSpaceCheck bool

Jan 12, 2024

Changes in this version

+ func GetClusterPods(namespace string, cs CopyStrategy, ddfs helpers.Filesystem, k string) error

Dec 19, 2023

Changes in this version

type Args

+ Disabled []string

+ Enabled []string

+ PATSet bool

type SummaryInfo

+ CollectionsDisabled []string

+ CollectionsEnabled []string

+ PatSet bool

Dec 18, 2023

Changes in this version

+ func GetClusterNodes(namespace string, cs CopyStrategy, ddfs helpers.Filesystem, k string) error

Dec 1, 2023

Changes in this version

+ func FindClusterID(outputDir string) (clusterStatsList []clusterstats.ClusterStats, err error)

type Collector

+ Name func() string

+ type NodeCaptureStats struct

+ func (n *NodeCaptureStats) Update(node string, secondsElapsed int, status string)

+ type Stats struct

+ TransfersComplete int

+ var CollectionStatsGlobal *Stats

+ func (c *Stats) PrintState()

+ func (c *Stats) UpdateDDCVersion(ddcVersion, logFile, ddcYaml, collectionType string, ddcYamlIsValid bool, ...)

+ func (c *Stats) UpdateNodeState(node string, secondsElapsed int, status string)

type SummaryInfo

+ ClusterID map[string]string

+ DDCVersion string

+ DremioVersion map[string]string

Jul 13, 2023

Changes in this version

+ func GetClusterLogs(namespace string, cs CopyStrategy, ddfs helpers.Filesystem, k string, ...) error

type Args

+ DDCYamlLoc string

+ DremioPAT string

+ TransferDir string

type HostCaptureConfiguration

+ DremioPAT string

+ TransferDir string

Jun 16, 2023

Changes in this version

+ var DirPerms fs.FileMode = 0750

+ func ClusterK8sExecute(namespace string, cs CopyStrategy, ddfs helpers.Filesystem, c Collector, ...) error

+ func ComposeCopy(conf HostCaptureConfiguration, source, destination string) (stdOut string, err error)

+ func ComposeCopyNoSudo(conf HostCaptureConfiguration, source, destination string) (stdOut string, err error)

+ func ComposeCopyTo(conf HostCaptureConfiguration, source, destination string) (stdOut string, err error)

+ func ComposeExecute(conf HostCaptureConfiguration, command []string) (stdOut string, err error)

+ func ComposeExecuteAndStream(conf HostCaptureConfiguration, output cli.OutputHandler, command []string) error

+ func ComposeExecuteNoSudo(conf HostCaptureConfiguration, command []string) (stdOut string, err error)

+ func Execute(c Collector, s CopyStrategy, collectionArgs Args, clusterCollection ...func()) error

+ func ExtractTarGz(gzFilePath, dest string) error

+ func FindTarGzFiles(rootDir string) ([]string, error)

+ func SanitizeArchivePath(d, t string) (v string, err error)

+ type Args struct

+ CoordinatorStr string

+ CopyStrategy CopyStrategy

+ DDCfs helpers.Filesystem

+ ExecutorsStr string

+ OutputLoc string

+ SudoUser string

+ type ClusterInfo struct

+ NumberNodesContacted int

+ TotalNodesAttempted int

+ type Collector interface

+ CopyFromHost func(hostString string, isCoordinator bool, source, destination string) (out string, err error)

+ CopyFromHostSudo func(hostString string, isCoordinator bool, sudoUser, source, destination string) (out string, err error)

+ CopyToHost func(hostString string, isCoordinator bool, source, destination string) (out string, err error)

+ CopyToHostSudo func(hostString string, isCoordinator bool, sudoUser, source, destination string) (out string, err error)

+ FindHosts func(searchTerm string) (podName []string, err error)

+ HelpText func() string

+ HostExecute func(hostString string, isCoordinator bool, args ...string) (stdOut string, err error)

+ HostExecuteAndStream func(hostString string, output cli.OutputHandler, isCoordinator bool, ...) error

+ type CopyStrategy interface

+ ArchiveDiag func(o string, outputLoc string) error

+ CreatePath func(fileType, source, nodeType string) (path string, err error)

+ GetTmpDir func() string

+ type FailedFiles struct

+ Err error

+ Path string

+ func Capture(conf HostCaptureConfiguration, ...) (files []helpers.CollectedFile, failedFiles []FailedFiles, ...)

+ type FindErr struct

+ Cmd string

+ func (fe FindErr) Error() string

+ type HostCaptureConfiguration struct

+ Collector Collector

+ CopyStrategy CopyStrategy

+ DDCfs helpers.Filesystem

+ Host string

+ IsCoordinator bool

+ NodeCaptureOutput string

+ OutputLocation string

+ SudoUser string

+ type SummaryInfo struct

+ ClusterInfo ClusterInfo

+ CollectedFiles []helpers.CollectedFile

+ Coordinators []string

+ EndTimeUTC time.Time

+ Executors []string

+ FailedFiles []FailedFiles

+ SkippedFiles []string

+ StartTimeUTC time.Time

+ TotalBytesCollected int64

+ TotalRuntimeSeconds int64

+ func (summary SummaryInfo) String() (string, error)

+ type SummaryInfoWriterError struct

+ Err error

+ SummaryInfo SummaryInfo

+ func (w SummaryInfoWriterError) Error() string