googlecloudlogserialport_impl

package

v0.52.0 Latest Latest Go to latest Published: Feb 3, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/GoogleCloudPlatform/khi

Links

Documentation ¶

Index ¶

Constants
Variables
func GenerateSerialPortQuery(taskMode inspectioncore_contract.InspectionTaskModeType, ...) []string
func Register(registry coreinspection.InspectionTaskRegistry) error

Constants ¶

View Source

const MaxNodesPerQuery = 30

Variables ¶

View Source

var FieldSetReadTask = inspectiontaskbase.NewFieldSetReadTask(googlecloudlogserialport_contract.FieldSetReadTaskID, googlecloudlogserialport_contract.LogQueryTaskID.Ref(), []log.FieldSetReader{
	&googlecloudlogserialport_contract.GCESerialPortLogFieldSetReader{},
})

FieldSetReadTask is the task to run GCESerialPortLogFieldSetReader on logs to parse serial port logs.

View Source

var LogFilterTask = inspectiontaskbase.NewLogFilterTask(googlecloudlogserialport_contract.LogFilterTaskID, googlecloudlogserialport_contract.FieldSetReadTaskID.Ref(),
	func(ctx context.Context, l *log.Log) bool {
		return log.MustGetFieldSet(l, &googlecloudlogserialport_contract.GCESerialPortLogFieldSet{}).Message != ""
	},
)

LogFilterTask removes logs with empty message. This message is mostly just contained escape sequences and stripped by ANSIEscapeSequenceStripper.

View Source

var LogGrouperTask = inspectiontaskbase.NewLogGrouperTask(
	googlecloudlogserialport_contract.LogGrouperTaskID,
	googlecloudlogserialport_contract.LogFilterTaskID.Ref(),
	func(ctx context.Context, l *log.Log) string {
		return log.MustGetFieldSet(l, &googlecloudlogserialport_contract.GCESerialPortLogFieldSet{}).GetResourcePath().Path
	},
)

LogGrouperTask is the grouper task for GCE serial port logs. It groups logs by the node name and port name

View Source

var LogIngesterTask = inspectiontaskbase.NewLogIngesterTask(
	googlecloudlogserialport_contract.LogIngesterTaskID,
	googlecloudlogserialport_contract.LogFilterTaskID.Ref(),
)

LogIngesterTask is the log serializer task for GCE serial port logs. It includes all logs gathered from log list.

View Source

var LogQueryTask = googlecloudcommon_contract.NewListLogEntriesTask(&serialPortLoggingFilterTaskSetting{})

View Source

var LogToTimelineMapperTask = inspectiontaskbase.NewLogToTimelineMapperTask[struct{}](
	googlecloudlogserialport_contract.LogToTimelineMapperTaskID,
	&serialportLogToTimelineMapper{},
	inspectioncore_contract.FeatureTaskLabel(
		"GCE Node Serialport log",
		`Serialport logs from GCE instances. This helps detailed investigation on VM bootstrapping issue on GCE instance.`,
		enum.LogTypeSerialPort,
		10000, false, googlecloudinspectiontypegroup_contract.GKEBasedClusterInspectionTypes...,
	),
)

LogToTimelineMapperTask is the task to map logs into events on serial port logs.

Functions ¶

func GenerateSerialPortQuery ¶

func GenerateSerialPortQuery(taskMode inspectioncore_contract.InspectionTaskModeType, foundNodeNames []string, nodeNameSubstrings []string) []string

func Register ¶

func Register(registry coreinspection.InspectionTaskRegistry) error

Register registers all googlecloudlogserialport inspection tasks to the registry.

flowchart TD

LogQueryTask
LogFilterTask
FieldSetReadTask
LogIngesterTask
LogGrouperTask
LogToTimelineMapperTask

LogQueryTask --> FieldSetReadTask
FieldSetReadTask --> LogFilterTask
LogFilterTask --> LogIngesterTask
LogFilterTask --> LogGrouperTask
LogGrouperTask --> LogToTimelineMapperTask
LogIngesterTask --> LogToTimelineMapperTask

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL