tracking

Documentation

Index

• type JobTracker
  • func CreateJobTracker(logger log.Logger, cl *dipscl.Client, jobId string) JobTracker
  • func CreateTaskTracker(logger log.Logger, cl *dipscl.Client, jobId string, taskId string) JobTracker
  • func (t *JobTracker) Crit(msg string, ctx ...interface{})
  • func (t *JobTracker) Debug(msg string, ctx ...interface{})
  • func (t *JobTracker) Error(msg string, ctx ...interface{})
  • func (t *JobTracker) Info(msg string, ctx ...interface{})
  • func (t *JobTracker) Progress(progress uint)
  • func (t *JobTracker) StdErr(msg string, ctx ...interface{})
  • func (t *JobTracker) StdOut(msg string, ctx ...interface{})
  • func (t *JobTracker) Warn(msg string, ctx ...interface{})

Types

type JobTracker

type JobTracker struct {
	// contains filtered or unexported fields
}

Tracks job status, progress and logs

func CreateJobTracker

func CreateJobTracker(logger log.Logger, cl *dipscl.Client, jobId string) JobTracker

Creates a new job tracking instance

func CreateTaskTracker

func CreateTaskTracker(logger log.Logger, cl *dipscl.Client, jobId string, taskId string) JobTracker

Creates a new task tracking instance

func (*JobTracker) Crit

func (t *JobTracker) Crit(msg string, ctx ...interface{})

func (*JobTracker) Debug

func (t *JobTracker) Debug(msg string, ctx ...interface{})

func (*JobTracker) Error

func (t *JobTracker) Error(msg string, ctx ...interface{})

func (*JobTracker) Info

func (t *JobTracker) Info(msg string, ctx ...interface{})

func (*JobTracker) Progress

func (t *JobTracker) Progress(progress uint)

Tracks progress of the current task

func (*JobTracker) StdErr

func (t *JobTracker) StdErr(msg string, ctx ...interface{})

func (*JobTracker) StdOut

func (t *JobTracker) StdOut(msg string, ctx ...interface{})

func (*JobTracker) Warn

func (t *JobTracker) Warn(msg string, ctx ...interface{})