googlecloudlogk8sevent_impl

var FieldSetReaderTask = inspectiontaskbase.NewFieldSetReadTask(googlecloudlogk8sevent_contract.FieldSetReaderTaskID, googlecloudlogk8sevent_contract.ListLogEntriesTaskID.Ref(), []log.FieldSetReader{
	&googlecloudlogk8sevent_contract.GCPKubernetesEventFieldSetReader{},
})

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

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

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

var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTask[struct{}](googlecloudlogk8sevent_contract.LogToTimelineMapperTaskID, &KubernetesEventLogToTimelineMapperSetting{}, inspectioncore_contract.FeatureTaskLabel(
	"Kubernetes Event Logs",
	"Gather kubernetes event logs and visualize these on the associated resource timeline.",
	enum.LogTypeEvent,
	2000,
	true,
	googlecloudinspectiontypegroup_contract.GCPK8sClusterInspectionTypes...,
))