collector

package
v0.0.0-...-3566972 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2024 License: MIT Imports: 37 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DNSCollector 

type DNSCollector struct {
	HostConf      string
	ContainerConf string
	// contains filtered or unexported fields
}

DNSCollector defines a DNS Collector struct

func NewDNSCollector 

func NewDNSCollector(osIdentifier utils.OSIdentifier, filePaths *utils.KnownFilePaths, fileSystem interfaces.FileSystemAccessor) *DNSCollector

NewDNSCollector is a constructor

func (*DNSCollector) CheckSupported 

func (collector *DNSCollector) CheckSupported() error

func (*DNSCollector) Collect 

func (collector *DNSCollector) Collect() error

Collect implements the interface method

func (*DNSCollector) GetData 

func (collector *DNSCollector) GetData() map[string]interfaces.DataValue

func (*DNSCollector) GetName 

func (collector *DNSCollector) GetName() string

type HelmCollector 

type HelmCollector struct {
	// contains filtered or unexported fields
}

HelmCollector defines a Helm Collector struct

func NewHelmCollector 

func NewHelmCollector(config *restclient.Config, runtimeInfo *utils.RuntimeInfo) *HelmCollector

NewHelmCollector is a constructor

func (*HelmCollector) CheckSupported 

func (collector *HelmCollector) CheckSupported() error

func (*HelmCollector) Collect 

func (collector *HelmCollector) Collect() error

Collect implements the interface method

func (*HelmCollector) GetData 

func (collector *HelmCollector) GetData() map[string]interfaces.DataValue

func (*HelmCollector) GetName 

func (collector *HelmCollector) GetName() string

func (*HelmCollector) ToDiscoveryClient 

func (collector *HelmCollector) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error)

func (*HelmCollector) ToRESTConfig 

func (collector *HelmCollector) ToRESTConfig() (*restclient.Config, error)

Implement the RESTClientGetter interface for helm client initialization. This allows us to provide our restclient.Config directly, without having to copy individual fields.

func (*HelmCollector) ToRESTMapper 

func (collector *HelmCollector) ToRESTMapper() (meta.RESTMapper, error)

func (*HelmCollector) ToRawKubeConfigLoader 

func (collector *HelmCollector) ToRawKubeConfigLoader() clientcmd.ClientConfig

type HelmRelease 

type HelmRelease struct {
	Name      string               `json:"name"`
	Namespace string               `json:"namespace"`
	Status    release.Status       `json:"status"`
	ChartName string               `json:"chart"`
	History   []HelmReleaseHistory `json:"history"`
}

type HelmReleaseHistory 

type HelmReleaseHistory struct {
	Date       time.Time      `json:"lastDeployment"`
	Message    string         `json:"description"`
	Status     release.Status `json:"status"`
	Revision   int            `json:"revision"`
	AppVersion string         `json:"appVersion"`
}

type IPTablesCollector 

type IPTablesCollector struct {
	// contains filtered or unexported fields
}

IPTablesCollector defines a IPTables Collector struct

func NewIPTablesCollector 

func NewIPTablesCollector(osIdentifier utils.OSIdentifier, runtimeInfo *utils.RuntimeInfo) *IPTablesCollector

NewIPTablesCollector is a constructor

func (*IPTablesCollector) CheckSupported 

func (collector *IPTablesCollector) CheckSupported() error

func (*IPTablesCollector) Collect 

func (collector *IPTablesCollector) Collect() error

Collect implements the interface method

func (*IPTablesCollector) GetData 

func (collector *IPTablesCollector) GetData() map[string]interfaces.DataValue

func (*IPTablesCollector) GetName 

func (collector *IPTablesCollector) GetName() string

type KubeObjectsCollector 

type KubeObjectsCollector struct {
	// contains filtered or unexported fields
}

KubeObjectsCollector defines a KubeObjects Collector struct

func NewKubeObjectsCollector 

func NewKubeObjectsCollector(config *restclient.Config, runtimeInfo *utils.RuntimeInfo) *KubeObjectsCollector

NewKubeObjectsCollector is a constructor

func (*KubeObjectsCollector) CheckSupported 

func (collector *KubeObjectsCollector) CheckSupported() error

func (*KubeObjectsCollector) Collect 

func (collector *KubeObjectsCollector) Collect() error

Collect implements the interface method

func (*KubeObjectsCollector) GetData 

func (collector *KubeObjectsCollector) GetData() map[string]interfaces.DataValue

func (*KubeObjectsCollector) GetName 

func (collector *KubeObjectsCollector) GetName() string

type KubeletCmdCollector 

type KubeletCmdCollector struct {
	KubeletCommand string
	// contains filtered or unexported fields
}

KubeletCmdCollector defines a KubeletCmd Collector struct

