 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
      Index ¶
- Constants
- Variables
- func CreateCollector(ctx context.Context, client *kubernetes.Clientset, scheme *runtime.Scheme, ...) (*corev1.ConfigMap, *corev1.Pod, error)
- func DedupCollectors(allCollectors []*troubleshootv1beta2.Collect) []*troubleshootv1beta2.Collect
- func DeterministicIDForCollector(collector *troubleshootv1beta2.Collect) string
- func EnsureClusterResourcesFirst(list []*troubleshootv1beta2.Collect) []*troubleshootv1beta2.Collect
- func EnsureCollectorInList(list []*troubleshootv1beta2.Collect, collector troubleshootv1beta2.Collect) []*troubleshootv1beta2.Collect
- func GetCephCollectorFilepath(name, namespace string) string
- func GetCollector(collector *troubleshootv1beta2.Collect, bundlePath string, namespace string, ...) (interface{}, bool)
- func GetConfigMapErrorsFileName(configMapCollector *troubleshootv1beta2.ConfigMap) string
- func GetConfigMapFileName(configMapCollector *troubleshootv1beta2.ConfigMap, name string) string
- func GetContainerLogs(ctx context.Context, client kubernetes.Interface, namespace string, ...) ([]byte, error)
- func GetLonghornBackingImageManagersDirectory(namespace string) string
- func GetLonghornBackingImagesDirectory(namespace string) string
- func GetLonghornEngineImagesDirectory(namespace string) string
- func GetLonghornEnginesDirectory(namespace string) string
- func GetLonghornInstanceManagersDirectory(namespace string) string
- func GetLonghornLogsDirectory(namespace string) string
- func GetLonghornNodesDirectory(namespace string) string
- func GetLonghornReplicaChecksum(clientConfig *rest.Config, replica longhornv1beta1types.Replica, ...) (string, error)
- func GetLonghornReplicasDirectory(namespace string) string
- func GetLonghornSettingsFile(namespace string) string
- func GetLonghornShareManagersDirectory(namespace string) string
- func GetLonghornVolumesDirectory(namespace string) string
- func GetSecretErrorsFileName(secretCollector *troubleshootv1beta2.Secret) string
- func GetSecretFileName(secretCollector *troubleshootv1beta2.Secret, name string) string
- func IsRBACError(err error) bool
- func ListInstanceManagerReplicaPods(ctx context.Context, clientConfig *rest.Config, namespace string) (map[string]string, error)
- func ParseCollectorFromDoc(doc []byte) (*troubleshootv1beta2.Collector, error)
- func ParseHostCollectorFromDoc(doc []byte) (*troubleshootv1beta2.HostCollector, error)
- func ParseRemoteCollectorFromDoc(doc []byte) (*troubleshootv1beta2.RemoteCollector, error)
- func ParseReplicaChecksum(data []byte) (map[string]string, error)
- func RedactResult(bundlePath string, input CollectorResult, ...) error
- func RemoteHostCollect(ctx context.Context, params RemoteCollectParams) (map[string][]byte, error)
- func RunPodLogs(ctx context.Context, client v1.CoreV1Interface, podSpec *corev1.Pod) ([]byte, error)
- func RunPodLogsWithOptions(ctx context.Context, client v1.CoreV1Interface, podSpec *corev1.Pod, ...) ([]byte, error)
- func RunPodsReadyNodes(ctx context.Context, client v1.CoreV1Interface, opts RunPodOptions) (map[string][]byte, error)
- func TarSupportBundleDir(bundlePath string, input CollectorResult, outputFilename string) error
- func WaitForPodCompleted(ctx context.Context, client kubernetes.Interface, namespace string, ...) error
- func WaitForPodCondition(ctx context.Context, client kubernetes.Interface, namespace string, ...) error
- type BlockDeviceInfo
- type CPUInfo
- type CephCommand
- type CertCollection
- type CertificateSource
- type ClusterVersion
- type CollectCeph
- type CollectCertificates
- type CollectClusterInfo
- type CollectClusterResources
- type CollectCollectd
- type CollectConfigMap
- type CollectCopy
- type CollectCopyFromHost
- type CollectDNS
- type CollectData
- type CollectEtcd
- type CollectExec
- type CollectGoldpinger
- type CollectHTTP
- type CollectHelm
- type CollectHostBlockDevices
- func (c *CollectHostBlockDevices) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostBlockDevices) IsExcluded() (bool, error)
- func (c *CollectHostBlockDevices) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostBlockDevices) Title() string
 
- type CollectHostCGroups
- type CollectHostCPU
- type CollectHostCertificate
- func (c *CollectHostCertificate) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostCertificate) IsExcluded() (bool, error)
- func (c *CollectHostCertificate) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostCertificate) Title() string
 
- type CollectHostCertificatesCollection
- func (c *CollectHostCertificatesCollection) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostCertificatesCollection) IsExcluded() (bool, error)
- func (c *CollectHostCertificatesCollection) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostCertificatesCollection) Title() string
 
- type CollectHostCopy
- type CollectHostDNS
- type CollectHostDiskUsage
- func (c *CollectHostDiskUsage) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostDiskUsage) IsExcluded() (bool, error)
- func (c *CollectHostDiskUsage) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostDiskUsage) Title() string
 
- type CollectHostFilesystemPerformance
- func (c *CollectHostFilesystemPerformance) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostFilesystemPerformance) IsExcluded() (bool, error)
- func (c *CollectHostFilesystemPerformance) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostFilesystemPerformance) Title() string
 
- type CollectHostHTTP
- type CollectHostHTTPLoadBalancer
- func (c *CollectHostHTTPLoadBalancer) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostHTTPLoadBalancer) IsExcluded() (bool, error)
- func (c *CollectHostHTTPLoadBalancer) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostHTTPLoadBalancer) Title() string
 
- type CollectHostIPV4Interfaces
- func (c *CollectHostIPV4Interfaces) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostIPV4Interfaces) IsExcluded() (bool, error)
- func (c *CollectHostIPV4Interfaces) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostIPV4Interfaces) Title() string
 
- type CollectHostJournald
- func (c *CollectHostJournald) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostJournald) IsExcluded() (bool, error)
- func (c *CollectHostJournald) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostJournald) Title() string
 
- type CollectHostKernelConfigs
- func (c *CollectHostKernelConfigs) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostKernelConfigs) IsExcluded() (bool, error)
- func (c *CollectHostKernelConfigs) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostKernelConfigs) Title() string
 
- type CollectHostKernelModules
- func (c *CollectHostKernelModules) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostKernelModules) IsExcluded() (bool, error)
- func (c *CollectHostKernelModules) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostKernelModules) Title() string
 
- type CollectHostMemory
- type CollectHostNetworkNamespaceConnectivity
- type CollectHostOS
- type CollectHostRun
- type CollectHostServices
- func (c *CollectHostServices) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostServices) IsExcluded() (bool, error)
- func (c *CollectHostServices) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostServices) Title() string
 
- type CollectHostSubnetAvailable
- func (c *CollectHostSubnetAvailable) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostSubnetAvailable) IsExcluded() (bool, error)
- func (c *CollectHostSubnetAvailable) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostSubnetAvailable) Title() string
 
- type CollectHostSysctl
- type CollectHostSystemPackages
- func (c *CollectHostSystemPackages) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostSystemPackages) IsExcluded() (bool, error)
- func (c *CollectHostSystemPackages) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostSystemPackages) Title() string
 
- type CollectHostTCPConnect
- func (c *CollectHostTCPConnect) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostTCPConnect) IsExcluded() (bool, error)
- func (c *CollectHostTCPConnect) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostTCPConnect) Title() string
 
- type CollectHostTCPLoadBalancer
- func (c *CollectHostTCPLoadBalancer) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostTCPLoadBalancer) IsExcluded() (bool, error)
- func (c *CollectHostTCPLoadBalancer) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostTCPLoadBalancer) Title() string
 
- type CollectHostTCPPortStatus
- func (c *CollectHostTCPPortStatus) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostTCPPortStatus) IsExcluded() (bool, error)
- func (c *CollectHostTCPPortStatus) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostTCPPortStatus) Title() string
 
- type CollectHostTime
- type CollectHostUDPPortStatus
- func (c *CollectHostUDPPortStatus) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostUDPPortStatus) IsExcluded() (bool, error)
- func (c *CollectHostUDPPortStatus) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
- func (c *CollectHostUDPPortStatus) Title() string
 
- type CollectImageFacts
- type CollectLogs
- func (c *CollectLogs) Collect(progressChan chan<- interface{}) (CollectorResult, error)
- func (c *CollectLogs) CollectWithClient(progressChan chan<- interface{}, client kubernetes.Interface) (CollectorResult, error)
- func (c *CollectLogs) IsExcluded() (bool, error)
- func (c *CollectLogs) Title() string
 
- type CollectLonghorn
- type CollectMetrics
- type CollectMssql
- type CollectMysql
- type CollectNodeMetrics
- type CollectPostgres
- type CollectProgress
- type CollectRedis
- type CollectRegistry
- type CollectRun
- type CollectRunDaemonSet
- type CollectRunPod
- type CollectSecret
- type CollectSonobuoyResults
- type CollectSysctl
- type Collector
- type CollectorResult
- func (r CollectorResult) AddResult(other CollectorResult)
- func (r CollectorResult) ArchiveBundle(bundlePath string, outputFilename string) error
- func (r CollectorResult) ArchiveSupportBundle(bundlePath string, outputFilename string) error
- func (r CollectorResult) CloseWriter(bundlePath string, relativePath string, writer interface{}) error
- func (r CollectorResult) GetReader(bundlePath string, relativePath string) (io.ReadCloser, error)
- func (r CollectorResult) GetWriter(bundlePath string, relativePath string) (io.Writer, error)
- func (r CollectorResult) ReplaceResult(bundlePath string, relativePath string, reader io.Reader) error
- func (r CollectorResult) SaveResult(bundlePath string, relativePath string, reader io.Reader) error
- func (r CollectorResult) SaveResults(bundlePath, relativePath, targetDir string) error
- func (r CollectorResult) SymLinkResult(bundlePath, relativeLinkPath, relativeFilePath string) error
 
