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(_ context.Context, req *pb.UploadToSchedulerRequest) (*pb.UploadToSchedulerResponse, error)
• type JobRunService
• type Notifier
• type ReplayHandler
  • func NewReplayHandler(l log.Logger, service ReplayService) *ReplayHandler
  • func (h ReplayHandler) GetReplay(ctx context.Context, req *pb.GetReplayRequest) (*pb.GetReplayResponse, error)
  • func (h ReplayHandler) ListReplay(ctx context.Context, req *pb.ListReplayRequest) (*pb.ListReplayResponse, error)
  • func (h ReplayHandler) Replay(ctx context.Context, req *pb.ReplayRequest) (*pb.ReplayResponse, error)
• type ReplayService

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(_ 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
}

type ReplayHandler

type ReplayHandler struct {
	pb.UnimplementedReplayServiceServer
	// contains filtered or unexported fields
}

func NewReplayHandler

func NewReplayHandler(l log.Logger, service ReplayService) *ReplayHandler

func (ReplayHandler) GetReplay

func (h ReplayHandler) GetReplay(ctx context.Context, req *pb.GetReplayRequest) (*pb.GetReplayResponse, error)

func (ReplayHandler) ListReplay

func (h ReplayHandler) ListReplay(ctx context.Context, req *pb.ListReplayRequest) (*pb.ListReplayResponse, error)

func (ReplayHandler) Replay

func (h ReplayHandler) Replay(ctx context.Context, req *pb.ReplayRequest) (*pb.ReplayResponse, error)

type ReplayService

type ReplayService interface {
	CreateReplay(ctx context.Context, tenant tenant.Tenant, jobName scheduler.JobName, config *scheduler.ReplayConfig) (replayID uuid.UUID, err error)
	GetReplayList(ctx context.Context, projectName tenant.ProjectName) (replays []*scheduler.Replay, err error)
	GetReplayByID(ctx context.Context, replayID uuid.UUID) (replay *scheduler.ReplayWithRun, err error)
}