serialport_impl

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

var LogFilterTask = inspectiontaskbase.NewLogFilterTask(
	serialport.LogFilterTaskID,
	serialport.LogQueryTaskID.Ref(),
	func(ctx context.Context, l *log.Log) bool {
		msg, err := serialport.ExtractGCESerialPortMessage(l.NodeReader)
		if err != nil {
			return false
		}
		return msg != ""
	},
)

var LogGrouperTask = inspectiontaskbase.NewLogGrouperTask(
	serialport.LogGrouperTaskID,
	serialport.LogFilterTaskID.Ref(),
	func(ctx context.Context, l *log.Log) string {
		serialFS, err := serialport.ExtractGCESerialPortLog(l.NodeReader)
		if err != nil {
			return ""
		}
		return fmt.Sprintf("%s#%s", serialFS.NodeName, serialFS.Port)
	},
)

var LogIngesterTask = inspectiontaskbase.NewLogIngesterTask(
	serialport.LogIngesterTaskID,
	&serialPortLogIngester{},
)

var LogQueryTask = gcpcommon.NewStructuredListLogEntriesTask(&serialPortLoggingFilterTaskSetting{})

var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTask(
	serialport.LogToTimelineMapperTaskID,
	&serialportLogToTimelineMapper{},
	inspectioncore.FeatureTaskLabel(
		"GCE Node Serial Port Logs",
		`Gather serial port logs from GCE instances to troubleshoot VM bootstrapping and OS initialization issues.`,
		10000,
		false,
	),
)