- type CollectorRunOpts
- type ConfigMapOutput
- type DNSEntry
- type DNSQuery
- type DNSResult
- type DNSTroubleshootResult
- type DatabaseConnection
- type DiskUsageInfo
- type Durations
- type FSPerfResults
- type FakeReader
- type FioDepth
- type FioDiskUtil
- type FioGlobalOptions
- type FioJobOptions
- type FioJobs
- type FioLatency
- type FioNS
- type FioPercentile
- type FioResult
- type FioStats
- type HTTPError
- type HTTPResponse
- type HostCertificatesCollection
- type HostCollectResult
- type HostCollector
- type HostOSInfo
- type HostOSInfoNodes
- type HostRunInfo
- type ImageRunner
- type KConfigs
- type KernelModuleInfo
- type KernelModuleStatus
- type LoggingTransport
- type MemoryInfo
- type MergeableCollector
- type NTPStatus
- type NetworkNamespaceConnectivityErrors
- type NetworkNamespaceConnectivityInfo
- type NetworkNamespaceConnectivityOutput
- type NetworkStatus
- type NetworkStatusResult
- type ParsedCertificate
- type PodSpecRunner
- type RBACError
- type RBACErrors
- type RegistryImage
- type RegistryInfo
- type ReleaseInfo
- type RemoteCollectParams
- type RemoteCollectResult
- type RemoteCollector
- func (c *RemoteCollector) CheckRBAC(ctx context.Context) error
- func (c *RemoteCollector) GetDisplayName() string
- func (c *RemoteCollector) IsExcluded() bool
- func (c *RemoteCollector) RunCollectorSync(globalRedactors []*troubleshootv1beta2.Redact) (CollectorResult, error)
- func (c *RemoteCollector) RunRemote(ctx context.Context, runner runner, nodes []string, ...) (map[string][]byte, error)
 
- type RemoteCollectors
- type RunPodOptions
- type SecretOutput
- type ServiceInfo
- type SubnetAvailableResult
- type SubnetStatus
- type SystemPackage
- type SystemPackagesInfo
- type TimeInfo
- type VersionInfo
Constants ¶
const ( FioJobName = "fsperf" DefaultFioRunTime = "120" )
const ( KernelModuleUnknown = "unknown" KernelModuleLoaded = "loaded" KernelModuleLoadable = "loadable" KernelModuleLoading = "loading" KernelModuleUnloading = "unloading" )
const ( NetworkStatusAddressInUse = "address-in-use" NetworkStatusConnectionRefused = "connection-refused" NetworkStatusConnectionTimeout = "connection-timeout" NetworkStatusConnected = "connected" NetworkStatusErrorOther = "error" NetworkStatusBindPermissionDenied = "bind-permission-denied" NetworkStatusInvalidAddress = "invalid-address" )
const ( SubnetStatusAvailable = "a-subnet-is-available" SubnetStatusNoneAvailable = "no-subnet-available" )
const ( DefaultSonobuoyNamespace = "sonobuoy" DefaultSonobuoyAggregatorPodName = "sonobuoy" DefaultSonobuoyAggregatorContainerName = "kube-sonobuoy" DefaultSonobuoyAggregatorResultsPath = "/tmp/sonobuoy" )
const CertInvalid = "cert-invalid"
    const CertMissing = "cert-missing"
    const CertValid = "cert-valid"
    const (
	DefaultCephNamespace = "rook-ceph"
)
    const (
	DefaultLonghornNamespace = "longhorn-system"
)
    const HostBlockDevicesFileName = `block_devices.json`
    const HostBlockDevicesPath = `host-collectors/system/block_devices.json`
    const HostCPUFileName = `cpu.json`
    const HostCPUPath = `host-collectors/system/cpu.json`
    const (
	HostDNSPath = "host-collectors/dns/"
)
    const HostIPV4FileName = `ipv4Interfaces.json`
    const HostIPV4InterfacesPath = `host-collectors/system/ipv4Interfaces.json`
    const HostInfoFileName = `hostos_info.json`
    const HostJournaldPath = `host-collectors/journald/`
    const HostKernelConfigsFileName = `kernel-configs.json`
    const HostKernelConfigsPath = `host-collectors/system/kernel-configs.json`
    const HostKernelModulesPath = `host-collectors/system/kernel_modules.json`
    const HostMemoryFileName = `memory.json`
    const HostMemoryPath = `host-collectors/system/memory.json`
    const HostOSInfoPath = `host-collectors/system/hostos_info.json`
    const HostServicesFileName = `systemctl_services.json`
    const HostServicesPath = `host-collectors/system/systemctl_services.json`
    const HostSysctlFileName = `sysctl.json`
    const HostSysctlPath = `host-collectors/system/sysctl.json`
    const HostTimeFileName = `time.json`
    const HostTimePath = `host-collectors/system/time.json`
    const KeyPairEncrypted = "key-pair-encrypted"
    const KeyPairInvalid = "key-pair-invalid"
    const KeyPairMismatch = "key-pair-mismatch"
    const KeyPairMissing = "key-pair-missing"
    const KeyPairSwitched = "key-pair-switched"
    const KeyPairValid = "key-pair-valid"
    const MAX_CONCURRENT_REDACTORS = 10
    Max number of concurrent redactors to run Ensure the number is low enough since each of the redactors also spawns goroutines to redact files in tar archives and other goroutines for each redactor spec.
const NodeInfoBaseDir = `host-collectors/system`
    Variables ¶
