grpc

Documentation

Overview

Package grpc provides a gRPC service to access the store for scheduler job definitions.

Index

• Variables
• type JobsHandler
  • 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

Variables

var (
	Migration140 = false
	Migration150 = false
	Migration230 = false
)

Types

type JobsHandler

type JobsHandler struct {
	logcore.Handler
	// contains filtered or unexported fields
}

JobsHandler implements the JobService API

func NewJobsHandler

func NewJobsHandler(store jobs.DAO, messageRepository log3.MessageRepository) *JobsHandler

NewJobsHandler creates a new JobsHandler

func (*JobsHandler) CleanStuckTasks

func (j *JobsHandler) CleanStuckTasks(ctx context.Context, duration ...time.Duration) ([]*proto.Task, error)

CleanStuckTasks may be run at startup to

func (*JobsHandler) Close

func (j *JobsHandler) Close()

func (*JobsHandler) DeleteJob

func (j *JobsHandler) DeleteJob(ctx context.Context, request *proto.DeleteJobRequest, response *proto.DeleteJobResponse) error

func (*JobsHandler) DeleteLogsFor

func (j *JobsHandler) DeleteLogsFor(ctx context.Context, job string, tasks ...string) (int64, error)

func (*JobsHandler) DeleteTasks

func (j *JobsHandler) DeleteTasks(ctx context.Context, request *proto.DeleteTasksRequest, response *proto.DeleteTasksResponse) error

func (*JobsHandler) DetectStuckTasks

func (j *JobsHandler) DetectStuckTasks(ctx context.Context, request *proto.DetectStuckTasksRequest, response *proto.DetectStuckTasksResponse) error

func (*JobsHandler) GetJob

func (j *JobsHandler) GetJob(ctx context.Context, request *proto.GetJobRequest, response *proto.GetJobResponse) error

func (*JobsHandler) ListJobs

func (j *JobsHandler) ListJobs(ctx context.Context, request *proto.ListJobsRequest, streamer proto.JobService_ListJobsStream) error

func (*JobsHandler) ListTasks

func (j *JobsHandler) ListTasks(ctx context.Context, request *proto.ListTasksRequest, streamer proto.JobService_ListTasksStream) error

func (*JobsHandler) PutJob

func (j *JobsHandler) PutJob(ctx context.Context, request *proto.PutJobRequest, response *proto.PutJobResponse) error

//////////////// JOBS STORE ///////////////

func (*JobsHandler) PutTask

func (j *JobsHandler) PutTask(ctx context.Context, request *proto.PutTaskRequest, response *proto.PutTaskResponse) error

//////////////// TASKS STORE ///////////////

func (*JobsHandler) PutTaskStream

func (j *JobsHandler) PutTaskStream(ctx context.Context, streamer proto.JobService_PutTaskStreamStream) error