Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + var Migration140 = false + var Migration150 = false + type JobsHandler struct + func NewJobsHandler(store jobs.DAO, messageRepository log3.MessageRepository) *JobsHandler + func (j *JobsHandler) CleanStuckTasks(ctx context.Context, duration ...time.Duration) ([]*proto.Task, error) + func (j *JobsHandler) Close() + func (j *JobsHandler) DeleteJob(ctx context.Context, request *proto.DeleteJobRequest, ...) error + func (j *JobsHandler) DeleteLogsFor(ctx context.Context, job string, tasks ...string) (int64, error) + func (j *JobsHandler) DeleteTasks(ctx context.Context, request *proto.DeleteTasksRequest, ...) error + func (j *JobsHandler) DetectStuckTasks(ctx context.Context, request *proto.DetectStuckTasksRequest, ...) error + func (j *JobsHandler) GetJob(ctx context.Context, request *proto.GetJobRequest, ...) error + func (j *JobsHandler) ListJobs(ctx context.Context, request *proto.ListJobsRequest, ...) error + func (j *JobsHandler) ListTasks(ctx context.Context, request *proto.ListTasksRequest, ...) error + func (j *JobsHandler) PutJob(ctx context.Context, request *proto.PutJobRequest, ...) error + func (j *JobsHandler) PutTask(ctx context.Context, request *proto.PutTaskRequest, ...) error + func (j *JobsHandler) PutTaskStream(ctx context.Context, streamer proto.JobService_PutTaskStreamStream) error Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020