var ( // ErrCollectorNotFound is returned when an undefined host collector is // specified by the user. ErrHostCollectorNotFound = errors.New("unrecognized host collector") ErrInsufficientPermissionsToRun = errors.New("insufficient permissions to run all collectors") ErrRemoteCollectorNotImplemented = errors.New("unimplemented remote collector") )
var CephCommands = []CephCommand{ { ID: "status", Command: []string{"ceph", "status"}, Args: []string{"-f", "json-pretty"}, Format: "json", DefaultTimeout: "30s", }, { ID: "status-txt", Command: []string{"ceph", "status"}, Format: "txt", DefaultTimeout: "30s", }, { ID: "fs", Command: []string{"ceph", "fs", "status"}, Args: []string{"-f", "json-pretty"}, Format: "json", DefaultTimeout: "30s", }, { ID: "fs-txt", Command: []string{"ceph", "fs", "status"}, Format: "txt", DefaultTimeout: "30s", }, { ID: "fs-ls", Command: []string{"ceph", "fs", "ls"}, Args: []string{"-f", "json-pretty"}, Format: "json", DefaultTimeout: "30s", }, { ID: "osd-status", Command: []string{"ceph", "osd", "status"}, Args: []string{"-f", "json-pretty"}, Format: "json", DefaultTimeout: "30s", }, { ID: "osd-tree", Command: []string{"ceph", "osd", "tree"}, Args: []string{"-f", "json-pretty"}, Format: "json", DefaultTimeout: "30s", }, { ID: "osd-pool", Command: []string{"ceph", "osd", "pool", "ls", "detail"}, Args: []string{"-f", "json-pretty"}, Format: "json", DefaultTimeout: "30s", }, { ID: "health", Command: []string{"ceph", "health", "detail"}, Args: []string{"-f", "json-pretty"}, Format: "json", DefaultTimeout: "30s", }, { ID: "auth", Command: []string{"ceph", "auth", "ls"}, Args: []string{"-f", "json-pretty"}, Format: "json", DefaultTimeout: "30s", }, { ID: "rgw-stats", Command: []string{"radosgw-admin", "bucket", "stats"}, Args: []string{"--rgw-cache-enabled=false"}, Format: "json", DefaultTimeout: "30s", }, { ID: "rbd-du-txt", Command: []string{"rbd", "du"}, Args: []string{"--pool=replicapool"}, Format: "txt", DefaultTimeout: "60s", }, { ID: "df", Command: []string{"ceph", "df"}, Args: []string{"-f", "json-pretty"}, Format: "json", DefaultTimeout: "30s", }, { ID: "df-txt", Command: []string{"ceph", "df"}, Format: "txt", DefaultTimeout: "30s", }, { ID: "osd-df", Command: []string{"ceph", "osd", "df"}, Args: []string{"-f", "json-pretty"}, Format: "json", DefaultTimeout: "30s", }, { ID: "osd-df-txt", Command: []string{"ceph", "osd", "df"}, Format: "txt", DefaultTimeout: "30s", }, }
Functions ¶
func CreateCollector ¶
func CreateCollector(ctx context.Context, client *kubernetes.Clientset, scheme *runtime.Scheme, ownerRef metav1.Object, name string, namespace string, nodeName string, serviceAccountName string, jobType string, collect *troubleshootv1beta2.HostCollect, image string, pullPolicy string) (*corev1.ConfigMap, *corev1.Pod, error)
func DedupCollectors ¶ added in v0.56.0
func DedupCollectors(allCollectors []*troubleshootv1beta2.Collect) []*troubleshootv1beta2.Collect
deduplicates a list of troubleshootv1beta2.Collect objects marshals object to json and then uses its string value to check for uniqueness there is no sorting of the keys in the collect object's spec so if the spec isn't an exact match line for line as written, no dedup will occur
func DeterministicIDForCollector ¶
func DeterministicIDForCollector(collector *troubleshootv1beta2.Collect) string
func EnsureClusterResourcesFirst ¶ added in v0.46.0
func EnsureClusterResourcesFirst(list []*troubleshootv1beta2.Collect) []*troubleshootv1beta2.Collect
collect ClusterResources earliest in the list so the pod list does not include pods started by collectors
func EnsureCollectorInList ¶ added in v0.46.0
func EnsureCollectorInList(list []*troubleshootv1beta2.Collect, collector troubleshootv1beta2.Collect) []*troubleshootv1beta2.Collect
Ensure that the specified collector is in the list of collectors
func GetCephCollectorFilepath ¶ added in v0.9.50
func GetCollector ¶ added in v0.44.0
func GetConfigMapErrorsFileName ¶ added in v0.13.3
func GetConfigMapErrorsFileName(configMapCollector *troubleshootv1beta2.ConfigMap) string
func GetConfigMapFileName ¶ added in v0.13.3
func GetConfigMapFileName(configMapCollector *troubleshootv1beta2.ConfigMap, name string) string
func GetContainerLogs ¶ added in v0.15.0
func GetLonghornBackingImageManagersDirectory ¶ added in v0.11.0
func GetLonghornBackingImagesDirectory ¶ added in v0.11.0
func GetLonghornEngineImagesDirectory ¶ added in v0.11.0
func GetLonghornEnginesDirectory ¶ added in v0.11.0
func GetLonghornInstanceManagersDirectory ¶ added in v0.11.0
func GetLonghornLogsDirectory ¶ added in v0.11.0
func GetLonghornNodesDirectory ¶ added in v0.11.0
func GetLonghornReplicaChecksum ¶ added in v0.12.0
func GetLonghornReplicasDirectory ¶ added in v0.11.0
func GetLonghornSettingsFile ¶ added in v0.11.0
func GetLonghornShareManagersDirectory ¶ added in v0.11.0
func GetLonghornVolumesDirectory ¶ added in v0.11.0
func GetSecretErrorsFileName ¶ added in v0.13.3
func GetSecretErrorsFileName(secretCollector *troubleshootv1beta2.Secret) string
func GetSecretFileName ¶ added in v0.13.3
func GetSecretFileName(secretCollector *troubleshootv1beta2.Secret, name string) string
func IsRBACError ¶ added in v0.9.15
func ListInstanceManagerReplicaPods ¶ added in v0.12.0
func ListInstanceManagerReplicaPods(ctx context.Context, clientConfig *rest.Config, namespace string) (map[string]string, error)
Returns a map of nodeName:podName
func ParseCollectorFromDoc ¶ added in v0.15.0
func ParseCollectorFromDoc(doc []byte) (*troubleshootv1beta2.Collector, error)
func ParseHostCollectorFromDoc ¶ added in v0.15.0
func ParseHostCollectorFromDoc(doc []byte) (*troubleshootv1beta2.HostCollector, error)
func ParseRemoteCollectorFromDoc ¶ added in v0.15.0
func ParseRemoteCollectorFromDoc(doc []byte) (*troubleshootv1beta2.RemoteCollector, error)
func ParseReplicaChecksum ¶ added in v0.12.0
func RedactResult ¶ added in v0.38.0
func RedactResult(bundlePath string, input CollectorResult, additionalRedactors []*troubleshootv1beta2.Redact) error
func RemoteHostCollect ¶ added in v0.106.0
func RunPodLogs ¶ added in v0.14.0
func RunPodLogs(ctx context.Context, client v1.CoreV1Interface, podSpec *corev1.Pod) ([]byte, error)
RunPodLogs runs a pod to completion on a node and returns its logs
func RunPodLogsWithOptions ¶ added in v0.121.0
func RunPodLogsWithOptions(ctx context.Context, client v1.CoreV1Interface, podSpec *corev1.Pod, allowImagePullRetries bool) ([]byte, error)
RunPodLogsWithOptions runs a pod to completion on a node and returns its logs with configurable options
func RunPodsReadyNodes ¶ added in v0.14.0
func RunPodsReadyNodes(ctx context.Context, client v1.CoreV1Interface, opts RunPodOptions) (map[string][]byte, error)
func TarSupportBundleDir ¶ added in v0.13.15
func TarSupportBundleDir(bundlePath string, input CollectorResult, outputFilename string) error
TarSupportBundleDir wraps ArchiveSupportBundle for backwards compatibility Deprecated: Remove in a future version (v1.0)
Types ¶
type BlockDeviceInfo ¶ added in v0.10.2
type BlockDeviceInfo struct {
	Name             string `json:"name"`
	KernelName       string `json:"kernel_name"`
	ParentKernelName string `json:"parent_kernel_name"`
	Type             string `json:"type"`
	Major            int    `json:"major"`
	Minor            int    `json:"minor"`
	Size             uint64 `json:"size"`
	FilesystemType   string `json:"filesystem_type"`
	Mountpoint       string `json:"mountpoint"`
	Serial           string `json:"serial"`
	ReadOnly         bool   `json:"read_only"`
	Removable        bool   `json:"removable"`
}
    type CephCommand ¶ added in v0.9.50
type CertCollection ¶ added in v0.62.0
type CertCollection struct {
	Source           *CertificateSource  `json:"source"`
	Errors           []string            `json:"errors,omitempty"`
	CertificateChain []ParsedCertificate `json:"certificateChain,omitempty"`
}
    Certificate collection struct
type CertificateSource ¶ added in v0.62.0
type CertificateSource struct {
	SecretName    string `json:"secret,omitempty"`
	ConfigMapName string `json:"configMap,omitempty"`
	Namespace     string `json:"namespace,omitempty"`
}
    Certificate source
type ClusterVersion ¶
type CollectCeph ¶ added in v0.44.0
type CollectCeph struct {
	Collector    *troubleshootv1beta2.Ceph
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectCeph) Collect ¶ added in v0.44.0
func (c *CollectCeph) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectCeph) IsExcluded ¶ added in v0.44.0
func (c *CollectCeph) IsExcluded() (bool, error)
func (*CollectCeph) Title ¶ added in v0.44.0
func (c *CollectCeph) Title() string
type CollectCertificates ¶ added in v0.62.0
type CollectCertificates struct {
	Collector    *troubleshootv1beta2.Certificates
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectCertificates) Collect ¶ added in v0.62.0
func (c *CollectCertificates) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectCertificates) IsExcluded ¶ added in v0.62.0
func (c *CollectCertificates) IsExcluded() (bool, error)
func (*CollectCertificates) Title ¶ added in v0.62.0
func (c *CollectCertificates) Title() string
type CollectClusterInfo ¶ added in v0.44.0
type CollectClusterInfo struct {
	Collector    *troubleshootv1beta2.ClusterInfo
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	RBACErrors
}
    func (*CollectClusterInfo) Collect ¶ added in v0.44.0
func (c *CollectClusterInfo) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectClusterInfo) IsExcluded ¶ added in v0.44.0
func (c *CollectClusterInfo) IsExcluded() (bool, error)
func (*CollectClusterInfo) Title ¶ added in v0.44.0
func (c *CollectClusterInfo) Title() string
type CollectClusterResources ¶ added in v0.44.0
type CollectClusterResources struct {
	Collector    *troubleshootv1beta2.ClusterResources
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	RBACErrors
}
    func (*CollectClusterResources) Collect ¶ added in v0.44.0
func (c *CollectClusterResources) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectClusterResources) IsExcluded ¶ added in v0.44.0
func (c *CollectClusterResources) IsExcluded() (bool, error)
func (*CollectClusterResources) Merge ¶ added in v0.44.0
func (c *CollectClusterResources) Merge(allCollectors []Collector) ([]Collector, error)
func (*CollectClusterResources) Title ¶ added in v0.44.0
func (c *CollectClusterResources) Title() string
type CollectCollectd ¶ added in v0.44.0
type CollectCollectd struct {
	Collector    *troubleshootv1beta2.Collectd
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectCollectd) Collect ¶ added in v0.44.0
func (c *CollectCollectd) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectCollectd) IsExcluded ¶ added in v0.44.0
func (c *CollectCollectd) IsExcluded() (bool, error)
func (*CollectCollectd) Title ¶ added in v0.44.0
func (c *CollectCollectd) Title() string
type CollectConfigMap ¶ added in v0.44.0
type CollectConfigMap struct {
	Collector    *troubleshootv1beta2.ConfigMap
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectConfigMap) Collect ¶ added in v0.44.0
func (c *CollectConfigMap) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectConfigMap) IsExcluded ¶ added in v0.44.0
func (c *CollectConfigMap) IsExcluded() (bool, error)
func (*CollectConfigMap) Title ¶ added in v0.44.0
func (c *CollectConfigMap) Title() string
type CollectCopy ¶ added in v0.44.0
type CollectCopy struct {
	Collector    *troubleshootv1beta2.Copy
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectCopy) Collect ¶ added in v0.44.0
func (c *CollectCopy) Collect(progressChan chan<- interface{}) (CollectorResult, error)
Copy function gets a file or folder from a container specified in the specs.
func (*CollectCopy) IsExcluded ¶ added in v0.44.0
func (c *CollectCopy) IsExcluded() (bool, error)
func (*CollectCopy) Title ¶ added in v0.44.0
func (c *CollectCopy) Title() string
type CollectCopyFromHost ¶ added in v0.44.0
type CollectCopyFromHost struct {
	Collector        *troubleshootv1beta2.CopyFromHost
	BundlePath       string
	Namespace        string
	ClientConfig     *rest.Config
	Client           kubernetes.Interface
	Context          context.Context
	RetryFailedMount bool
	RBACErrors
}
    func (*CollectCopyFromHost) Collect ¶ added in v0.44.0
func (c *CollectCopyFromHost) Collect(progressChan chan<- interface{}) (CollectorResult, error)
copies a file or directory from a host or hosts to include in the bundle.
func (*CollectCopyFromHost) IsExcluded ¶ added in v0.44.0
func (c *CollectCopyFromHost) IsExcluded() (bool, error)
func (*CollectCopyFromHost) Title ¶ added in v0.44.0
func (c *CollectCopyFromHost) Title() string
type CollectDNS ¶ added in v0.90.1
type CollectDNS struct {
	Collector    *troubleshootv1beta2.DNS
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectDNS) Collect ¶ added in v0.90.1
func (c *CollectDNS) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectDNS) IsExcluded ¶ added in v0.90.1
func (c *CollectDNS) IsExcluded() (bool, error)
func (*CollectDNS) Title ¶ added in v0.90.1
func (c *CollectDNS) Title() string
type CollectData ¶ added in v0.44.0
type CollectData struct {
	Collector    *troubleshootv1beta2.Data
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectData) Collect ¶ added in v0.44.0
func (c *CollectData) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectData) IsExcluded ¶ added in v0.44.0
func (c *CollectData) IsExcluded() (bool, error)
func (*CollectData) Title ¶ added in v0.44.0
func (c *CollectData) Title() string
type CollectEtcd ¶ added in v0.99.0
type CollectEtcd struct {
	Collector    *troubleshootv1beta2.Etcd
	BundlePath   string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectEtcd) Collect ¶ added in v0.99.0