func NewKubeletCmdCollector 

func NewKubeletCmdCollector(osIdentifier utils.OSIdentifier, runtimeInfo *utils.RuntimeInfo) *KubeletCmdCollector

NewKubeletCmdCollector is a constructor

func (*KubeletCmdCollector) CheckSupported 

func (collector *KubeletCmdCollector) CheckSupported() error

func (*KubeletCmdCollector) Collect 

func (collector *KubeletCmdCollector) Collect() error

Collect implements the interface method

func (*KubeletCmdCollector) GetData 

func (collector *KubeletCmdCollector) GetData() map[string]interfaces.DataValue

func (*KubeletCmdCollector) GetName 

func (collector *KubeletCmdCollector) GetName() string

type NetworkOutboundCollector 

type NetworkOutboundCollector struct {
	// contains filtered or unexported fields
}

NetworkOutboundCollector defines a NetworkOutbound Collector struct

func NewNetworkOutboundCollector 

func NewNetworkOutboundCollector() *NetworkOutboundCollector

NewNetworkOutboundCollector is a constructor

func (*NetworkOutboundCollector) CheckSupported 

func (collector *NetworkOutboundCollector) CheckSupported() error

func (*NetworkOutboundCollector) Collect 

func (collector *NetworkOutboundCollector) Collect() error

Collect implements the interface method

func (*NetworkOutboundCollector) GetData 

func (collector *NetworkOutboundCollector) GetData() map[string]interfaces.DataValue

func (*NetworkOutboundCollector) GetName 

func (collector *NetworkOutboundCollector) GetName() string

type NetworkOutboundDatum 

type NetworkOutboundDatum struct {
	TimeStamp time.Time `json:"TimeStamp"`

	Status string `json:"Status"`
	// contains filtered or unexported fields
}

NetworkOutboundDatum defines a NetworkOutbound Datum

type NodeLogsCollector 

type NodeLogsCollector struct {
	// contains filtered or unexported fields
}

NodeLogsCollector defines a NodeLogs Collector struct

func NewNodeLogsCollector 

func NewNodeLogsCollector(runtimeInfo *utils.RuntimeInfo, fileSystem interfaces.FileSystemAccessor) *NodeLogsCollector

NewNodeLogsCollector is a constructor

func (*NodeLogsCollector) CheckSupported 

func (collector *NodeLogsCollector) CheckSupported() error

func (*NodeLogsCollector) Collect 

func (collector *NodeLogsCollector) Collect() error

Collect implements the interface method

func (*NodeLogsCollector) GetData 

func (collector *NodeLogsCollector) GetData() map[string]interfaces.DataValue

func (*NodeLogsCollector) GetName 

func (collector *NodeLogsCollector) GetName() string

type NodeMetrics 

type NodeMetrics struct {
	NodeName    string `json:"name"`
	CPUUsage    int64  `json:"cpuUsage"`
	MemoryUsage int64  `json:"memoryUsage"`
}

type OsmCollector 

type OsmCollector struct {
	// contains filtered or unexported fields
}

OsmCollector defines an OSM Collector struct

func NewOsmCollector 

func NewOsmCollector(config *rest.Config, runtimeInfo *utils.RuntimeInfo) *OsmCollector

NewOsmCollector is a constructor

func (*OsmCollector) CheckSupported 

func (collector *OsmCollector) CheckSupported() error

func (*OsmCollector) Collect 

func (collector *OsmCollector) Collect() error

Collect implements the interface method

func (*OsmCollector) GetData 

func (collector *OsmCollector) GetData() map[string]interfaces.DataValue

func (*OsmCollector) GetName 

func (collector *OsmCollector) GetName() string

type PDBCollector 

type PDBCollector struct {
	// contains filtered or unexported fields
}

PDBCollector defines a Pod disruption Budget Collector struct

func NewPDBCollector 

func NewPDBCollector(config *restclient.Config, runtimeInfo *utils.RuntimeInfo) *PDBCollector

NewPDBCollector is a constructor

func (*PDBCollector) CheckSupported 

func (collector *PDBCollector) CheckSupported() error

func (*PDBCollector) Collect 

func (collector *PDBCollector) Collect() error

Collect implements the interface method

func (*PDBCollector) GetData 

func (collector *PDBCollector) GetData() map[string]interfaces.DataValue

func (*PDBCollector) GetName 

func (collector *PDBCollector) GetName() string

type PDBInfo 

type PDBInfo struct {
	Name               string `json:"name"`
	MinAvailable       string `json:"minavailable"`
	MaxUnavailable     string `json:"maxunavailable"`
	DisruptionsAllowed int32  `json:"disruptionsallowed"`
}

type PodMetrics 

