googlecloudlogcomposerapiaudit_impl

var ClusterIdentityAliasTask = coretask.NewAliasTask(
	googlecloudlogcomposerapiaudit_contract.ClusterIdentityTaskID,
	googlecloudk8scommon_contract.ClusterIdentityTaskID.Ref(),
)

var FieldSetReaderTask = inspectiontaskbase.NewFieldSetReadTask(
	googlecloudlogcomposerapiaudit_contract.FieldSetReaderTaskID,
	googlecloudlogcomposerapiaudit_contract.ListLogEntriesTaskID.Ref(),
	[]log.FieldSetReader{
		&googlecloudcommon_contract.GCPOperationAuditLogFieldSetReader{},
		&googlecloudlogcomposerapiaudit_contract.ComposerAuditLogResourceFieldSetReader{},
		&googlecloudcommon_contract.GCPDefaultSeverityFieldSetReader{},
	},
)

var ListLogEntriesTask = googlecloudcommon_contract.NewListLogEntriesTask(&composerAPIListLogEntriesTaskSetting{})

var LogGrouperTask = inspectiontaskbase.NewLogGrouperTask(
	googlecloudlogcomposerapiaudit_contract.LogGrouperTaskID,
	googlecloudlogcomposerapiaudit_contract.FieldSetReaderTaskID.Ref(),
	func(ctx context.Context, l *log.Log) string {
		resourceFieldSet, err := log.GetFieldSet(l, &googlecloudlogcomposerapiaudit_contract.ComposerAuditLogResourceFieldSet{})
		if err != nil {
			return "unknown"
		}
		return resourceFieldSet.EnvironmentName
	},
)

var LogIngesterTask = googlecloudcommon_contract.NewGCPOperationLogIngesterTask(
	googlecloudlogcomposerapiaudit_contract.LogIngesterTaskID,
	googlecloudlogcomposerapiaudit_contract.FieldSetReaderTaskID.Ref(),
	googlecloudlogcomposerapiaudit_contract.LogTypeManagedAirflowAPI,
)

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,
	),
)