v1beta1

package
v0.23.0 Latest Latest
Warning

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

 Go to latest Published: Nov 6, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type JobLineageService added in v0.22.4 

type JobLineageService interface {
	GetJobExecutionSummary(ctx context.Context, jobSchedules []*scheduler.JobSchedule, numberOfUpstreamPerLevel int) ([]*scheduler.JobRunLineage, error)
}

type JobRunHandler 

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

func NewJobRunHandler 

func NewJobRunHandler(
	l log.Logger,
	service JobRunService,
	notifier Notifier,
	schedulerService SchedulerService,
	jobLineageService JobLineageService,
	jobSLAPredictorService JobSLAPredictorService,
	thirdPartySensorService ThirdPartySensorService,
) *JobRunHandler

func (JobRunHandler) CreateSchedulerRole added in v0.19.0 

func (h JobRunHandler) CreateSchedulerRole(ctx context.Context, req *pb.CreateSchedulerRoleRequest) (*pb.CreateSchedulerRoleResponse, error)

func (JobRunHandler) GetDexSensorStatus added in v0.22.14 

func (h JobRunHandler) GetDexSensorStatus(ctx context.Context, resourceURN resource.URN, startTime, endTime time.Time) (*pb.DexSensorResponse, error)

func (JobRunHandler) GetInterval added in v0.10.0 

func (h JobRunHandler) GetInterval(ctx context.Context, req *pb.GetIntervalRequest) (*pb.GetIntervalResponse, error)

GetInterval gets interval on specific job given reference time.

func (JobRunHandler) GetJobRunLineageSummary added in v0.22.4 

func (h JobRunHandler) GetJobRunLineageSummary(ctx context.Context, req *pb.GetJobRunLineageSummaryRequest) (*pb.GetJobRunLineageSummaryResponse, error)

func (JobRunHandler) GetJobRuns added in v0.17.0 

func (h JobRunHandler) GetJobRuns(ctx context.Context, req *pb.GetJobRunsRequest) (*pb.GetJobRunsResponse, error)

GetJobRuns gets job runs from optimus DB based on the criteria

func (JobRunHandler) GetSchedulerRole added in v0.19.0 

func (h JobRunHandler) GetSchedulerRole(ctx context.Context, req *pb.GetSchedulerRoleRequest) (*pb.GetSchedulerRoleResponse, error)

func (JobRunHandler) GetThirdPartySensorStatus added in v0.22.14 

func (h JobRunHandler) GetThirdPartySensorStatus(ctx context.Context, req *pb.GetThirdPartySensorRequest) (*pb.GetThirdPartySensorResponse, error)

GetThirdPartySensorStatus gets third party sensor status

func (JobRunHandler) IdentifyPotentialSLABreach added in v0.22.4 

func (h JobRunHandler) IdentifyPotentialSLABreach(ctx context.Context, req *pb.IdentifyPotentialSLABreachRequest) (*pb.IdentifyPotentialSLABreachResponse, error)

IdentifyPotentialSLABreach predicts potential SLA breaches for the given job targets at their targeted SLA time

func (JobRunHandler) JobRun 

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

JobRun gets the job runs from scheduler based on the criteria

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
	GetJobRunsByFilter(ctx context.Context, projectName tenant.ProjectName, jobName scheduler.JobName, filters ...filter.FilterOpt) ([]*scheduler.JobRun, error)
	GetJobRuns(ctx context.Context, projectName tenant.ProjectName, jobName scheduler.JobName, criteria *scheduler.JobRunsCriteria) ([]*scheduler.JobRunStatus, string, error)
	UploadToScheduler(ctx context.Context, projectName tenant.ProjectName) error
	GetInterval(ctx context.Context, projectName tenant.ProjectName, jobName scheduler.JobName, referenceTime time.Time) (interval.Interval, error)
}

type JobSLAPredictorService added in v0.22.4 

type JobSLAPredictorService interface {
	IdentifySLABreaches(ctx context.Context, projectName tenant.ProjectName, referenceTime time.Time, scheduleRangeInHours time.Duration, jobNames []scheduler.JobName, labels map[string]string, enableAlert bool, severity string) (map[scheduler.JobName]map[scheduler.JobName]*service.JobState, error)
}

type Notifier 

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

type ReplayHandler added in v0.7.0 

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

func NewReplayHandler added in v0.7.0 

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

func (ReplayHandler) CancelReplay added in v0.11.3 

func (h ReplayHandler) CancelReplay(ctx context.Context, req *pb.CancelReplayRequest) (*pb.CancelReplayResponse, error)

func (ReplayHandler) GetReplay added in v0.7.0 

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

func (ReplayHandler) GetReplayDetails added in v0.16.1 

func (h ReplayHandler) GetReplayDetails(ctx context.Context, req *pb.GetReplayDetailsRequest) (*pb.GetReplayDetailsResponse, error)

func (ReplayHandler) ListReplay added in v0.7.0 

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

func (ReplayHandler) Replay added in v0.7.0 

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

func (ReplayHandler) ReplayDryRun added in v0.9.0 

func (h ReplayHandler) ReplayDryRun(ctx context.Context, req *pb.ReplayDryRunRequest) (*pb.ReplayDryRunResponse, error)

type ReplayService added in v0.7.0 

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)
	GetByFilter(ctx context.Context, project tenant.ProjectName, filters ...filter.FilterOpt) ([]*scheduler.ReplayWithRun, error)
	GetReplayByID(ctx context.Context, replayID uuid.UUID) (replay *scheduler.ReplayWithRun, err error)
	GetRunsStatus(ctx context.Context, tenant tenant.Tenant, jobName scheduler.JobName, config *scheduler.ReplayConfig) (runs []*scheduler.JobRunStatus, err error)
	CancelReplay(ctx context.Context, replayWithRun *scheduler.ReplayWithRun) error
}

type SchedulerService added in v0.19.0 

type SchedulerService interface {
	CreateSchedulerRole(ctx context.Context, t tenant.Tenant, roleName string) error
	GetRolePermissions(ctx context.Context, t tenant.Tenant, roleName string) ([]string, error)
}

type ThirdPartySensorService added in v0.22.14 

type ThirdPartySensorService interface {
	GetClient(upstreamResolverType config.UpstreamResolverType) (service.ThirdPartyClient, 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.