grpc

package
v4.4.0 Latest Latest
Warning

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

 Go to latest Published: Apr 3, 2024 License: AGPL-3.0 Imports: 34 Imported by: 0

Documentation

Overview

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

Index

Constants

View Source 
const ServiceName = common.ServiceGrpcNamespace_ + common.ServiceJobs

Variables

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

Functions

func BuildDataSourceSyncJob added in v4.0.6 

func BuildDataSourceSyncJob(dsName string, flat, autoStart bool, languages ...string) *jobs.Job

Types

type JobsHandler 

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

JobsHandler implements the JobService API

func NewJobsHandler 

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

NewJobsHandler creates a new JobsHandler

func (*JobsHandler) CleanDeadUserJobs added in v4.0.1 

func (j *JobsHandler) CleanDeadUserJobs(ctx context.Context) error

CleanDeadUserJobs finds AutoStart+AutoClean user-scope jobs that were never started

func (*JobsHandler) CleanStuckTasks 

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

CleanStuckTasks may be run at startup to find orphan tasks and their corresponding logs, then find orphan logs as well

func (*JobsHandler) Close 

func (j *JobsHandler) Close()

func (*JobsHandler) DeleteJob 

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

func (*JobsHandler) DetectStuckTasks 

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

DetectStuckTasks calls CleanStuckTasks with default duration

func (*JobsHandler) GetJob 

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

func (*JobsHandler) ListAutoRestartJobs added in v4.2.0 

func (j *JobsHandler) ListAutoRestartJobs(ctx context.Context) (out []*proto.Job, er error)

ListAutoRestartJobs filters the list of restartable jobs

func (*JobsHandler) ListJobs 

func (j *JobsHandler) ListJobs(request *proto.ListJobsRequest, streamer proto.JobService_ListJobsServer) error

func (*JobsHandler) ListTasks 

func (j *JobsHandler) ListTasks(request *proto.ListTasksRequest, streamer proto.JobService_ListTasksServer) error

func (*JobsHandler) Name 

func (j *JobsHandler) Name() string

func (*JobsHandler) OrphanLogs added in v4.0.7 

func (j *JobsHandler) OrphanLogs(ctx context.Context) (int64, error)

OrphanLogs finds all logs older than an hour that do not belong to any known tasks

func (*JobsHandler) PutJob 

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

func (*JobsHandler) PutTask 

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

func (*JobsHandler) PutTaskStream 

func (j *JobsHandler) PutTaskStream(streamer proto.JobService_PutTaskStreamServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.