Documentation
¶
Index ¶
- Constants
- Variables
- func GenerateSerialPortQuery(taskMode inspectioncore_contract.InspectionTaskModeType, ...) []string
- func GenerateSerialPortStructuredQuery(taskMode inspectioncore_contract.InspectionTaskModeType, ...) []*logestimator.StructuredLogQuery
- 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 LogFilterTask = inspectiontaskbase.NewLogFilterTask( googlecloudlogserialport_contract.LogFilterTaskID, googlecloudlogserialport_contract.LogQueryTaskID.Ref(), func(ctx context.Context, l *log.Log) bool { msg, err := googlecloudlogserialport_contract.ExtractGCESerialPortMessage(l.NodeReader) if err != nil { return false } return msg != "" }, )
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, err := googlecloudlogserialport_contract.ExtractGCESerialPortLog(l.NodeReader) if err != nil { return "" } 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.NewStructuredListLogEntriesTask(&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
GenerateSerialPortQuery generates query strings for serial port logs.
func GenerateSerialPortStructuredQuery ¶ added in v0.58.2
func GenerateSerialPortStructuredQuery(taskMode inspectioncore_contract.InspectionTaskModeType, foundNodeNames []string, nodeNameSubstrings []string) []*logestimator.StructuredLogQuery
GenerateSerialPortStructuredQuery generates structured log queries for serial port logs.
func Register ¶
func Register(registry coreinspection.InspectionTaskRegistry) error
Register registers all googlecloudlogserialport inspection tasks to the registry.
flowchart TD
LogQueryTask LogFilterTask LogIngesterTask LogGrouperTask LogToTimelineMapperTask LogQueryTask --> LogFilterTask LogFilterTask --> LogIngesterTask LogFilterTask --> LogGrouperTask LogGrouperTask --> LogToTimelineMapperTask LogIngesterTask --> LogToTimelineMapperTask
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.