grpc

package
v2.2.8+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 31, 2021 License: AGPL-3.0 Imports: 27 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

View Source
var (
	Migration140 = false
	Migration150 = false
)

Functions

This section is empty.

Types

type JobsHandler

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

JobsHandler implements the JobService API

func NewJobsHandler added in v1.5.0

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 added in v1.5.0

func (j *JobsHandler) Close()

func (*JobsHandler) DeleteJob

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

func (*JobsHandler) DeleteLogsFor added in v1.4.0

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 (*JobsHandler) ListTasks

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL