Documentation
¶
Overview ¶
Package googlecloudlogcomputeapiaudit_impl defines the implementation of the googlecloudlogcomputeapiaudit task.
Package googlecloudlogcomputeapiaudit_impl defines the implementation of the googlecloudlogcomputeapiaudit task.
Index ¶
- Variables
- func GenerateComputeAPIQuery(taskMode inspectioncore_contract.InspectionTaskModeType, nodeNames []string) []string
- func GenerateComputeAPIStructuredQuery(taskMode inspectioncore_contract.InspectionTaskModeType, nodeNames []string) []*logestimator.StructuredLogQuery
- func Register(registry coreinspection.InspectionTaskRegistry) error
Constants ¶
This section is empty.
Variables ¶
var ClusterIdentityAliasTask = coretask.NewAliasTask( googlecloudlogcomputeapiaudit_contract.ClusterIdentityTaskID, googlecloudk8scommon_contract.ClusterIdentityTaskID.Ref(), )
var ListLogEntriesTask = googlecloudcommon_contract.NewStructuredListLogEntriesTask(&computeAPIListLogEntriesTaskSetting{})
var LogGrouperTask = inspectiontaskbase.NewLogGrouperTask(googlecloudlogcomputeapiaudit_contract.LogGrouperTaskID, googlecloudlogcomputeapiaudit_contract.ListLogEntriesTaskID.Ref(), func(ctx context.Context, l *log.Log) string { audit, err := googlecloudcommon_contract.ExtractGCPAuditLog(l.NodeReader) if err != nil { return "unknown" } return getInstanceNameFromResourceName(audit.ResourceName) })
LogGrouperTask groups GCE API audit logs by node resource name for parallel mapper processing.
var LogIngesterTask = googlecloudcommon_contract.NewGCPOperationLogIngesterTask( googlecloudlogcomputeapiaudit_contract.LogIngesterTaskID, googlecloudlogcomputeapiaudit_contract.ListLogEntriesTaskID.Ref(), googlecloudlogcomputeapiaudit_contract.LogTypeComputeApi, )
LogIngesterTask is a task that ingests log metadata (timestamp, severity, summary, log type) into KHI v6 format.
var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTask[*googlecloudcommon_contract.GCPOperationTracker](googlecloudlogcomputeapiaudit_contract.LogToTimelineMapperTaskID, &gcpComputeAuditLogLogToTimelineMapperSetting{}, inspectioncore_contract.FeatureTaskLabel("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, ), )
LogToTimelineMapperTask maps GCE API audit logs to timeline events and revisions in parallel.
Functions ¶
func GenerateComputeAPIQuery ¶
func GenerateComputeAPIQuery(taskMode inspectioncore_contract.InspectionTaskModeType, nodeNames []string) []string
GenerateComputeAPIQuery generates a query for compute API logs.
func GenerateComputeAPIStructuredQuery ¶ added in v0.58.2
func GenerateComputeAPIStructuredQuery(taskMode inspectioncore_contract.InspectionTaskModeType, nodeNames []string) []*logestimator.StructuredLogQuery
GenerateComputeAPIStructuredQuery generates a structured query slice for compute API logs.
func Register ¶
func Register(registry coreinspection.InspectionTaskRegistry) error
Register registers all googlecloudlogcomputeapiaudit inspection tasks to the registry.
flowchart TD
ListLogEntriesTask LogIngesterTask LogGrouperTask LogToTimelineMapperTask ListLogEntriesTask --> LogGrouperTask ListLogEntriesTask --> LogIngesterTask LogGrouperTask --> LogToTimelineMapperTask LogIngesterTask --> LogToTimelineMapperTask
Types ¶
This section is empty.
Source Files