googlecloudlogk8sevent_impl

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

var EventLogNEGDiscoveryTask = googlecloudk8scommon_contract.NEGToBackendServiceInventoryBuilder.DiscoveryTask(
	googlecloudlogk8sevent_contract.NEGToBackendServiceDiscoveryTaskID,
	[]taskid.UntypedTaskReference{googlecloudlogk8sevent_contract.FieldSetReaderTaskID.Ref()},
	func(ctx context.Context, taskMode inspectioncore_contract.InspectionTaskModeType, progress *inspectionmetadata.TaskProgressMetadata) (googlecloudk8scommon_contract.NEGToBackendServiceMap, error) {
		if taskMode != inspectioncore_contract.TaskModeRun {
			return nil, nil
		}

		logs := coretask.GetTaskResult(ctx, googlecloudlogk8sevent_contract.FieldSetReaderTaskID.Ref())
		result := make(googlecloudk8scommon_contract.NEGToBackendServiceMap)

		for _, l := range logs {
			fs, err := log.GetFieldSet(l, &googlecloudlogk8sevent_contract.KubernetesEventFieldSet{})
			if err == nil {
				neg, bs := googlecloudk8scommon_contract.ExtractNEGToBackendService(fs.Message)
				if neg != "" && bs != "" {
					result[neg] = bs
				}
			}
		}
		return result, nil
	},
)

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

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 fmt.Sprintf("cluster=%s,kind=%s,namespace=%s,name=%s", event.ClusterName, event.ResourceKind, event.Namespace, event.Resource)
	},
)

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

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