k8s_node

Documentation

Index

• Constants
• Variables
• func GenerateK8sNodeLogQuery(projectId string, clusterId string, nodeNameSubstrings []string) string

Constants

const ConfigureHelperShStartingMsg = "Start to configure instance for kubernetes"

const ConfigureHelperShTerminatingMsg = "Done for the configuration for kubernetes"

const ConfigureShStartingMsg = "Start to install kubernetes files"

const ConfigureShTerminatingMsg = "Done for installing kubernetes files"

const ContainerdStartingMsg = "starting containerd"

const DockerdStartingMsg = "Starting up"

const DockerdTerminatingMsg = "Daemon shutdown complete"

const GKENodeLogQueryTaskID = query.GKEQueryPrefix + "k8s-node"

Variables

var GKENodeLogParseJob = parser.NewParserTaskFromParser(gcp_task.GCPPrefix+"feature/nodelog-parser", &k8sNodeParser{}, false)

var GKENodeQueryTask = query.NewQueryGeneratorTask(GKENodeLogQueryTaskID, "Kubernetes node log", enum.LogTypeNode, []string{
	gcp_task.InputProjectIdTaskID,
	gcp_task.InputClusterNameTaskID,
	gcp_task.InputNodeNameFilterTaskID,
}, func(ctx context.Context, i int, vs *task.VariableSet) ([]string, error) {
	clusterName, err := gcp_task.GetInputClusterNameFromTaskVariable(vs)
	if err != nil {
		return nil, err
	}
	projectId, err := gcp_task.GetInputProjectIdFromTaskVariable(vs)
	if err != nil {
		return nil, err
	}
	nodeNameSubstrings, err := gcp_task.GetNodeNameFilterFromTaskVaraible(vs)
	if err != nil {
		return nil, err
	}
	return []string{GenerateK8sNodeLogQuery(projectId, clusterName, nodeNameSubstrings)}, nil
})

Functions

func GenerateK8sNodeLogQuery

func GenerateK8sNodeLogQuery(projectId string, clusterId string, nodeNameSubstrings []string) string