googlecloudlogmulticloudapiaudit_impl

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

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

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

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

var LogIngesterTask = inspectiontaskbase.NewLogIngesterTask(googlecloudlogmulticloudapiaudit_contract.LogIngesterTaskID, googlecloudlogmulticloudapiaudit_contract.ListLogEntriesTaskID.Ref())

var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTask[struct{}](googlecloudlogmulticloudapiaudit_contract.LogToTimelineMapperTaskID, &multicloudAuditLogLogToTimelineMapperSetting{},
	inspectioncore_contract.FeatureTaskLabel(`MultiCloud API logs`,
		`Gather Anthos Multicloud audit log including cluster creation,deletion and upgrades.`,
		enum.LogTypeGkeAudit,
		5000,
		true,
	),
)