Documentation
¶
Index ¶
- Constants
- func ExtractPodWorkloadName(name string) string
- type InputKubernetesMeta
- func (in *InputKubernetesMeta) Collect(collector pipeline.Collector) error
- func (in *InputKubernetesMeta) Description() string
- func (in *InputKubernetesMeta) Init(context pipeline.Context) (int, error)
- func (in *InputKubernetesMeta) InitKruise(cfg *restclient.Config)
- func (in *InputKubernetesMeta) Stop() error
Constants ¶
View Source
const ( Pod = "Pod" Service = "Service" Deployment = "Deployment" DaemonSet = "DaemonSet" StatefulSet = "StatefulSet" Job = "Job" CronJob = "CronJob" Node = "Node" Namespace = "Namespace" PersistentVolume = "PersistentVolume" PersistentVolumeClaim = "PersistentVolumeClaim" StorageClass = "StorageClass" Ingress = "Ingress" Configmap = "ConfigMap" Secret = "Secret" )
The kinds of kubernetes resources.
View Source
const ( KeyName = "name" KeyNamespace = "namespace" KeyCreationTime = "creation_time" KeyPhase = "phase" KeyClusterIP = "cluster_ip" KeyPodIP = "pod_ip" KeyType = "type" KeyPorts = "ports" KeyLoadBalancerIP = "load_balancer_ip" KeyAddresses = "addresses" KeyWorkload = "workload" KeyTaints = "taints" KeyUnschedulable = "unschedulable" KeyRestartCount = "restart_count" KeyHostNetwork = "host_network" KeyContainerName = "container_name" KeyImageName = "image_name" KeyStorageClass = "storage_class" KeyVolume = "volume" KeyVolumeClaim = "volume_claim" KeyCapacity = "request_capacity" KeyStorageDriver = "storage_driver" KeyAccessMode = "access_mode" KeyProvisioner = "provisioner" KeyObservedGeneration = "observed_generation" KeyDesiredReplicas = "desired_replicas" KeyReplicas = "replicas" KeyUpdatedReplicas = "updated_replicas" KeyAvailableReplicas = "available_replicas" KeyStrategy = "strategy" KeyMisscheduledReplicas = "misscheduled_replicas" KeySchedule = "schedule" KeySuspend = "suspend" KeyActiveJobs = "active_jobs" KeyLastScheduleTime = "last_schedule_time" KeyStartTime = "start_time" KeyCompletionTime = "completion_time" KeyActive = "active" KeySucceeded = "succeeded" KeyFailed = "failed" KeyRules = "rules" KeyAllocatableCPU = "allocatable_cpu" KeyAllocatableMem = "allocatable_mem" KeyAllocatableEphemeralStorage = "allocatable_ephemeral_storage" KeyAllocatablePods = "allocatable_pods" KeyAllocatableStorage = "allocatable_storage" KeyKernelVersion = "kernel_version" KeyArchitecture = "architecture" KeyBootID = "boot_id" KeyContainerRuntimeVersion = "container_runtime_version" KeyKubeProxyVersion = "kube_proxy_version" KeyKubeletVersion = "kubelet_version" KeyMachineID = "machine_id" KeyOperatingSystem = "operating_system" KeyOSImage = "os_image" KeySystemUUID = "system_uuid" KeyImmutable = "immutable" KeyResourceVersion = "resource_version" KeyServiceReferenceName = "service_reference_name" KeyServiceReferenceType = "service_reference_type" )
Keys used in meta node.
Variables ¶
This section is empty.
Functions ¶
func ExtractPodWorkloadName ¶ added in v1.0.34
Types ¶
type InputKubernetesMeta ¶
type InputKubernetesMeta struct {
Pod bool
Node bool
Service bool
Deployment bool
DaemonSet bool
StatefulSet bool
Configmap bool
Secret bool
Job bool
CronJob bool
Namespace bool
PersistentVolume bool
PersistentVolumeClaim bool
StorageClass bool
Ingress bool
DisableReportParents bool
KubeConfigPath string
SelectedNamespaces []string
LabelSelectors string
IntervalMs int
EnableOpenKruise bool
Labels map[string]string
// contains filtered or unexported fields
}
func (*InputKubernetesMeta) Collect ¶
func (in *InputKubernetesMeta) Collect(collector pipeline.Collector) error
func (*InputKubernetesMeta) Description ¶
func (in *InputKubernetesMeta) Description() string
func (*InputKubernetesMeta) Init ¶
func (in *InputKubernetesMeta) Init(context pipeline.Context) (int, error)
func (*InputKubernetesMeta) InitKruise ¶ added in v1.6.0
func (in *InputKubernetesMeta) InitKruise(cfg *restclient.Config)
func (*InputKubernetesMeta) Stop ¶
func (in *InputKubernetesMeta) Stop() error
Click to show internal directories.
Click to hide internal directories.