func (c *CollectEtcd) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectEtcd) IsExcluded ¶ added in v0.99.0
func (c *CollectEtcd) IsExcluded() (bool, error)
func (*CollectEtcd) Title ¶ added in v0.99.0
func (c *CollectEtcd) Title() string
type CollectExec ¶ added in v0.44.0
type CollectExec struct {
	Collector    *troubleshootv1beta2.Exec
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectExec) Collect ¶ added in v0.44.0
func (c *CollectExec) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectExec) IsExcluded ¶ added in v0.44.0
func (c *CollectExec) IsExcluded() (bool, error)
func (*CollectExec) Title ¶ added in v0.44.0
func (c *CollectExec) Title() string
type CollectGoldpinger ¶ added in v0.79.0
type CollectGoldpinger struct {
	Collector    *troubleshootv1beta2.Goldpinger
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    Collect goldpinger results from goldpinger service running in a cluster The results are stored in goldpinger/check_all.json since we use the /check_all endpoint
func (*CollectGoldpinger) Collect ¶ added in v0.79.0
func (c *CollectGoldpinger) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectGoldpinger) DiscoverOrCreateGoldpinger ¶ added in v0.104.0
func (c *CollectGoldpinger) DiscoverOrCreateGoldpinger(ns string) (string, createdResources, error)
func (*CollectGoldpinger) IsExcluded ¶ added in v0.79.0
func (c *CollectGoldpinger) IsExcluded() (bool, error)
func (*CollectGoldpinger) Title ¶ added in v0.79.0
func (c *CollectGoldpinger) Title() string
type CollectHTTP ¶ added in v0.44.0
type CollectHTTP struct {
	Collector    *troubleshootv1beta2.HTTP
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	RBACErrors
}
    func (*CollectHTTP) Collect ¶ added in v0.44.0
func (c *CollectHTTP) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectHTTP) IsExcluded ¶ added in v0.44.0
func (c *CollectHTTP) IsExcluded() (bool, error)
func (*CollectHTTP) Title ¶ added in v0.44.0
func (c *CollectHTTP) Title() string
type CollectHelm ¶ added in v0.71.1
type CollectHelm struct {
	Collector    *troubleshootv1beta2.Helm
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectHelm) Collect ¶ added in v0.71.1
func (c *CollectHelm) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectHelm) IsExcluded ¶ added in v0.71.1
func (c *CollectHelm) IsExcluded() (bool, error)
func (*CollectHelm) Title ¶ added in v0.71.1
func (c *CollectHelm) Title() string
type CollectHostBlockDevices ¶ added in v0.10.8
type CollectHostBlockDevices struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostBlockDevices) Collect ¶ added in v0.10.8
func (c *CollectHostBlockDevices) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostBlockDevices) IsExcluded ¶ added in v0.10.8
func (c *CollectHostBlockDevices) IsExcluded() (bool, error)
func (*CollectHostBlockDevices) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostBlockDevices) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostBlockDevices) Title ¶ added in v0.10.8
func (c *CollectHostBlockDevices) Title() string
type CollectHostCGroups ¶ added in v0.97.0
type CollectHostCGroups struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostCGroups) Collect ¶ added in v0.97.0
func (c *CollectHostCGroups) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostCGroups) IsExcluded ¶ added in v0.97.0
func (c *CollectHostCGroups) IsExcluded() (bool, error)
func (*CollectHostCGroups) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostCGroups) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostCGroups) Title ¶ added in v0.97.0
func (c *CollectHostCGroups) Title() string
type CollectHostCPU ¶ added in v0.10.8
type CollectHostCPU struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostCPU) Collect ¶ added in v0.10.8
func (c *CollectHostCPU) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostCPU) IsExcluded ¶ added in v0.10.8
func (c *CollectHostCPU) IsExcluded() (bool, error)
func (*CollectHostCPU) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostCPU) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostCPU) Title ¶ added in v0.10.8
func (c *CollectHostCPU) Title() string
type CollectHostCertificate ¶ added in v0.10.8
type CollectHostCertificate struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostCertificate) Collect ¶ added in v0.10.8
func (c *CollectHostCertificate) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostCertificate) IsExcluded ¶ added in v0.10.8
func (c *CollectHostCertificate) IsExcluded() (bool, error)
func (*CollectHostCertificate) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostCertificate) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostCertificate) Title ¶ added in v0.10.8
func (c *CollectHostCertificate) Title() string
type CollectHostCertificatesCollection ¶ added in v0.70.0
type CollectHostCertificatesCollection struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostCertificatesCollection) Collect ¶ added in v0.70.0
func (c *CollectHostCertificatesCollection) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostCertificatesCollection) IsExcluded ¶ added in v0.70.0
func (c *CollectHostCertificatesCollection) IsExcluded() (bool, error)
func (*CollectHostCertificatesCollection) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostCertificatesCollection) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostCertificatesCollection) Title ¶ added in v0.70.0
func (c *CollectHostCertificatesCollection) Title() string
type CollectHostCopy ¶ added in v0.61.0
type CollectHostCopy struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostCopy) Collect ¶ added in v0.61.0
func (c *CollectHostCopy) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostCopy) IsExcluded ¶ added in v0.61.0
func (c *CollectHostCopy) IsExcluded() (bool, error)
func (*CollectHostCopy) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostCopy) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostCopy) Title ¶ added in v0.61.0
func (c *CollectHostCopy) Title() string
type CollectHostDNS ¶ added in v0.103.0
type CollectHostDNS struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostDNS) Collect ¶ added in v0.103.0
func (c *CollectHostDNS) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostDNS) IsExcluded ¶ added in v0.103.0
func (c *CollectHostDNS) IsExcluded() (bool, error)
func (*CollectHostDNS) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostDNS) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostDNS) Title ¶ added in v0.103.0
func (c *CollectHostDNS) Title() string
type CollectHostDiskUsage ¶ added in v0.10.8
type CollectHostDiskUsage struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostDiskUsage) Collect ¶ added in v0.10.8
func (c *CollectHostDiskUsage) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostDiskUsage) IsExcluded ¶ added in v0.10.8
func (c *CollectHostDiskUsage) IsExcluded() (bool, error)
func (*CollectHostDiskUsage) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostDiskUsage) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostDiskUsage) Title ¶ added in v0.10.8
func (c *CollectHostDiskUsage) Title() string
type CollectHostFilesystemPerformance ¶ added in v0.10.8
type CollectHostFilesystemPerformance struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostFilesystemPerformance) Collect ¶ added in v0.10.8
func (c *CollectHostFilesystemPerformance) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostFilesystemPerformance) IsExcluded ¶ added in v0.10.8
func (c *CollectHostFilesystemPerformance) IsExcluded() (bool, error)
func (*CollectHostFilesystemPerformance) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostFilesystemPerformance) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostFilesystemPerformance) Title ¶ added in v0.10.8
func (c *CollectHostFilesystemPerformance) Title() string
type CollectHostHTTP ¶ added in v0.10.8
type CollectHostHTTP struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostHTTP) Collect ¶ added in v0.10.8
func (c *CollectHostHTTP) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostHTTP) IsExcluded ¶ added in v0.10.8
func (c *CollectHostHTTP) IsExcluded() (bool, error)
func (*CollectHostHTTP) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostHTTP) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostHTTP) Title ¶ added in v0.10.8
func (c *CollectHostHTTP) Title() string
type CollectHostHTTPLoadBalancer ¶ added in v0.10.8
type CollectHostHTTPLoadBalancer struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostHTTPLoadBalancer) Collect ¶ added in v0.10.8
func (c *CollectHostHTTPLoadBalancer) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostHTTPLoadBalancer) IsExcluded ¶ added in v0.10.8
func (c *CollectHostHTTPLoadBalancer) IsExcluded() (bool, error)
func (*CollectHostHTTPLoadBalancer) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostHTTPLoadBalancer) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostHTTPLoadBalancer) Title ¶ added in v0.10.8
func (c *CollectHostHTTPLoadBalancer) Title() string
type CollectHostIPV4Interfaces ¶ added in v0.10.8
type CollectHostIPV4Interfaces struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostIPV4Interfaces) Collect ¶ added in v0.10.8
func (c *CollectHostIPV4Interfaces) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostIPV4Interfaces) IsExcluded ¶ added in v0.10.8
func (c *CollectHostIPV4Interfaces) IsExcluded() (bool, error)
func (*CollectHostIPV4Interfaces) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostIPV4Interfaces) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostIPV4Interfaces) Title ¶ added in v0.10.8
func (c *CollectHostIPV4Interfaces) Title() string
type CollectHostJournald ¶ added in v0.98.0
type CollectHostJournald struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostJournald) Collect ¶ added in v0.98.0
func (c *CollectHostJournald) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostJournald) IsExcluded ¶ added in v0.98.0
func (c *CollectHostJournald) IsExcluded() (bool, error)
func (*CollectHostJournald) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostJournald) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostJournald) Title ¶ added in v0.98.0
func (c *CollectHostJournald) Title() string
type CollectHostKernelConfigs ¶ added in v0.93.0
type CollectHostKernelConfigs struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostKernelConfigs) Collect ¶ added in v0.93.0
func (c *CollectHostKernelConfigs) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostKernelConfigs) IsExcluded ¶ added in v0.93.0
func (c *CollectHostKernelConfigs) IsExcluded() (bool, error)
func (*CollectHostKernelConfigs) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostKernelConfigs) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostKernelConfigs) Title ¶ added in v0.93.0
func (c *CollectHostKernelConfigs) Title() string
type CollectHostKernelModules ¶ added in v0.15.0
type CollectHostKernelModules struct {
	BundlePath string
	// contains filtered or unexported fields
}
    CollectHostKernelModules is responsible for collecting kernel module status from the host.
func (*CollectHostKernelModules) Collect ¶ added in v0.15.0
func (c *CollectHostKernelModules) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
Collect the kernel module status from the host. Modules are returned as a map keyed on the module name used by the kernel, e.g:
{
  "system/kernel_modules.json": {
    ...
    "dm_snapshot": {
      "instances": 8,
      "size": 45056,
      "status": "loaded"
    },
    ...
  },
}
Module status may be: loaded, loadable, loading, unloading or unknown. When a module is loaded, it may have one or more instances. The size represents the amount of memory (in bytes) that the module is using.
func (*CollectHostKernelModules) IsExcluded ¶ added in v0.15.0
func (c *CollectHostKernelModules) IsExcluded() (bool, error)
IsExcluded returns true if the collector has been excluded from the results.
func (*CollectHostKernelModules) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostKernelModules) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostKernelModules) Title ¶ added in v0.15.0
func (c *CollectHostKernelModules) Title() string
Title is the name of the collector.
type CollectHostMemory ¶ added in v0.10.8
type CollectHostMemory struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostMemory) Collect ¶ added in v0.10.8
func (c *CollectHostMemory) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostMemory) IsExcluded ¶ added in v0.10.8
func (c *CollectHostMemory) IsExcluded() (bool, error)
func (*CollectHostMemory) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostMemory) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostMemory) Title ¶ added in v0.10.8
func (c *CollectHostMemory) Title() string
type CollectHostNetworkNamespaceConnectivity ¶ added in v0.108.0
type CollectHostNetworkNamespaceConnectivity struct {
	BundlePath string
	// contains filtered or unexported fields
}
    CollectHostNetworkNamespaceConnectivity collects information about the capability of the host to route traffic between two different network namespaces. This collector will create two network namespaces and attempt to issue TCP and UDP requests between them.
