log

Documentation

Index

• func GetLogs(ctx *logger.RequestContext, request GetMixedLogRequest) (schema.JobLogInfo, error)
• func GetPFJobLogs(ctx *logger.RequestContext, request GetMixedLogRequest) (schema.JobLogInfo, error)
• type GetMixedLogRequest
• type GetMixedLogResponse
• type GetRunLogRequest
• type GetRunLogResponse
  • func GetRunLog(ctx *logger.RequestContext, runID string, request GetRunLogRequest) (*GetRunLogResponse, error)

Functions

func GetLogs

func GetLogs(ctx *logger.RequestContext, request GetMixedLogRequest) (schema.JobLogInfo, error)

GetLogs return mixed logs

func GetPFJobLogs

func GetPFJobLogs(ctx *logger.RequestContext, request GetMixedLogRequest) (schema.JobLogInfo, error)

GetPFJobLogs todo to be merged with GetLogs return mixed log by events and logs

Types

type GetMixedLogRequest

type GetMixedLogRequest struct {
	Name         string
	Namespace    string
	ResourceType string
	Framework    string

	LineLimit      string
	SizeLimit      int64
	IsReadFromTail bool
	ClusterName    string
	ClusterInfo    model.ClusterInfo
}

GetMixedLogRequest can request job log or k8s pod/deploy events and log

type GetMixedLogResponse

type GetMixedLogResponse struct {
	ResourceName string               `json:"name"`
	Resourcetype string               `json:"type"`
	TaskList     []schema.TaskLogInfo `json:"taskList"`
	Events       []string             `json:"eventList"`
}

GetMixedLogResponse return mixed logs

type GetRunLogRequest

type GetRunLogRequest struct {
	JobID           string `json:"jobID"`
	PageNo          int    `json:"pageNo"`
	PageSize        int    `json:"pageSize"`
	LogFilePosition string `json:"logFilePosition"`
}

type GetRunLogResponse

type GetRunLogResponse struct {
	SubmitLog string              `json:"submitLog"`
	RunLog    []schema.JobLogInfo `json:"runLog"`
	RunID     string              `json:"runID"`
}

func GetRunLog

func GetRunLog(ctx *logger.RequestContext, runID string, request GetRunLogRequest) (*GetRunLogResponse, error)