Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ClusterIdentityAliasTask = coretask.NewAliasTask( googlecloudlogcomposerapiaudit_contract.ClusterIdentityTaskID, googlecloudk8scommon_contract.ClusterIdentityTaskID.Ref(), )
ClusterIdentityAliasTask aliases the cluster identity task for Composer API audit log inspection.
var ListLogEntriesTask = googlecloudcommon_contract.NewStructuredListLogEntriesTask(&composerAPIListLogEntriesTaskSetting{})
ListLogEntriesTask is the task that queries Cloud Composer audit logs from Cloud Logging.
var LogGrouperTask = inspectiontaskbase.NewLogGrouperTask( googlecloudlogcomposerapiaudit_contract.LogGrouperTaskID, googlecloudlogcomposerapiaudit_contract.ListLogEntriesTaskID.Ref(), func(ctx context.Context, l *log.Log) string { resourceFieldSet, err := googlecloudlogcomposerapiaudit_contract.ExtractComposerAuditLogResource(l.NodeReader) if err != nil { return "unknown" } return resourceFieldSet.EnvironmentName }, )
LogGrouperTask groups Cloud Composer audit logs by environment name.
var LogIngesterTask = googlecloudcommon_contract.NewGCPOperationLogIngesterTask( googlecloudlogcomposerapiaudit_contract.LogIngesterTaskID, googlecloudlogcomposerapiaudit_contract.ListLogEntriesTaskID.Ref(), googlecloudlogcomposerapiaudit_contract.LogTypeManagedAirflowAPI, )
LogIngesterTask ingests Cloud Composer audit logs into KHI v6 format.
var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTask[*googlecloudcommon_contract.GCPOperationTracker]( googlecloudlogcomposerapiaudit_contract.LogToTimelineMapperTaskID, &composerAuditLogLogToTimelineMapperSetting{}, inspectioncore_contract.FeatureTaskLabel( "Managed Airflow API Logs", "Gather Managed Airflow API audit logs to visualize environment operations (creation, update, and deletion) on timelines.", 5500, true, ), )
LogToTimelineMapperTask maps Cloud Composer audit logs to timeline events and operation revisions.
Functions ¶
func GenerateComposerAuditQuery ¶
GenerateComposerAuditQuery generates a Cloud Logging filter string for Cloud Composer audit logs.
func GenerateComposerAuditStructuredQuery ¶ added in v0.58.2
func GenerateComposerAuditStructuredQuery(projectID, location, environmentName string) *logestimator.StructuredLogQuery
GenerateComposerAuditStructuredQuery generates a structured query for Cloud Composer audit logs.
func Register ¶
func Register(registry coreinspection.InspectionTaskRegistry) error
Register registers all googlecloudlogcomposerapiaudit inspection tasks to the registry.
Types ¶
This section is empty.
Source Files