func (*CollectHostNetworkNamespaceConnectivity) Collect ¶ added in v0.108.0
func (c *CollectHostNetworkNamespaceConnectivity) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
Collect collects the network namespace connectivity information. This function expects both the from and to CIDRs to be provided and different from each other.
func (*CollectHostNetworkNamespaceConnectivity) IsExcluded ¶ added in v0.108.0
func (c *CollectHostNetworkNamespaceConnectivity) IsExcluded() (bool, error)
IsExcluded returns true if the collector should be excluded.
func (*CollectHostNetworkNamespaceConnectivity) Title ¶ added in v0.108.0
func (c *CollectHostNetworkNamespaceConnectivity) Title() string
Title returns the title of the collector.
type CollectHostOS ¶ added in v0.16.0
type CollectHostOS struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostOS) Collect ¶ added in v0.16.0
func (c *CollectHostOS) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostOS) IsExcluded ¶ added in v0.16.0
func (c *CollectHostOS) IsExcluded() (bool, error)
func (*CollectHostOS) Title ¶ added in v0.16.0
func (c *CollectHostOS) Title() string
type CollectHostRun ¶ added in v0.37.0
type CollectHostRun struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostRun) Collect ¶ added in v0.37.0
func (c *CollectHostRun) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostRun) IsExcluded ¶ added in v0.37.0
func (c *CollectHostRun) IsExcluded() (bool, error)
func (*CollectHostRun) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostRun) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostRun) Title ¶ added in v0.37.0
func (c *CollectHostRun) Title() string
type CollectHostServices ¶ added in v0.10.15
type CollectHostServices struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostServices) Collect ¶ added in v0.10.15
func (c *CollectHostServices) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostServices) IsExcluded ¶ added in v0.10.15
func (c *CollectHostServices) IsExcluded() (bool, error)
func (*CollectHostServices) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostServices) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostServices) Title ¶ added in v0.10.15
func (c *CollectHostServices) Title() string
type CollectHostSubnetAvailable ¶ added in v0.59.0
type CollectHostSubnetAvailable struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostSubnetAvailable) Collect ¶ added in v0.59.0
func (c *CollectHostSubnetAvailable) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostSubnetAvailable) IsExcluded ¶ added in v0.59.0
func (c *CollectHostSubnetAvailable) IsExcluded() (bool, error)
func (*CollectHostSubnetAvailable) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostSubnetAvailable) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostSubnetAvailable) Title ¶ added in v0.59.0
func (c *CollectHostSubnetAvailable) Title() string
type CollectHostSysctl ¶ added in v0.108.1
type CollectHostSysctl struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostSysctl) Collect ¶ added in v0.108.1
func (c *CollectHostSysctl) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostSysctl) IsExcluded ¶ added in v0.108.1
func (c *CollectHostSysctl) IsExcluded() (bool, error)
func (*CollectHostSysctl) Title ¶ added in v0.108.1
func (c *CollectHostSysctl) Title() string
type CollectHostSystemPackages ¶ added in v0.24.0
type CollectHostSystemPackages struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostSystemPackages) Collect ¶ added in v0.24.0
func (c *CollectHostSystemPackages) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostSystemPackages) IsExcluded ¶ added in v0.24.0
func (c *CollectHostSystemPackages) IsExcluded() (bool, error)
func (*CollectHostSystemPackages) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostSystemPackages) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostSystemPackages) Title ¶ added in v0.24.0
func (c *CollectHostSystemPackages) Title() string
type CollectHostTCPConnect ¶ added in v0.10.8
type CollectHostTCPConnect struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostTCPConnect) Collect ¶ added in v0.10.8
func (c *CollectHostTCPConnect) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostTCPConnect) IsExcluded ¶ added in v0.10.8
func (c *CollectHostTCPConnect) IsExcluded() (bool, error)
func (*CollectHostTCPConnect) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostTCPConnect) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostTCPConnect) Title ¶ added in v0.10.8
func (c *CollectHostTCPConnect) Title() string
type CollectHostTCPLoadBalancer ¶ added in v0.10.8
type CollectHostTCPLoadBalancer struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostTCPLoadBalancer) Collect ¶ added in v0.10.8
func (c *CollectHostTCPLoadBalancer) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostTCPLoadBalancer) IsExcluded ¶ added in v0.10.8
func (c *CollectHostTCPLoadBalancer) IsExcluded() (bool, error)
func (*CollectHostTCPLoadBalancer) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostTCPLoadBalancer) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostTCPLoadBalancer) Title ¶ added in v0.10.8
func (c *CollectHostTCPLoadBalancer) Title() string
type CollectHostTCPPortStatus ¶ added in v0.10.8
type CollectHostTCPPortStatus struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostTCPPortStatus) Collect ¶ added in v0.10.8
func (c *CollectHostTCPPortStatus) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostTCPPortStatus) IsExcluded ¶ added in v0.10.8
func (c *CollectHostTCPPortStatus) IsExcluded() (bool, error)
func (*CollectHostTCPPortStatus) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostTCPPortStatus) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostTCPPortStatus) Title ¶ added in v0.10.8
func (c *CollectHostTCPPortStatus) Title() string
type CollectHostTime ¶ added in v0.10.8
type CollectHostTime struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostTime) Collect ¶ added in v0.10.8
func (c *CollectHostTime) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostTime) IsExcluded ¶ added in v0.10.8
func (c *CollectHostTime) IsExcluded() (bool, error)
func (*CollectHostTime) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostTime) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostTime) Title ¶ added in v0.10.8
func (c *CollectHostTime) Title() string
type CollectHostUDPPortStatus ¶ added in v0.55.0
type CollectHostUDPPortStatus struct {
	BundlePath string
	// contains filtered or unexported fields
}
    func (*CollectHostUDPPortStatus) Collect ¶ added in v0.55.0
func (c *CollectHostUDPPortStatus) Collect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostUDPPortStatus) IsExcluded ¶ added in v0.55.0
func (c *CollectHostUDPPortStatus) IsExcluded() (bool, error)
func (*CollectHostUDPPortStatus) RemoteCollect ¶ added in v0.104.0
func (c *CollectHostUDPPortStatus) RemoteCollect(progressChan chan<- interface{}) (map[string][]byte, error)
func (*CollectHostUDPPortStatus) Title ¶ added in v0.55.0
func (c *CollectHostUDPPortStatus) Title() string
type CollectImageFacts ¶ added in v0.123.0
type CollectImageFacts struct {
	Collector    *troubleshootv1beta2.Data
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectImageFacts) Collect ¶ added in v0.123.0
func (c *CollectImageFacts) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectImageFacts) IsExcluded ¶ added in v0.123.0
func (c *CollectImageFacts) IsExcluded() (bool, error)
func (*CollectImageFacts) Title ¶ added in v0.123.0
func (c *CollectImageFacts) Title() string
type CollectLogs ¶ added in v0.44.0
type CollectLogs struct {
	Collector    *troubleshootv1beta2.Logs
	BundlePath   string
	Namespace    string // TODO: There is a Namespace parameter in troubleshootv1beta2.Logs. Should we remove this?
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	SinceTime    *time.Time
	RBACErrors
}
    func (*CollectLogs) Collect ¶ added in v0.44.0
func (c *CollectLogs) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectLogs) CollectWithClient ¶ added in v0.54.0
func (c *CollectLogs) CollectWithClient(progressChan chan<- interface{}, client kubernetes.Interface) (CollectorResult, error)
CollectWithClient is a helper function that allows passing in a kubernetes client It's a stopgap implementation before it's decided whether to either always use a single client for collectors or leave the implementation as is. Ref: https://github.com/replicatedhq/troubleshoot/pull/821#discussion_r1026258904
func (*CollectLogs) IsExcluded ¶ added in v0.44.0
func (c *CollectLogs) IsExcluded() (bool, error)
func (*CollectLogs) Title ¶ added in v0.44.0
func (c *CollectLogs) Title() string
type CollectLonghorn ¶ added in v0.44.0
type CollectLonghorn struct {
	Collector    *troubleshootv1beta2.Longhorn
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectLonghorn) Collect ¶ added in v0.44.0
func (c *CollectLonghorn) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectLonghorn) IsExcluded ¶ added in v0.44.0
func (c *CollectLonghorn) IsExcluded() (bool, error)
func (*CollectLonghorn) Title ¶ added in v0.44.0
func (c *CollectLonghorn) Title() string
type CollectMetrics ¶ added in v0.69.0
type CollectMetrics struct {
	Collector    *troubleshootv1beta2.CustomMetrics
	BundlePath   string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectMetrics) Collect ¶ added in v0.69.0
func (c *CollectMetrics) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectMetrics) IsExcluded ¶ added in v0.69.0
func (c *CollectMetrics) IsExcluded() (bool, error)
func (*CollectMetrics) Title ¶ added in v0.69.0
func (c *CollectMetrics) Title() string
type CollectMssql ¶ added in v0.60.0
type CollectMssql struct {
	Collector    *troubleshootv1beta2.Database
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectMssql) Collect ¶ added in v0.60.0
func (c *CollectMssql) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectMssql) IsExcluded ¶ added in v0.60.0
func (c *CollectMssql) IsExcluded() (bool, error)
func (*CollectMssql) Title ¶ added in v0.60.0
func (c *CollectMssql) Title() string
type CollectMysql ¶ added in v0.44.0
type CollectMysql struct {
	Collector    *troubleshootv1beta2.Database
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectMysql) Collect ¶ added in v0.44.0
func (c *CollectMysql) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectMysql) IsExcluded ¶ added in v0.44.0
func (c *CollectMysql) IsExcluded() (bool, error)
func (*CollectMysql) Title ¶ added in v0.44.0
func (c *CollectMysql) Title() string
type CollectNodeMetrics ¶ added in v0.86.0
type CollectNodeMetrics struct {
	Collector    *troubleshootv1beta2.NodeMetrics
	BundlePath   string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectNodeMetrics) Collect ¶ added in v0.86.0