type PodMetrics struct {
	ContainerName string `json:"name"`
	CPUUsage      int64  `json:"cpuUsage"`
	MemoryUsage   int64  `json:"memoryUsage"`
}

type PodsContainerLogsCollector 

type PodsContainerLogsCollector struct {
	// contains filtered or unexported fields
}

PodsContainerLogsCollector defines a Pods Container Logs Collector struct

func NewPodsContainerLogsCollector 

func NewPodsContainerLogsCollector(config *restclient.Config, runtimeInfo *utils.RuntimeInfo) *PodsContainerLogsCollector

NewPodsContainerLogs is a constructor

func (*PodsContainerLogsCollector) CheckSupported 

func (collector *PodsContainerLogsCollector) CheckSupported() error

func (*PodsContainerLogsCollector) Collect 

func (collector *PodsContainerLogsCollector) Collect() error

Collect implements the interface method

func (*PodsContainerLogsCollector) GetData 

func (collector *PodsContainerLogsCollector) GetData() map[string]interfaces.DataValue

func (*PodsContainerLogsCollector) GetName 

func (collector *PodsContainerLogsCollector) GetName() string

type PodsContainerStruct 

type PodsContainerStruct struct {
	Name          string        `json:"name"`
	Ready         string        `json:"ready"`
	Status        string        `json:"status"`
	Restart       int32         `json:"restart"`
	Age           time.Duration `json:"age"`
	ContainerName string        `json:"containerName"`
	ContainerLog  string        `json:"containerLog"`
}

type SmiCollector 

type SmiCollector struct {
	// contains filtered or unexported fields
}

SmiCollector defines an Smi Collector struct

func NewSmiCollector 

func NewSmiCollector(config *rest.Config, runtimeInfo *utils.RuntimeInfo) *SmiCollector

NewSmiCollector is a constructor

func (*SmiCollector) CheckSupported 

func (collector *SmiCollector) CheckSupported() error

func (*SmiCollector) Collect 

func (collector *SmiCollector) Collect() error

Collect implements the interface method

func (*SmiCollector) GetData 

func (collector *SmiCollector) GetData() map[string]interfaces.DataValue

func (*SmiCollector) GetName 

func (collector *SmiCollector) GetName() string

type SystemLogsCollector 

type SystemLogsCollector struct {
	// contains filtered or unexported fields
}

SystemLogsCollector defines a SystemLogs Collector struct

func NewSystemLogsCollector 

func NewSystemLogsCollector(osIdentifier utils.OSIdentifier, runtimeInfo *utils.RuntimeInfo) *SystemLogsCollector

NewSystemLogsCollector is a constructor

func (*SystemLogsCollector) CheckSupported 

func (collector *SystemLogsCollector) CheckSupported() error

func (*SystemLogsCollector) Collect 

func (collector *SystemLogsCollector) Collect() error

Collect implements the interface method

func (*SystemLogsCollector) GetData 

func (collector *SystemLogsCollector) GetData() map[string]interfaces.DataValue

func (*SystemLogsCollector) GetName 

func (collector *SystemLogsCollector) GetName() string

type SystemPerfCollector 

type SystemPerfCollector struct {
	// contains filtered or unexported fields
}

SystemPerfCollector defines a SystemPerf Collector struct

func NewSystemPerfCollector 

func NewSystemPerfCollector(config *restclient.Config, runtimeInfo *utils.RuntimeInfo) *SystemPerfCollector

NewSystemPerfCollector is a constructor

func (*SystemPerfCollector) CheckSupported 

func (collector *SystemPerfCollector) CheckSupported() error

func (*SystemPerfCollector) Collect 

func (collector *SystemPerfCollector) Collect() error

Collect implements the interface method

func (*SystemPerfCollector) GetData 

func (collector *SystemPerfCollector) GetData() map[string]interfaces.DataValue

func (*SystemPerfCollector) GetName 

func (collector *SystemPerfCollector) GetName() string

type WindowsLogsCollector 

type WindowsLogsCollector struct {
	// contains filtered or unexported fields
}

func NewWindowsLogsCollector 

func NewWindowsLogsCollector(osIdentifier utils.OSIdentifier, runtimeInfo *utils.RuntimeInfo, filePaths *utils.KnownFilePaths, fileSystem interfaces.FileSystemAccessor, pollInterval, timeout time.Duration) *WindowsLogsCollector

func (*WindowsLogsCollector) CheckSupported 

func (collector *WindowsLogsCollector) CheckSupported() error

func (*WindowsLogsCollector) Collect 

func (collector *WindowsLogsCollector) Collect() error

Collect implements the interface method

func (*WindowsLogsCollector) GetData 

func (collector *WindowsLogsCollector) GetData() map[string]interfaces.DataValue

func (*WindowsLogsCollector) GetName 

func (collector *WindowsLogsCollector) GetName() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.