googlecloudlogserialport_impl

package

v0.57.2 Latest Latest Go to latest Published: Jul 21, 2026 License: Apache-2.0 Imports: 15 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 ClusterIdentityAliasTask = coretask.NewAliasTask(
	googlecloudlogserialport_contract.ClusterIdentityTaskID,
	googlecloudk8scommon_contract.ClusterIdentityTaskID.Ref(),
)

View Source

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

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 {
		serialFS := log.MustGetFieldSet(l, &googlecloudlogserialport_contract.GCESerialPortLogFieldSet{})
		return fmt.Sprintf("%s#%s", serialFS.NodeName, serialFS.Port)
	},
)

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,
	&serialPortLogIngester{},
)

LogIngesterTask is the log ingester task.

View Source

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

View Source

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

LogToTimelineMapperTask is the timeline mapper task.

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