func (c *CollectNodeMetrics) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectNodeMetrics) IsExcluded ¶ added in v0.86.0
func (c *CollectNodeMetrics) IsExcluded() (bool, error)
func (*CollectNodeMetrics) Title ¶ added in v0.86.0
func (c *CollectNodeMetrics) Title() string
type CollectPostgres ¶ added in v0.44.0
type CollectPostgres struct {
	Collector    *troubleshootv1beta2.Database
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectPostgres) Collect ¶ added in v0.44.0
func (c *CollectPostgres) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectPostgres) IsExcluded ¶ added in v0.44.0
func (c *CollectPostgres) IsExcluded() (bool, error)
func (*CollectPostgres) Title ¶ added in v0.44.0
func (c *CollectPostgres) Title() string
type CollectProgress ¶ added in v0.15.0
type CollectRedis ¶ added in v0.44.0
type CollectRedis struct {
	Collector    *troubleshootv1beta2.Database
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectRedis) Collect ¶ added in v0.44.0
func (c *CollectRedis) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectRedis) IsExcluded ¶ added in v0.44.0
func (c *CollectRedis) IsExcluded() (bool, error)
func (*CollectRedis) Title ¶ added in v0.44.0
func (c *CollectRedis) Title() string
type CollectRegistry ¶ added in v0.44.0
type CollectRegistry struct {
	Collector    *troubleshootv1beta2.RegistryImages
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectRegistry) Collect ¶ added in v0.44.0
func (c *CollectRegistry) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectRegistry) IsExcluded ¶ added in v0.44.0
func (c *CollectRegistry) IsExcluded() (bool, error)
func (*CollectRegistry) Title ¶ added in v0.44.0
func (c *CollectRegistry) Title() string
type CollectRun ¶ added in v0.44.0
type CollectRun struct {
	Collector    *troubleshootv1beta2.Run
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectRun) Collect ¶ added in v0.44.0
func (c *CollectRun) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectRun) IsExcluded ¶ added in v0.44.0
func (c *CollectRun) IsExcluded() (bool, error)
func (*CollectRun) Title ¶ added in v0.44.0
func (c *CollectRun) Title() string
type CollectRunDaemonSet ¶ added in v0.83.0
type CollectRunDaemonSet struct {
	Collector    *troubleshootv1beta2.RunDaemonSet
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectRunDaemonSet) Collect ¶ added in v0.83.0
func (c *CollectRunDaemonSet) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectRunDaemonSet) IsExcluded ¶ added in v0.83.0
func (c *CollectRunDaemonSet) IsExcluded() (bool, error)
func (*CollectRunDaemonSet) Title ¶ added in v0.83.0
func (c *CollectRunDaemonSet) Title() string
type CollectRunPod ¶ added in v0.44.0
type CollectRunPod struct {
	Collector    *troubleshootv1beta2.RunPod
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectRunPod) Collect ¶ added in v0.44.0
func (c *CollectRunPod) Collect(progressChan chan<- interface{}) (result CollectorResult, err error)
func (*CollectRunPod) IsExcluded ¶ added in v0.44.0
func (c *CollectRunPod) IsExcluded() (bool, error)
func (*CollectRunPod) Title ¶ added in v0.44.0
func (c *CollectRunPod) Title() string
type CollectSecret ¶ added in v0.44.0
type CollectSecret struct {
	Collector    *troubleshootv1beta2.Secret
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectSecret) Collect ¶ added in v0.44.0
func (c *CollectSecret) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectSecret) IsExcluded ¶ added in v0.44.0
func (c *CollectSecret) IsExcluded() (bool, error)
func (*CollectSecret) Title ¶ added in v0.44.0
func (c *CollectSecret) Title() string
type CollectSonobuoyResults ¶ added in v0.84.0
type CollectSonobuoyResults struct {
	Collector    *troubleshootv1beta2.Sonobuoy
	BundlePath   string
	Namespace    string // this is not used
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectSonobuoyResults) Collect ¶ added in v0.84.0
func (c *CollectSonobuoyResults) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectSonobuoyResults) IsExcluded ¶ added in v0.84.0
func (c *CollectSonobuoyResults) IsExcluded() (bool, error)
func (*CollectSonobuoyResults) Title ¶ added in v0.84.0
func (c *CollectSonobuoyResults) Title() string
type CollectSysctl ¶ added in v0.44.0
type CollectSysctl struct {
	Collector    *troubleshootv1beta2.Sysctl
	BundlePath   string
	Namespace    string
	ClientConfig *rest.Config
	Client       kubernetes.Interface
	Context      context.Context
	RBACErrors
}
    func (*CollectSysctl) Collect ¶ added in v0.44.0
func (c *CollectSysctl) Collect(progressChan chan<- interface{}) (CollectorResult, error)
func (*CollectSysctl) IsExcluded ¶ added in v0.44.0
func (c *CollectSysctl) IsExcluded() (bool, error)
func (*CollectSysctl) Title ¶ added in v0.44.0
func (c *CollectSysctl) Title() string
type Collector ¶
type Collector interface {
	Title() string
	IsExcluded() (bool, error)
	GetRBACErrors() []error
	HasRBACErrors() bool
	CheckRBAC(ctx context.Context, c Collector, collector *troubleshootv1beta2.Collect, clientConfig *rest.Config, namespace string) error
	Collect(progressChan chan<- interface{}) (CollectorResult, error)
}
    func EnsureCopyLast ¶ added in v0.111.0
Ensure Copy collectors are last in the list This is because copy collectors are expected to copy files from other collectors such as Exec, RunPod, RunDaemonSet
type CollectorResult ¶ added in v0.13.15
func CollectorResultFromBundle ¶ added in v0.53.0
func CollectorResultFromBundle(bundleDir string) (CollectorResult, error)
CollectorResultFromBundle creates a CollectorResult from a bundle directory The bundle directory is not necessarily a support bundle, it can be any directory of collected files as part of other operations or files that are already on disk.
func NewResult ¶ added in v0.13.15
func NewResult() CollectorResult
func (CollectorResult) AddResult ¶ added in v0.49.1
func (r CollectorResult) AddResult(other CollectorResult)
AddResult combines another results object into this collector result. This ensures when archiving a bundle from the result, all files are included. It also ensures that when operating on the results in memory (e.g preflights), all files are included.
func (CollectorResult) ArchiveBundle ¶ added in v0.102.0
func (r CollectorResult) ArchiveBundle(bundlePath string, outputFilename string) error
ArchiveBundle creates an archive of the files in the bundle directory
func (CollectorResult) ArchiveSupportBundle ¶ added in v0.53.0
func (r CollectorResult) ArchiveSupportBundle(bundlePath string, outputFilename string) error
ArchiveSupportBundle creates an archive of the files in the bundle directory Deprecated: Use better named ArchiveBundle since this method is used to archive any directory
func (CollectorResult) CloseWriter ¶ added in v0.13.17
func (r CollectorResult) CloseWriter(bundlePath string, relativePath string, writer interface{}) error
func (CollectorResult) GetReader ¶ added in v0.13.15
func (r CollectorResult) GetReader(bundlePath string, relativePath string) (io.ReadCloser, error)
func (CollectorResult) ReplaceResult ¶ added in v0.13.15
func (CollectorResult) SaveResult ¶ added in v0.13.15
SaveResult saves the collector result to relativePath file on disk. If bundlePath is empty, no file is created on disk. The relativePath is always saved in the result map.
func (CollectorResult) SaveResults ¶ added in v0.78.0
func (r CollectorResult) SaveResults(bundlePath, relativePath, targetDir string) error
SaveResults walk a target directory and call SaveResult on all files retrieved from the walk.
func (CollectorResult) SymLinkResult ¶ added in v0.48.0
func (r CollectorResult) SymLinkResult(bundlePath, relativeLinkPath, relativeFilePath string) error
SymLinkResult creates a symlink (relativeLinkPath) of relativeFilePath in the bundle. If bundlePath is empty, no symlink is created. The relativeLinkPath is always saved in the result map.
type CollectorRunOpts ¶ added in v0.15.0
type ConfigMapOutput ¶ added in v0.13.3
type DNSTroubleshootResult ¶ added in v0.101.0
type DNSTroubleshootResult struct {
	KubernetesClusterIP string `json:"kubernetesClusterIP"`
	PodResolvConf       string `json:"podResolvConf"`
	Query               struct {
		Kubernetes struct {
			Name    string `json:"name"`
			Address string `json:"address"`
		} `json:"kubernetes"`
		NonResolvableDomain struct {
			Name    string `json:"name"`
			Address string `json:"address"`
		} `json:"nonResolvableDomain"`
	} `json:"query"`
	KubeDNSPods      []string `json:"kubeDNSPods"`
	KubeDNSService   string   `json:"kubeDNSService"`
	KubeDNSEndpoints string   `json:"kubeDNSEndpoints"`
}
    DNSTroubleshootResult represents the structure of the DNS troubleshooting JSON data
type DatabaseConnection ¶ added in v0.9.27
type DiskUsageInfo ¶ added in v0.10.0
type FSPerfResults ¶ added in v0.10.4
type FSPerfResults struct {
	Min     time.Duration
	Max     time.Duration
	Average time.Duration
	P1      time.Duration
	P5      time.Duration
	P10     time.Duration
	P20     time.Duration
	P30     time.Duration
	P40     time.Duration
	P50     time.Duration
	P60     time.Duration
	P70     time.Duration
	P80     time.Duration
	P90     time.Duration
	P95     time.Duration
	P99     time.Duration
	P995    time.Duration
	P999    time.Duration
	P9995   time.Duration
	P9999   time.Duration
}
    func (FSPerfResults) String ¶ added in v0.10.18
func (f FSPerfResults) String() string
type FakeReader ¶ added in v0.123.0
type FakeReader struct {
	// contains filtered or unexported fields
}
    FakeReader implements io.Reader for in-memory data
