log

Documentation

Index

• type CrontabLogFlowEntity
  • func CreateLogFlow(ctx context.Context, id, fatherId int64, workerIp string, ...) (*CrontabLogFlowEntity, error)
  • func ListLogFlow(ctx context.Context, id, fatherId int64, workIp, flowId, flowName string, ...) ([]*CrontabLogFlowEntity, int64, error)
  • func UpdateLogFlow(ctx context.Context, id, fatherId int64, workerIp string, ...) (*CrontabLogFlowEntity, error)
  • func (CrontabLogFlowEntity) TableName() string
• type CrontabLogJobEntity
  • func CreateLogJob(ctx context.Context, id, fatherId, traceId int64, workerIp string, ...) (*CrontabLogJobEntity, error)
  • func ListLogJob(ctx context.Context, id, fatherId, traceId int64, ...) ([]*CrontabLogJobEntity, int64, error)
  • func UpdateLogJob(ctx context.Context, id, fatherId, traceId int64, workerIp string, ...) (*CrontabLogJobEntity, error)
  • func (CrontabLogJobEntity) TableName() string

Types

type CrontabLogFlowEntity

type CrontabLogFlowEntity struct {
	Id         int64  `gorm:"not null; column:id" json:"id"`
	FatherId   int64  `gorm:"not null; column:father_id" json:"father_id"`
	WorkerIp   string `gorm:"not null; column:worker_ip" json:"worker_ip"`
	FlowId     string `gorm:"not null; column:flow_id" json:"flow_id"`
	FlowName   string `gorm:"not null; column:flow_name" json:"flow_name"`
	FlowInfo   string `gorm:"not null; column:flow_info" json:"flow_info"`
	StartTime  int64  `gorm:"not null; column:start_time" json:"start_time"`
	EndTime    int64  `gorm:"not null; column:end_time" json:"end_time"`
	Input      string `gorm:"not null; column:input" json:"input"`
	Output     string `gorm:"not null; column:output" json:"output"`
	ErrorMsg   string `gorm:"not null; column:error_msg" json:"error_msg"`
	Desc       string `gorm:"not null; column:desc" json:"desc"`
	CreateTime int64  `gorm:"not null; column:create_time" json:"create_time"`
	UpdateTime int64  `gorm:"not null; column:update_time" json:"update_time"`
}

func CreateLogFlow

func CreateLogFlow(ctx context.Context, id, fatherId int64, workerIp string, flowId, flowName, flowInfo string, startTime, endTime int64, input, output, errMsg, desc string) (*CrontabLogFlowEntity, error)

func ListLogFlow

func ListLogFlow(ctx context.Context, id, fatherId int64, workIp, flowId, flowName string, startTime, endTime int64, sortValue string, offset, limit int64) ([]*CrontabLogFlowEntity, int64, error)

func UpdateLogFlow

func UpdateLogFlow(ctx context.Context, id, fatherId int64, workerIp string, flowId, flowName, flowInfo string, startTime, endTime int64, input, output, errMsg, desc string) (*CrontabLogFlowEntity, error)

func (CrontabLogFlowEntity) TableName

func (CrontabLogFlowEntity) TableName() string

type CrontabLogJobEntity

type CrontabLogJobEntity struct {
	Id         int64  `gorm:"not null; column:id" json:"id"`
	FatherId   int64  `gorm:"not null; column:father_id" json:"father_id"`
	TraceId    int64  `gorm:"not null; column:trace_id" json:"trace_id"`
	WorkerIp   string `gorm:"not null; column:worker_ip" json:"worker_ip"`
	FlowId     string `gorm:"not null; column:flow_id" json:"flow_id"`
	FlowName   string `gorm:"not null; column:flow_name" json:"flow_name"`
	FlowInfo   string `gorm:"not null; column:flow_info" json:"flow_info"`
	JobId      string `gorm:"not null; column:job_id" json:"job_id"`
	JobName    string `gorm:"not null; column:job_name" json:"job_name"`
	JobInfo    string `gorm:"not null; column:job_info" json:"job_info"`
	StartTime  int64  `gorm:"not null; column:start_time" json:"start_time"`
	EndTime    int64  `gorm:"not null; column:end_time" json:"end_time"`
	Input      string `gorm:"not null; column:input" json:"input"`
	Output     string `gorm:"not null; column:output" json:"output"`
	ErrorMsg   string `gorm:"not null; column:error_msg" json:"error_msg"`
	Desc       string `gorm:"not null; column:desc" json:"desc"`
	CreateTime int64  `gorm:"not null; column:create_time" json:"create_time"`
	UpdateTime int64  `gorm:"not null; column:update_time" json:"update_time"`
}

func CreateLogJob

func CreateLogJob(ctx context.Context, id, fatherId, traceId int64, workerIp string, flowId, flowName, flowInfo string, jobId, jobName, jobInfo string, startTime, endTime int64, input, output, errMsg, desc string) (*CrontabLogJobEntity, error)

func ListLogJob

func ListLogJob(ctx context.Context, id, fatherId, traceId int64, workIp, flowId, jobId, flowName, jobName string, startTime, endTime int64, sortValue string, offset, limit int64) ([]*CrontabLogJobEntity, int64, error)

func UpdateLogJob

func UpdateLogJob(ctx context.Context, id, fatherId, traceId int64, workerIp string, flowId, flowName, flowInfo string, jobId, jobName, jobInfo string, startTime, endTime int64, input, output, errMsg, desc string) (*CrontabLogJobEntity, error)

func (CrontabLogJobEntity) TableName

func (CrontabLogJobEntity) TableName() string