grpc

package
v1.2.3 Latest Latest
Warning

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

Go to latest
Published: Dec 7, 2018 License: AGPL-3.0 Imports: 19 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

This section is empty.

Functions

This section is empty.

Types

type JobsHandler

type JobsHandler struct {
	// contains filtered or unexported fields
}

JobsHandler implements the JobService API

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) DeleteJob

func (j *JobsHandler) DeleteJob(ctx context.Context, request *proto.DeleteJobRequest, response *proto.DeleteJobResponse) 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