job

package

v1.0.10 Latest Latest Go to latest Published: Oct 8, 2023 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

View Source

var ErrJobAborted = errors.New("Aborted")

This section is empty.

type JobLogMsg struct {
	Lvl string
	Msg string
}

type JobLogWriter struct {
	log.LogFilter
	log.LogFormatter
	// contains filtered or unexported fields
}

JobLogWriter implements log Writer Interface and writes messages to terminal.

func (jlw *JobLogWriter) Clear()

Clear clear the output

func (jlw *JobLogWriter) Close()

Close implementing method. empty.

func (jlw *JobLogWriter) Flush()

Flush implementing method. empty.

func (jlw *JobLogWriter) GetMessages(start, limit int) []JobLogMsg

GetMessage get job log messages from start to start+limit. GetMessage(0, -1): get all message

func (jlw *JobLogWriter) Write(le *log.Event) (err error)

Write write message in console.

type JobRunner struct {
	Log *log.Log
	Run func()
	Out JobLogWriter
	// contains filtered or unexported fields
}

func NewJobRunner(logger ...log.Logger) *JobRunner

func (jr *JobRunner) Abort()

func (jr *JobRunner) IsAborted() bool

func (jr *JobRunner) IsRunning() bool

func (jr *JobRunner) Start()