Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -27,12 +27,11 @@ const InspectionTypeID = "gcp-composer"

// ComposerInspectionType is the inspection type for google cloud composer.
var ComposerInspectionType = coreinspection.InspectionType{
Id: InspectionTypeID,
Name: "Cloud Composer",
Description: `Visualize logs related to Cloud Composer environment.
Supports all GKE related logs(Cloud Composer v2) and Airflow logs(Airflow 2.0.0 or higher in any Cloud Composer version(v1-v2, partical v3))`,
Icon: "assets/icons/composer.webp",
Priority: math.MaxInt - 10,
Id: InspectionTypeID,
Name: "Cloud Composer",
Description: "Gather and parse Cloud Composer environment logs (supporting GKE logs in Cloud Composer v2 and Apache Airflow logs (version 2.0.0 or higher) in any Composer version) to visualize environment operations on timelines.",
Icon: "assets/icons/composer.webp",
Priority: math.MaxInt - 10,
Labels: map[string]string{
inspectioncore_contract.InspectionTypeLabelKeyLogSource: "cloud_logging",
inspectioncore_contract.InspectionTypeLabelKeyEnvironment: "googlecloud",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -171,7 +171,7 @@ var AirflowOtherLogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMap
&otherLogToTimelineMapper{},
inspectioncore_contract.FeatureTaskLabelV2(
"Airflow Other Components Logs",
"Timeline mapping for other components' logs under Apache Airflow.",
"Gather logs from other Apache Airflow components to map and visualize their activities on timelines.",
1505,
false,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -167,7 +167,7 @@ var AirflowSchedulerLogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelin
&schedulerLogToTimelineMapper{},
inspectioncore_contract.FeatureTaskLabelV2(
"Airflow Scheduler Logs",
"Timeline mapping for scheduler logs under Apache Airflow.",
"Gather Apache Airflow scheduler logs to visualize DAG scheduling decisions and latency on resource timelines.",
1501,
false,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ var ComposerLogsTailTask = coretask.NewTask(
},
inspectioncore_contract.FeatureTaskLabelV2(
"Composer Logs",
"Cloud Composer related logs like airflow-worker, airflow-scheduler, airflow-dag-processor-manager, and others.",
"Gather Cloud Composer logs, including airflow-worker, airflow-scheduler, and airflow-dag-processor-manager, to visualize general environment operations on timelines.",
101000,
true,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -162,7 +162,7 @@ var AirflowWorkerLogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMa
&workerLogToTimelineMapper{},
inspectioncore_contract.FeatureTaskLabelV2(
"Airflow Worker Logs",
"Timeline mapping for worker logs under Apache Airflow.",
"Gather Apache Airflow worker logs to visualize task execution progress and errors on resource timelines.",
1502,
false,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,14 +27,11 @@ const InspectionTypeID = "gcp-gdcv-for-baremetal"

// GDCVForBaremetalInspectionType defines the inspection type for GDCV for Baremetal.
var GDCVForBaremetalInspectionType = coreinspection.InspectionType{
Id: InspectionTypeID,
Name: "GDCV for Baremetal (GKE on Baremetal, Anthos on Baremetal)",
Description: `Visualize logs generated from GDCV for baremetal cluster (including user, admin, hybrid, or standalone clusters).
Supporting K8s audit log, K8s event log, K8s node log, K8s container log and OnPrem API audit log.

This type can also be used for GCDE or GDCH.`,
Icon: "assets/icons/anthos.png",
Priority: math.MaxInt - 3,
Id: InspectionTypeID,
Name: "GDCV for Baremetal (GKE on Baremetal, Anthos on Baremetal)",
Description: `Gather and parse Google Distributed Cloud Virtual (GDCV) for Baremetal cluster logs (including user, admin, hybrid, or standalone clusters; Kubernetes audit, event, node, container, and On-Premises API audit logs) to visualize cluster operations on timelines. This type also supports GCDE and GDCH clusters.`,
Icon: "assets/icons/anthos.png",
Priority: math.MaxInt - 3,
Labels: map[string]string{
inspectioncore_contract.InspectionTypeLabelKeyLogSource: "cloud_logging",
inspectioncore_contract.InspectionTypeLabelKeyEnvironment: "googlecloud",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,12 +27,11 @@ const InspectionTypeID = "gcp-gdcv-for-vmware"

// GDCVForVMWareInspectionType defines the inspection type for GDCV for VMWare.
var GDCVForVMWareInspectionType = coreinspection.InspectionType{
Id: InspectionTypeID,
Name: "GDCV for VMWare (GKE on VMWare, Anthos on VMWare)",
Description: `Visualize logs generated from GDCV for VMWare cluster (including admin cluster/user cluster).
Supporting K8s audit log, K8s event log, K8s node log, K8s container log and OnPrem API audit log.`,
Icon: "assets/icons/anthos.png",
Priority: math.MaxInt - 4,
Id: InspectionTypeID,
Name: "GDCV for VMware (GKE on VMware, Anthos on VMware)",
Description: `Gather and parse Google Distributed Cloud Virtual (GDCV) for VMware cluster logs (including admin and user clusters; Kubernetes audit, event, node, container, and On-Premises API audit logs) to visualize cluster operations on timelines.`,
Icon: "assets/icons/anthos.png",
Priority: math.MaxInt - 4,
Labels: map[string]string{
inspectioncore_contract.InspectionTypeLabelKeyLogSource: "cloud_logging",
inspectioncore_contract.InspectionTypeLabelKeyEnvironment: "googlecloud",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,12 +27,11 @@ const InspectionTypeID = "gcp-gke"

// GKEInspectionType defines the inspection type for Google Kubernetes Engine.
var GKEInspectionType = coreinspection.InspectionType{
Id: InspectionTypeID,
Name: "Google Kubernetes Engine",
Description: `Visualize logs generated from GKE cluster.
Supporting K8s audit log, K8s event log,K8s node log, K8s container log, GCE audit log, Networking audit log(NEG attach/detach) and autoscaler log.`,
Icon: "assets/icons/gke.png",
Priority: math.MaxInt,
Id: InspectionTypeID,
Name: "Google Kubernetes Engine",
Description: `Gather and parse Google Kubernetes Engine (GKE) cluster logs (Kubernetes audit, event, node, container, GCE audit, Network, and Cluster Autoscaler logs) to visualize cluster operations on timelines.`,
Icon: "assets/icons/gke.png",
Priority: math.MaxInt,
Labels: map[string]string{
inspectioncore_contract.InspectionTypeLabelKeyLogSource: "cloud_logging",
inspectioncore_contract.InspectionTypeLabelKeyEnvironment: "googlecloud",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,12 +27,11 @@ const InspectionTypeID = "gcp-gke-on-aws"

// AnthosOnAWSInspectionType defines the inspection type for GKE on AWS.
var AnthosOnAWSInspectionType = coreinspection.InspectionType{
Id: InspectionTypeID,
Name: "GKE on AWS(Anthos on AWS)",
Description: `Visualize logs generated from GKE on AWS cluster.
Supporting K8s audit log, k8s event log, k8s node log, k8s container log and MultiCloud API audit log.`,
Icon: "assets/icons/anthos.png",
Priority: math.MaxInt - 2,
Id: InspectionTypeID,
Name: "GKE on AWS (Anthos on AWS)",
Description: `Gather and parse GKE on AWS cluster logs (Kubernetes audit, event, node, container logs, and Multi-Cloud API audit logs) to visualize cluster operations on timelines.`,
Icon: "assets/icons/anthos.png",
Priority: math.MaxInt - 2,
Labels: map[string]string{
inspectioncore_contract.InspectionTypeLabelKeyLogSource: "cloud_logging",
inspectioncore_contract.InspectionTypeLabelKeyEnvironment: "googlecloud",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,12 +27,11 @@ const InspectionTypeID = "gcp-gke-on-azure"

// AnthosOnAzureInspectionType defines the inspection type for GKE on Azure.
var AnthosOnAzureInspectionType = coreinspection.InspectionType{
Id: InspectionTypeID,
Name: "GKE on Azure(Anthos on Azure)",
Description: `Visualize logs generated from GKE on Azure cluster.
Supporting K8s audit log, k8s event log, k8s node log, k8s container log and MultiCloud API audit log.`,
Icon: "assets/icons/anthos.png",
Priority: math.MaxInt - 3,
Id: InspectionTypeID,
Name: "GKE on Azure (Anthos on Azure)",
Description: `Gather and parse GKE on Azure cluster logs (Kubernetes audit, event, node, container logs, and Multi-Cloud API audit logs) to visualize cluster operations on timelines.`,
Icon: "assets/icons/anthos.png",
Priority: math.MaxInt - 3,
Labels: map[string]string{
inspectioncore_contract.InspectionTypeLabelKeyLogSource: "cloud_logging",
inspectioncore_contract.InspectionTypeLabelKeyEnvironment: "googlecloud",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,8 +51,8 @@ var LogGrouperTask = inspectiontaskbase.NewLogGrouperTask(googlecloudlogcomputea

// LogToTimelineMapperTask maps GCE API audit logs to timeline events and revisions in parallel.
var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTaskV2[struct{}](googlecloudlogcomputeapiaudit_contract.LogToTimelineMapperTaskID, &gcpComputeAuditLogLogToTimelineMapperSetting{},
inspectioncore_contract.FeatureTaskLabelV2(`Compute API Logs`,
`Gather Compute API audit logs to show the timings of the provisioning of resources(e.g creating/deleting GCE VM,mounting Persistent Disk...etc) on associated timelines.`,
inspectioncore_contract.FeatureTaskLabelV2("Compute API Logs",
"Gather Compute API audit logs to visualize the provisioning of infrastructure resources (e.g., GCE VM creation/deletion, Persistent Disk mounting) on associated timelines.",
6000,
true,
),
Expand Down
4 changes: 2 additions & 2 deletions pkg/task/inspection/googlecloudlogcsm/impl/parser_task.go
Original file line number Diff line number Diff line change
Expand Up @@ -162,8 +162,8 @@ var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTaskV2(
googlecloudlogcsm_contract.LogToTimelineMapperTaskID,
&CSMAccessLogLogToTimelineMapper{},
inspectioncore_contract.FeatureTaskLabelV2(
"CSM Access Log",
"Gather CSM access logs from Cloud Logging and associate them in client or server Pods on timelines",
"CSM Access Logs",
"Gather CSM access logs to visualize network traffic flows and latency under client or server Pod timelines.",
10000,
false,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -232,7 +232,7 @@ var CSMTrafficDirectorLogToTimelineMapperTask = inspectiontaskbase.NewLogToTimel
&CSMTrafficDirectorLogToTimelineMapper{},
inspectioncore_contract.FeatureTaskLabelV2(
"CSM Resource Audit Logs",
"Gather audit logs related to TrafficDirector resources created by the TD based CSM. Map them into pseudo timelines with other Kubernetes logs.",
"Gather audit logs for Traffic Director resources created by the TD-based CSM to map them to timelines alongside associated Kubernetes resource logs.",
10100,
false,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -104,8 +104,8 @@ var LogGrouperTask = inspectiontaskbase.NewLogGrouperTask(googlecloudloggkeapiau

// LogToTimelineMapperTask is a task that maps GKE audit logs to timeline elements.
var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTaskV2[struct{}](googlecloudloggkeapiaudit_contract.LogToTimelineMapperTaskID, &gkeAuditLogLogToTimelineMapperSetting{},
inspectioncore_contract.FeatureTaskLabelV2(`GKE Audit logs`,
`Gather GKE audit log to show creation/upgrade/deletion of cluster/nodepool`,
inspectioncore_contract.FeatureTaskLabelV2(`GKE Audit Logs`,
`Gather GKE audit logs to visualize the creation, upgrade, and deletion of clusters and node pools on timelines.`,
5000,
true),
)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -158,7 +158,7 @@ var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTaskV2(
&autoscalerTimelineMapper{},
inspectioncore_contract.FeatureTaskLabelV2(
`GKE Autoscaler Logs`,
`Gather logs related to cluster autoscaler behavior to show them on the timelines of resources related to the autoscaler decision.`,
`Gather Cluster Autoscaler logs to visualize autoscaling decisions and actions on the timelines of the affected resources.`,
8000,
true,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -57,5 +57,5 @@ var GCPK8sAuditLogParserTailTask = inspectiontaskbase.NewInspectionTask(
func(ctx context.Context, taskMode inspectioncore_contract.InspectionTaskModeType) (struct{}, error) {
return struct{}{}, nil
},
inspectioncore_contract.FeatureTaskLabelV2("Kubernetes Audit Log(v3)", `Gather kubernetes audit logs and visualize resource modifications.`, 1001, true), coretask.NewSubsequentTaskRefsTaskLabel(inspectioncore_contract.SerializerTaskID.Ref()),
inspectioncore_contract.FeatureTaskLabelV2("Kubernetes Audit Logs", `Gather Kubernetes audit logs to visualize resource modifications and API call histories on associated timelines.`, 1001, true), coretask.NewSubsequentTaskRefsTaskLabel(inspectioncore_contract.SerializerTaskID.Ref()),
)
Original file line number Diff line number Diff line change
Expand Up @@ -148,8 +148,8 @@ var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTaskV2[st
googlecloudlogk8scontainer_contract.LogToTimelineMapperTaskID,
&containerLogLogToTimelineMapper{},
inspectioncore_contract.FeatureTaskLabelV2(
"Kubernetes container logs",
"Gather stdout/stderr logs of containers on the cluster to visualize them on the timeline under an associated Pod. Log volume can be huge when the cluster has many Pods.",
"Kubernetes Container Logs",
"Gather stdout/stderr logs of containers to visualize application runtime behaviors under associated Pod timelines. Note: The log volume can be very large if the cluster contains many Pods.",
4000,
false,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,8 +35,8 @@ var TailTask = inspectiontaskbase.NewInspectionTask(googlecloudlogk8scontrolplan
return struct{}{}, nil
},
inspectioncore_contract.FeatureTaskLabelV2(
"Kubernetes Control plane component logs",
"Gather Kubernetes control plane component(e.g kube-scheduler, kube-controller-manager,api-server) logs",
"Kubernetes Control Plane Component Logs",
"Gather logs from Kubernetes control plane components (e.g., kube-scheduler, kube-controller-manager, and kube-apiserver) to troubleshoot control plane behavior.",
9000,
false,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTaskV2(
&KubernetesEventTimelineMapper{},
inspectioncore_contract.FeatureTaskLabelV2(
"Kubernetes Event Logs",
"Gather kubernetes event logs and visualize these on the associated resource timeline.",
"Gather Kubernetes event logs to visualize cluster events on associated resource timelines.",
2000,
true,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -197,7 +197,7 @@ var TailTask = inspectiontaskbase.NewInspectionTask(googlecloudlogk8snode_contra
},
inspectioncore_contract.FeatureTaskLabelV2(
"Kubernetes Node Logs",
"Gather node components(e.g docker/container) logs. Log volume can be huge when the cluster has many nodes.",
"Gather logs from Kubernetes node components (e.g., Docker, containerd, or Kubelet) to troubleshoot node-level issues. Note: The log volume can be very large if the cluster contains many nodes.",
3000,
false,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -245,8 +245,8 @@ var _ inspectiontaskbase.LogToTimelineMapperV2[struct{}] = (*multicloudAuditLogL
var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTaskV2(
googlecloudlogmulticloudapiaudit_contract.LogToTimelineMapperTaskID,
&multicloudAuditLogLogToTimelineMapperSetting{},
inspectioncore_contract.FeatureTaskLabelV2(`MultiCloud API logs`,
`Gather Anthos MultiCloud audit log including cluster creation, deletion and upgrades.`,
inspectioncore_contract.FeatureTaskLabelV2(`Multi-Cloud API Logs`,
`Gather Anthos Multi-Cloud audit logs to visualize cluster lifecycle events (creation, deletion, and upgrades) on timelines.`,
5000,
true,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -277,7 +277,7 @@ var _ inspectiontaskbase.LogToTimelineMapperV2[*perNEGHistoryModificationStatus]
// LogToTimelineMapperTask registers the mapper to resolve network status in timeline.
var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTaskV2(googlecloudlognetworkapiaudit_contract.LogToTimelineMapperTaskID, &networkAPITimelineMapper{},
inspectioncore_contract.FeatureTaskLabelV2(`GCE Network Logs`,
`Gather GCE Network API logs to visualize statuses of Network Endpoint Groups(NEG)`,
`Gather GCE Network API logs to visualize the provisioning and status transitions of Network Endpoint Groups (NEGs) on timelines.`,
7000,
true,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -252,8 +252,8 @@ var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTaskV2(
googlecloudlogonpremapiaudit_contract.LogToTimelineMapperTaskID,
&OnPremAPIAuditTimelineMapper{},
inspectioncore_contract.FeatureTaskLabelV2(
"OnPrem API logs",
"Gather Anthos OnPrem audit log including cluster creation,deletion,enroll,unenroll and upgrades.",
"On-Premises API Logs",
"Gather Anthos On-Premises audit logs to visualize cluster lifecycle events (creation, deletion, enrollment, unenrollment, and upgrades) on timelines.",
9500,
true,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -156,8 +156,8 @@ var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTaskV2(
googlecloudlogserialport_contract.LogToTimelineMapperTaskID,
&serialportLogToTimelineMapper{},
inspectioncore_contract.FeatureTaskLabelV2(
"GCE Node Serialport log",
`Serialport logs from GCE instances. This helps detailed investigation on VM bootstrapping issue on GCE instance.`,
"GCE Node Serial Port Logs",
`Gather serial port logs from GCE instances to troubleshoot VM bootstrapping and OS initialization issues.`,
10000,
false,
),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ const InspectionTypeID = "oss-kubernetes-from-files"
var OSSKubernetesLogFilesInspectionType = coreinspection.InspectionType{
Id: InspectionTypeID,
Name: "OSS Kubernetes Log Files",
Description: "Visualize OSS Kubernetes logs through the uploaded files",
Description: "Parse uploaded OSS Kubernetes log files to visualize cluster operations on timelines.",
Icon: "assets/icons/k8s.png",
Priority: math.MaxInt - 1000,
Labels: map[string]string{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,5 +52,5 @@ var OSSK8sAuditLogParserTailTask = inspectiontaskbase.NewInspectionTask(
func(ctx context.Context, taskMode inspectioncore_contract.InspectionTaskModeType) (struct{}, error) {
return struct{}{}, nil
},
inspectioncore_contract.FeatureTaskLabelV2("Kubernetes Audit Log(v3)", `Gather kubernetes audit logs and visualize resource modifications.`, 1001, true), coretask.NewSubsequentTaskRefsTaskLabel(inspectioncore_contract.SerializerTaskID.Ref()),
inspectioncore_contract.FeatureTaskLabelV2("Kubernetes Audit Logs", `Gather Kubernetes audit logs to visualize resource modifications and API call histories on associated timelines.`, 1001, true), coretask.NewSubsequentTaskRefsTaskLabel(inspectioncore_contract.SerializerTaskID.Ref()),
)
Original file line number Diff line number Diff line change
Expand Up @@ -135,8 +135,8 @@ var OSSK8sEventLogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapp
ossclusterk8s_contract.OSSK8sEventLogToTimelineMapperTaskID,
&OSSK8sEventTimelineMapper{},
inspectioncore_contract.FeatureTaskLabelV2(
"OSS Kubernetes Event logs from JSONL audit log",
"The event log parser for OSS kubernetes from the audit log",
"OSS Kubernetes Event Logs",
"Gather and parse Kubernetes event logs from OSS Kubernetes JSONL audit logs to visualize resource lifecycle and operational events.",
2000,
true,
),
Expand Down
Loading