googlecloudlogonpremapiaudit_impl

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

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

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

var LogIngesterTask = googlecloudcommon_contract.NewGCPOperationLogIngesterTask(
	googlecloudlogonpremapiaudit_contract.LogIngesterTaskID,
	googlecloudlogonpremapiaudit_contract.ListLogEntriesTaskID.Ref(),
	googlecloudlogonpremapiaudit_contract.LogTypeOnPremAPI,
)

var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTask(
	googlecloudlogonpremapiaudit_contract.LogToTimelineMapperTaskID,
	&OnPremAPIAuditTimelineMapper{},
	inspectioncore_contract.FeatureTaskLabel(
		"On-Premises API Logs",
		"Gather Anthos On-Premises audit logs to visualize cluster lifecycle events (creation, deletion, enrollment, unenrollment, and upgrades) on timelines.",
		9500,
		true,
	),
)