networkapiaudit_impl

var ClusterIdentityAliasTask = coretask.NewAliasTask(
	networkapiaudit.ClusterIdentityTaskID,
	k8scommon.ClusterIdentityTaskID.Ref(),
)

var ListLogEntriesTask = gcpcommon.NewStructuredListLogEntriesTask(&networkAPIListLogEntriesTaskSetting{})

var LogGrouperTask = inspectiontaskbase.NewLogGrouperTask(networkapiaudit.LogGrouperTaskID, networkapiaudit.ListLogEntriesTaskID.Ref(),
	func(ctx context.Context, l *log.Log) string {
		audit, err := gcpcommon.ExtractGCPAuditLog(l.NodeReader)
		if err != nil {
			return "unknown"
		}
		return audit.ResourceName
	},
)

var LogIngesterTask = gcpcommon.NewGCPOperationLogIngesterTask(
	networkapiaudit.LogIngesterTaskID,
	networkapiaudit.ListLogEntriesTaskID.Ref(),
	networkapiaudit.LogTypeNetworkAPI,
)

var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTask(networkapiaudit.LogToTimelineMapperTaskID, &networkAPITimelineMapper{},
	inspectioncore.FeatureTaskLabel(`GCE Network Logs`,
		`Gather GCE Network API logs to visualize the provisioning and status transitions of Network Endpoint Groups (NEGs) on timelines.`,
		7000,
		true,
	),
)