googlecloudlogmulticloudapiaudit_impl

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

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

var LogGrouperTask = inspectiontaskbase.NewLogGrouperTask(
	googlecloudlogmulticloudapiaudit_contract.LogGrouperTaskID,
	googlecloudlogmulticloudapiaudit_contract.ListLogEntriesTaskID.Ref(),
	func(ctx context.Context, l *log.Log) string {
		resourceFieldSet, err := googlecloudlogmulticloudapiaudit_contract.ExtractMulticloudAPIAuditResource(l.NodeReader)
		if err != nil {
			return ""
		}
		if resourceFieldSet.IsCluster() {
			return fmt.Sprintf("cluster/%s/%s", resourceFieldSet.ClusterType, resourceFieldSet.ClusterName)
		}
		return fmt.Sprintf("nodepool/%s/%s/%s", resourceFieldSet.ClusterType, resourceFieldSet.ClusterName, resourceFieldSet.NodepoolName)
	},
)

var LogIngesterTask = googlecloudcommon_contract.NewGCPOperationLogIngesterTask(
	googlecloudlogmulticloudapiaudit_contract.LogIngesterTaskID,
	googlecloudlogmulticloudapiaudit_contract.ListLogEntriesTaskID.Ref(),
	googlecloudlogmulticloudapiaudit_contract.LogTypeMulticloudAPI,
)

var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTask[*googlecloudcommon_contract.GCPOperationTracker](
	googlecloudlogmulticloudapiaudit_contract.LogToTimelineMapperTaskID,
	&multicloudAuditLogLogToTimelineMapperSetting{},
	inspectioncore_contract.FeatureTaskLabel(`Multi-Cloud API Logs`,
		`Gather Anthos Multi-Cloud audit logs to visualize cluster lifecycle events (creation, deletion, and upgrades) on timelines.`,
		5000,
		true,
	),
)