type FioDepth ¶ added in v0.73.0
type FioDepth struct {
	FioDepth0    float32 `json:"0,omitempty"`
	FioDepth1    float32 `json:"1,omitempty"`
	FioDepth2    float32 `json:"2,omitempty"`
	FioDepth4    float32 `json:"4,omitempty"`
	FioDepth8    float32 `json:"8,omitempty"`
	FioDepth16   float32 `json:"16,omitempty"`
	FioDepth32   float32 `json:"32,omitempty"`
	FioDepth64   float32 `json:"64,omitempty"`
	FioDepthGE64 float32 `json:">=64,omitempty"`
}
    type FioDiskUtil ¶ added in v0.73.0
type FioDiskUtil struct {
	Name        string  `json:"name,omitempty"`
	ReadIos     int64   `json:"read_ios,omitempty"`
	WriteIos    int64   `json:"write_ios,omitempty"`
	ReadMerges  int64   `json:"read_merges,omitempty"`
	WriteMerges int64   `json:"write_merges,omitempty"`
	ReadTicks   int64   `json:"read_ticks,omitempty"`
	WriteTicks  int64   `json:"write_ticks,omitempty"`
	InQueue     int64   `json:"in_queue,omitempty"`
	Util        float32 `json:"util,omitempty"`
}
    func (FioDiskUtil) String ¶ added in v0.73.0
func (d FioDiskUtil) String() string
type FioGlobalOptions ¶ added in v0.73.0
type FioGlobalOptions struct {
	Directory  string `json:"directory,omitempty"`
	RandRepeat string `json:"randrepeat,omitempty"`
	Verify     string `json:"verify,omitempty"`
	IOEngine   string `json:"ioengine,omitempty"`
	Direct     string `json:"direct,omitempty"`
	GtodReduce string `json:"gtod_reduce,omitempty"`
}
    func (FioGlobalOptions) String ¶ added in v0.73.0
func (g FioGlobalOptions) String() string
type FioJobOptions ¶ added in v0.73.0
type FioJobOptions struct {
	Name      string `json:"name,omitempty"`
	BS        string `json:"bs,omitempty"`
	Directory string `json:"directory,omitempty"`
	RW        string `json:"rw,omitempty"`
	IOEngine  string `json:"ioengine,omitempty"`
	FDataSync string `json:"fdatasync,omitempty"`
	Size      string `json:"size,omitempty"`
	RunTime   string `json:"runtime,omitempty"`
}
    func (FioJobOptions) String ¶ added in v0.73.0
func (o FioJobOptions) String() string
type FioJobs ¶ added in v0.73.0
type FioJobs struct {
	JobName           string        `json:"jobname,omitempty"`
	GroupID           int           `json:"groupid,omitempty"`
	Error             int           `json:"error,omitempty"`
	Eta               int           `json:"eta,omitempty"`
	Elapsed           int           `json:"elapsed,omitempty"`
	JobOptions        FioJobOptions `json:"job options,omitempty"`
	Read              FioStats      `json:"read,omitempty"`
	Write             FioStats      `json:"write,omitempty"`
	Trim              FioStats      `json:"trim,omitempty"`
	Sync              FioStats      `json:"sync,omitempty"`
	JobRuntime        int32         `json:"job_runtime,omitempty"`
	UsrCpu            float32       `json:"usr_cpu,omitempty"`
	SysCpu            float32       `json:"sys_cpu,omitempty"`
	Ctx               int32         `json:"ctx,omitempty"`
	MajF              int32         `json:"majf,omitempty"`
	MinF              int32         `json:"minf,omitempty"`
	IoDepthLevel      FioDepth      `json:"iodepth_level,omitempty"`
	IoDepthSubmit     FioDepth      `json:"iodepth_submit,omitempty"`
	IoDepthComplete   FioDepth      `json:"iodepth_complete,omitempty"`
	LatencyNs         FioLatency    `json:"latency_ns,omitempty"`
	LatencyUs         FioLatency    `json:"latency_us,omitempty"`
	LatencyMs         FioLatency    `json:"latency_ms,omitempty"`
	LatencyDepth      int32         `json:"latency_depth,omitempty"`
	LatencyTarget     int32         `json:"latency_target,omitempty"`
	LatencyPercentile float32       `json:"latency_percentile,omitempty"`
	LatencyWindow     int32         `json:"latency_window,omitempty"`
}
    type FioLatency ¶ added in v0.73.0
type FioLatency struct {
	FioLat2      float32 `json:"2,omitempty"`
	FioLat4      float32 `json:"4,omitempty"`
	FioLat10     float32 `json:"10,omitempty"`
	FioLat20     float32 `json:"20,omitempty"`
	FioLat50     float32 `json:"50,omitempty"`
	FioLat100    float32 `json:"100,omitempty"`
	FioLat250    float32 `json:"250,omitempty"`
	FioLat500    float32 `json:"500,omitempty"`
	FioLat750    float32 `json:"750,omitempty"`
	FioLat1000   float32 `json:"1000,omitempty"`
	FioLat2000   float32 `json:"2000,omitempty"`
	FioLatGE2000 float32 `json:">=2000,omitempty"`
}
    type FioPercentile ¶ added in v0.73.0
type FioPercentile struct {
	P1    int `json:"1.000000,omitempty"`
	P5    int `json:"5.000000,omitempty"`
	P10   int `json:"10.000000,omitempty"`
	P20   int `json:"20.000000,omitempty"`
	P30   int `json:"30.000000,omitempty"`
	P40   int `json:"40.000000,omitempty"`
	P50   int `json:"50.000000,omitempty"`
	P60   int `json:"60.000000,omitempty"`
	P70   int `json:"70.000000,omitempty"`
	P80   int `json:"80.000000,omitempty"`
	P90   int `json:"90.000000,omitempty"`
	P95   int `json:"95.000000,omitempty"`
	P99   int `json:"99.000000,omitempty"`
	P995  int `json:"99.500000,omitempty"`
	P999  int `json:"99.900000,omitempty"`
	P9995 int `json:"99.950000,omitempty"`
	P9999 int `json:"99.990000,omitempty"`
}
    type FioResult ¶ added in v0.73.0
type FioResult struct {
	FioVersion    string           `json:"fio version,omitempty"`
	Timestamp     int64            `json:"timestamp,omitempty"`
	TimestampMS   int64            `json:"timestamp_ms,omitempty"`
	Time          string           `json:"time,omitempty"`
	GlobalOptions FioGlobalOptions `json:"global options,omitempty"`
	Jobs          []FioJobs        `json:"jobs,omitempty"`
	DiskUtil      []FioDiskUtil    `json:"disk_util,omitempty"`
}
    type FioStats ¶ added in v0.73.0
type FioStats struct {
	IOBytes     int64         `json:"io_bytes,omitempty"`
	IOKBytes    int64         `json:"io_kbytes,omitempty"`
	BWBytes     int64         `json:"bw_bytes,omitempty"`
	BW          int64         `json:"bw,omitempty"`
	Iops        float32       `json:"iops,omitempty"`
	Runtime     int64         `json:"runtime,omitempty"`
	TotalIos    int64         `json:"total_ios,omitempty"`
	ShortIos    int64         `json:"short_ios,omitempty"`
	DropIos     int64         `json:"drop_ios,omitempty"`
	SlatNs      FioNS         `json:"slat_ns,omitempty"`
	ClatNs      FioNS         `json:"clat_ns,omitempty"`
	LatNs       FioNS         `json:"lat_ns,omitempty"`
	Percentile  FioPercentile `json:"percentile,omitempty"`
	BwMin       int64         `json:"bw_min,omitempty"`
	BwMax       int64         `json:"bw_max,omitempty"`
	BwAgg       float32       `json:"bw_agg,omitempty"`
	BwMean      float32       `json:"bw_mean,omitempty"`
	BwDev       float32       `json:"bw_dev,omitempty"`
	BwSamples   int32         `json:"bw_samples,omitempty"`
	IopsMin     int32         `json:"iops_min,omitempty"`
	IopsMax     int32         `json:"iops_max,omitempty"`
	IopsMean    float32       `json:"iops_mean,omitempty"`
	IopsStdDev  float32       `json:"iops_stddev,omitempty"`
	IopsSamples int32         `json:"iops_samples,omitempty"`
}
    func (FioStats) FSPerfResults ¶ added in v0.73.0
func (s FioStats) FSPerfResults() FSPerfResults
type HTTPResponse ¶ added in v0.10.2
type HostCertificatesCollection ¶ added in v0.70.0
type HostCertificatesCollection struct {
	CertificatePath  string              `json:"certificatePath,omitempty"`
	CertificateChain []ParsedCertificate `json:"certificateChain,omitempty"`
	Message          string              `json:"message,omitempty"`
}
    func HostCertsParser ¶ added in v0.70.0
func HostCertsParser(certPath string) HostCertificatesCollection
type HostCollectResult ¶ added in v0.15.0
type HostCollectResult struct {
	AllCollectedData map[string][]byte
	Collectors       []HostCollector
	Spec             *troubleshootv1beta2.HostCollector
}
    func CollectHost ¶ added in v0.15.0
func CollectHost(c *troubleshootv1beta2.HostCollector, additionalRedactors *troubleshootv1beta2.Redactor, opts CollectorRunOpts) (*HostCollectResult, error)
CollectHost runs the collection phase for a local collector.
type HostCollector ¶ added in v0.10.0
type HostCollector interface {
	Title() string
	IsExcluded() (bool, error)
	Collect(progressChan chan<- interface{}) (map[string][]byte, error)
}
    func GetHostCollector ¶ added in v0.10.8
func GetHostCollector(collector *troubleshootv1beta2.HostCollect, bundlePath string) (HostCollector, bool)
type HostOSInfo ¶ added in v0.16.0
type HostOSInfoNodes ¶ added in v0.104.0
type HostOSInfoNodes struct {
	Nodes []string `json:"nodes"`
}
    type HostRunInfo ¶ added in v0.37.0
type ImageRunner ¶ added in v0.38.0
type ImageRunner interface {
	GetImage() string
	SetImage(string)
	GetImagePullSecret() *v1beta2.ImagePullSecrets
	SetImagePullSecret(*v1beta2.ImagePullSecrets)
	GetNamespace() string
}
    type KernelModuleInfo ¶ added in v0.15.0
type KernelModuleInfo struct {
	Size      uint64             `json:"size"`
	Instances uint               `json:"instances"`
	Status    KernelModuleStatus `json:"status"`
}
    type KernelModuleStatus ¶ added in v0.15.0
