googlecloudlogserialport_impl

package

v0.49.1 Latest Latest Go to latest Published: Nov 18, 2025 License: Apache-2.0 Imports: 18 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 HistoryModifierTask = inspectiontaskbase.NewHistoryModifierTask[struct{}](
	googlecloudlogserialport_contract.HistoryModifierTaskID,
	&serialportHistoryModifier{},
	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...,
	),
)

HistoryModifierTask is the task to modify history to generate events on 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 LogQueryTask = googlecloudcommon_contract.NewListLogEntriesTask(&serialPortLoggingFilterTaskSetting{})

View Source

var LogSerializerTask = inspectiontaskbase.NewLogSerializerTask(
	googlecloudlogserialport_contract.LogSerializerTaskID,
	googlecloudlogserialport_contract.LogFilterTaskID.Ref(),
)

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

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
LogSerializerTask
LogGrouperTask
HistoryModifierTask

LogQueryTask --> FieldSetReadTask
FieldSetReadTask --> LogFilterTask
LogFilterTask --> LogSerializerTask
LogFilterTask --> LogGrouperTask
LogGrouperTask --> HistoryModifierTask
LogSerializerTask --> HistoryModifierTask

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