googlecloudlogonpremapiaudit_impl

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

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

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

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

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

var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTask[struct{}](googlecloudlogonpremapiaudit_contract.LogToTimelineMapperTaskID, &onpremAuditLogLogToTimelineMapperSetting{},
	inspectioncore_contract.FeatureTaskLabel(`OnPrem API logs`,
		`Gather Anthos OnPrem audit log including cluster creation,deletion,enroll,unenroll and upgrades.`,
		enum.LogTypeOnPremAPI,
		5000,
		true,
	),
)