k8sevent_impl

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

var EventLogNEGDiscoveryTask = inspectiontaskbase.NewInspectionTask(
	k8sevent.NEGToBackendServiceDiscoveryTaskID,
	[]coretask.Dependency{k8sevent.ListLogEntriesTaskID.Ref()},
	func(ctx context.Context, taskMode inspectioncore.InspectionTaskModeType) (k8scommon.NEGToBackendServiceMap, error) {
		if taskMode != inspectioncore.TaskModeRun {
			return nil, nil
		}

		logs := coretask.GetTaskResult(ctx, k8sevent.ListLogEntriesTaskID.Ref())
		result := make(k8scommon.NEGToBackendServiceMap)

		for _, l := range logs {
			fs, err := k8sevent.ExtractKubernetesEvent(l.NodeReader)
			if err == nil {
				neg, bs := k8scommon.ExtractNEGToBackendService(fs.Message)
				if neg != "" && bs != "" {
					result[neg] = bs
				}
			}
		}
		return result, nil
	},
	coretask.ProvidesTag(k8scommon.TagNEGToBackendServiceDiscovery),
)

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

var LogGrouperTask = inspectiontaskbase.NewLogGrouperTask(
	k8sevent.LogGrouperTaskID,
	k8sevent.ListLogEntriesTaskID.Ref(),
	func(ctx context.Context, l *log.Log) string {
		event, err := k8sevent.ExtractKubernetesEvent(l.NodeReader)
		if err != nil {
			return "unknown"
		}
		return fmt.Sprintf("cluster=%s,kind=%s,namespace=%s,name=%s", event.ClusterName, event.ResourceKind, event.Namespace, event.Resource)
	},
)

var LogIngesterTask = inspectiontaskbase.NewLogIngesterTask(
	k8sevent.LogIngesterTaskID,
	&KubernetesEventLogIngester{},
)

var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTask(
	k8sevent.LogToTimelineMapperTaskID,
	&KubernetesEventTimelineMapper{},
	inspectioncore.FeatureTaskLabel(
		"Kubernetes Event Logs",
		"Gather Kubernetes event logs to visualize cluster events on associated resource timelines.",
		2000,
		true,
	),
)