reporter

Documentation

Index

• type JobReporter
  • func NewJobReporter(result *types.JobExecuteResult, client *network.ZadigClient, cancel *bool) *JobReporter
  • func (r *JobReporter) FinishedJobReport(status common.Status, err error) error
  • func (r *JobReporter) GetJobLog() (string, bool, error)
  • func (r *JobReporter) Report() error
  • func (r *JobReporter) ReportWithData(result *types.JobExecuteResult) (*types.ReportAgentJobResp, error)
  • func (r *JobReporter) SetLog() error
  • func (r *JobReporter) Start(ctx context.Context)

Types

type JobReporter

type JobReporter struct {
	Seq       int
	Ctx       context.Context
	Client    *network.ZadigClient
	Logger    *log.JobLogger
	Offset    int64
	CurLogNum int64
	Log       string
	JobCancel *bool
	Result    *types.JobExecuteResult
}

func NewJobReporter

func NewJobReporter(result *types.JobExecuteResult, client *network.ZadigClient, cancel *bool) *JobReporter

func (*JobReporter) FinishedJobReport

func (r *JobReporter) FinishedJobReport(status common.Status, err error) error

func (*JobReporter) GetJobLog

func (r *JobReporter) GetJobLog() (string, bool, error)

func (*JobReporter) Report

func (r *JobReporter) Report() error

func (*JobReporter) ReportWithData

func (r *JobReporter) ReportWithData(result *types.JobExecuteResult) (*types.ReportAgentJobResp, error)

func (*JobReporter) SetLog

func (r *JobReporter) SetLog() error

func (*JobReporter) Start

func (r *JobReporter) Start(ctx context.Context)