type KernelModuleStatus string
type LoggingTransport ¶ added in v0.107.4
type LoggingTransport struct {
	Transport http.RoundTripper
}
    type MemoryInfo ¶ added in v0.10.0
type MemoryInfo struct {
	Total uint64 `json:"total"`
}
    type MergeableCollector ¶ added in v0.44.0
type NetworkNamespaceConnectivityErrors ¶ added in v0.108.0
type NetworkNamespaceConnectivityErrors struct {
	FromCIDRCreation string `json:"from_cidr_creation"`
	ToCIDRCreation   string `json:"to_cidr_creation"`
	UDPClient        string `json:"udp_client"`
	UDPServer        string `json:"udp_server"`
	TCPClient        string `json:"tcp_client"`
	TCPServer        string `json:"tcp_server"`
}
    NetworkNamespaceConnectivityErrors is a struct that contains the errors that occurred during the network namespace connectivity test
func (NetworkNamespaceConnectivityErrors) Errors ¶ added in v0.108.0
func (e NetworkNamespaceConnectivityErrors) Errors() string
Errors returns a string representation of the errors found during the network namespace connectivity test.
type NetworkNamespaceConnectivityInfo ¶ added in v0.108.0
type NetworkNamespaceConnectivityInfo struct {
	FromCIDR string                             `json:"from_cidr"`
	ToCIDR   string                             `json:"to_cidr"`
	Errors   NetworkNamespaceConnectivityErrors `json:"errors"`
	Output   NetworkNamespaceConnectivityOutput `json:"output"`
	Success  bool                               `json:"success"`
}
    NetworkNamespaceConnectivityInfo is the output of this collector, here we have the logs, the information from the source and destination namespaces, errors and a success flag.
func (*NetworkNamespaceConnectivityInfo) ErrorMessage ¶ added in v0.108.0
func (n *NetworkNamespaceConnectivityInfo) ErrorMessage() string
ErrorMessage returns the error message from the errors field.
type NetworkNamespaceConnectivityOutput ¶ added in v0.108.0
type NetworkNamespaceConnectivityOutput struct {
	Logs []string `json:"logs"`
	// contains filtered or unexported fields
}
    NetworkNamespaceConnectivityOutput is a struct that contains the logs from the network namespace connectivity collector.
func (*NetworkNamespaceConnectivityOutput) Printf ¶ added in v0.108.0
func (l *NetworkNamespaceConnectivityOutput) Printf(format string, v ...interface{})
Printf is a method that allows us to print the logs directly into a slice.
type NetworkStatus ¶ added in v0.10.0
type NetworkStatus string
type NetworkStatusResult ¶ added in v0.10.0
type NetworkStatusResult struct {
	Status  NetworkStatus `json:"status"`
	Message string        `json:"message"`
}
    type ParsedCertificate ¶ added in v0.62.0
type ParsedCertificate struct {
	CertName                string    `json:"certificate"`
	Subject                 string    `json:"subject"`
	SubjectAlternativeNames []string  `json:"subjectAlternativeNames"`
	Issuer                  string    `json:"issuer"`
	NotAfter                time.Time `json:"notAfter"`
	NotBefore               time.Time `json:"notBefore"`
	IsValid                 bool      `json:"isValid"`
	IsCA                    bool      `json:"isCA"`
}
    Certificate Struct
func CertParser ¶ added in v0.62.0
func CertParser(certName string, certs []byte, currentTime time.Time) ([]ParsedCertificate, []string)
Certificate parser
type PodSpecRunner ¶ added in v0.38.0
type PodSpecRunner interface {
	GetPodSpec() corev1.PodSpec
	SetPodSpec(corev1.PodSpec)
	GetImagePullSecret() *v1beta2.ImagePullSecrets
	SetImagePullSecret(*v1beta2.ImagePullSecrets)
	GetNamespace() string
}
    type RBACErrors ¶ added in v0.44.0
type RBACErrors []error
func (*RBACErrors) CheckRBAC ¶ added in v0.44.0
func (e *RBACErrors) CheckRBAC(ctx context.Context, c Collector, collector *troubleshootv1beta2.Collect, clientConfig *rest.Config, namespace string) error
func (RBACErrors) GetRBACErrors ¶ added in v0.44.0
func (e RBACErrors) GetRBACErrors() []error
func (RBACErrors) HasRBACErrors ¶ added in v0.44.0
func (e RBACErrors) HasRBACErrors() bool
type RegistryImage ¶ added in v0.10.16
type RegistryInfo ¶ added in v0.10.16
type RegistryInfo struct {
	Images map[string]RegistryImage `json:"images"`
}
    type ReleaseInfo ¶ added in v0.71.1
type ReleaseInfo struct {
	ReleaseName  string        `json:"releaseName"`
	Chart        string        `json:"chart,omitempty"`
	ChartVersion string        `json:"chartVersion,omitempty"`
	AppVersion   string        `json:"appVersion,omitempty"`
	Namespace    string        `json:"namespace,omitempty"`
	VersionInfo  []VersionInfo `json:"releaseHistory,omitempty"`
}
    Helm release information struct
type RemoteCollectParams ¶ added in v0.106.0
type RemoteCollectParams struct {
	ProgressChan  chan<- interface{}
	HostCollector *troubleshootv1beta2.HostCollect
	BundlePath    string
	ClientConfig  *rest.Config // specify actual type
	Image         string
	PullPolicy    string        // specify actual type if needed
	Timeout       time.Duration // specify duration type if needed
	LabelSelector string
	NamePrefix    string
	Namespace     string
	Title         string
}
    type RemoteCollectResult ¶ added in v0.15.0
type RemoteCollectResult struct {
	AllCollectedData map[string][]byte
	Collectors       RemoteCollectors
	Spec             *troubleshootv1beta2.RemoteCollector
	IsRBACAllowed    bool
}
    func CollectRemote ¶ added in v0.15.0
func CollectRemote(c *troubleshootv1beta2.RemoteCollector, additionalRedactors *troubleshootv1beta2.Redactor, opts CollectorRunOpts) (*RemoteCollectResult, error)
CollectRemote runs the collection phase for a remote collector.
type RemoteCollector ¶ added in v0.15.0
type RemoteCollector struct {
	Collect       *troubleshootv1beta2.RemoteCollect
	Redact        bool
	RBACErrors    []error
	ClientConfig  *rest.Config
	Image         string
	PullPolicy    string
	LabelSelector string
	Namespace     string
	BundlePath    string
	Timeout       time.Duration
	NamePrefix    string
}
    func (*RemoteCollector) CheckRBAC ¶ added in v0.15.0
func (c *RemoteCollector) CheckRBAC(ctx context.Context) error
func (*RemoteCollector) GetDisplayName ¶ added in v0.15.0
func (c *RemoteCollector) GetDisplayName() string
func (*RemoteCollector) IsExcluded ¶ added in v0.15.0
func (c *RemoteCollector) IsExcluded() bool
checks if a given collector has a spec with 'exclude' that evaluates to true.
func (*RemoteCollector) RunCollectorSync ¶ added in v0.15.0
func (c *RemoteCollector) RunCollectorSync(globalRedactors []*troubleshootv1beta2.Redact) (CollectorResult, error)
func (*RemoteCollector) RunRemote ¶ added in v0.15.0
func (c *RemoteCollector) RunRemote(ctx context.Context, runner runner, nodes []string, collector *troubleshootv1beta2.HostCollect, nameGenerator names.NameGenerator, namePrefix string) (map[string][]byte, error)
type RemoteCollectors ¶ added in v0.15.0
type RemoteCollectors []*RemoteCollector
type RunPodOptions ¶ added in v0.14.0
type RunPodOptions struct {
	Image               string
	ImagePullPolicy     string
	Namespace           string
	Command             []string
	ImagePullSecretName string
	HostNetwork         bool
}
    RunPodOptions and RunPodReadyNodes currently only used for the Sysctl collector TODO: refactor sysctl collector and runPod collector to share the same code
type SecretOutput ¶
type ServiceInfo ¶ added in v0.10.15
type SubnetAvailableResult ¶ added in v0.59.0
type SubnetAvailableResult struct {
	CIDRRangeAlloc string `json:"CIDRRangeAlloc"`
	DesiredCIDR    int    `json:"desiredCIDR"`
	// If subnet-available, at least 1 of the DesiredCIDR size is available within CIDRRangeAlloc
	Status SubnetStatus `json:"status"`
}
    type SubnetStatus ¶ added in v0.59.0
type SubnetStatus string
type SystemPackage ¶ added in v0.24.0
type SystemPackagesInfo ¶ added in v0.24.0
type SystemPackagesInfo struct {
	OS        string          `json:"os"`
	OSVersion string          `json:"osVersion"`
	Packages  []SystemPackage `json:"packages"`
}
    
       Source Files
      ¶
      Source Files
      ¶
    
- ceph.go
- certificates.go
- cluster_info.go
- cluster_resources.go
- collect.go
- collectd.go
- collector.go
- configmap.go
- copy.go
- copy_from_host.go
- data.go
- database_shared.go
- dns.go
- etcd.go
- exec.go
- goldpinger.go
- helm.go
- host_block_device.go
- host_certificate.go
- host_certificates_collection.go
- host_cgroup.go
- host_cgroup_linux.go
- host_collector.go
- host_copy.go
- host_cpu.go
- host_disk_usage.go
- host_dns.go
- host_filesystem_performance.go
- host_filesystem_performance_linux.go
- host_http.go
- host_httploadbalancer.go
- host_ipv4interfaces.go
- host_journald.go
- host_kernel_configs.go
- host_kernel_modules.go
- host_memory.go
- host_network.go
- host_network_namespace_connectivity.go
- host_os_info.go
- host_run.go
- host_services.go
- host_subnetavailable.go
- host_sysctl.go
- host_system_package.go
- host_tcp_connect.go
- host_tcploadbalancer.go
- host_tcpportstatus.go
- host_time.go
- host_udpportstatus.go
- http.go
- image_facts.go
- interfaces.go
- k8s_metrics.go
- k8s_node_metrics.go
- load.go
- logs.go
- longhorn.go
- mssql.go
- mysql.go
- postgres.go
- rbac.go
- redact.go
- redis.go
- registry.go
- remote_collector.go
- result.go
- run.go
- run_daemonset.go
- run_pod.go
- runner.go
- secret.go
- sonobuoy_results.go
- sysctl.go
- util.go