v1beta1

Documentation

Index

• type JobRunHandler
  • func NewJobRunHandler(l log.Logger, service JobRunService, notifier Notifier) *JobRunHandler
  • func (h JobRunHandler) JobRun(ctx context.Context, req *pb.JobRunRequest) (*pb.JobRunResponse, error)
  • func (h JobRunHandler) JobRunInput(ctx context.Context, req *pb.JobRunInputRequest) (*pb.JobRunInputResponse, error)
  • func (h JobRunHandler) RegisterJobEvent(ctx context.Context, req *pb.RegisterJobEventRequest) (*pb.RegisterJobEventResponse, error)
  • func (h JobRunHandler) UploadToScheduler(ctx context.Context, req *pb.UploadToSchedulerRequest) (*pb.UploadToSchedulerResponse, error)
• type JobRunService
• type Notifier

Types

type JobRunHandler

type JobRunHandler struct {
	pb.UnimplementedJobRunServiceServer
	// contains filtered or unexported fields
}

func NewJobRunHandler

func NewJobRunHandler(l log.Logger, service JobRunService, notifier Notifier) *JobRunHandler

func (JobRunHandler) JobRun

func (h JobRunHandler) JobRun(ctx context.Context, req *pb.JobRunRequest) (*pb.JobRunResponse, error)

JobRun currently gets the job runs from scheduler based on the criteria TODO: later should collect the job runs from optimus

func (JobRunHandler) JobRunInput

func (h JobRunHandler) JobRunInput(ctx context.Context, req *pb.JobRunInputRequest) (*pb.JobRunInputResponse, error)

func (JobRunHandler) RegisterJobEvent

func (h JobRunHandler) RegisterJobEvent(ctx context.Context, req *pb.RegisterJobEventRequest) (*pb.RegisterJobEventResponse, error)

RegisterJobEvent TODO: check in jaeger if this api takes time, then we can make this async

func (JobRunHandler) UploadToScheduler

func (h JobRunHandler) UploadToScheduler(ctx context.Context, req *pb.UploadToSchedulerRequest) (*pb.UploadToSchedulerResponse, error)

type JobRunService

type JobRunService interface {
	JobRunInput(context.Context, tenant.ProjectName, scheduler.JobName, scheduler.RunConfig) (*scheduler.ExecutorInput, error)
	UpdateJobState(context.Context, scheduler.Event) error
	GetJobRuns(ctx context.Context, projectName tenant.ProjectName, jobName scheduler.JobName, criteria *scheduler.JobRunsCriteria) ([]*scheduler.JobRunStatus, error)
	UploadToScheduler(ctx context.Context, projectName tenant.ProjectName) error
}

type Notifier

type Notifier interface {
	Push(ctx context.Context, event scheduler.Event) error
}