v1beta1

package

v0.16.0 Latest Latest Go to latest Published: Aug 5, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/goto/optimus

Links

Open Source Insights

Documentation ¶

Index ¶

func ToJobProto(jobEntity *job.Job) *pb.JobSpecification
type ChangeLogService
type JobHandler
- func NewJobHandler(jobService JobService, changeLogService ChangeLogService, logger log.Logger) *JobHandler
type JobModificationService
type JobQueryService
type JobService
type JobStatusService

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ToJobProto ¶ added in v0.7.0

func ToJobProto(jobEntity *job.Job) *pb.JobSpecification

Types ¶

type ChangeLogService ¶ added in v0.13.0

type ChangeLogService interface {
	GetChangelog(ctx context.Context, projectName tenant.ProjectName, jobName job.Name) ([]*job.ChangeLog, error)
}

type JobHandler ¶

type JobHandler struct {
	pb.UnimplementedJobSpecificationServiceServer
	// contains filtered or unexported fields
}

func NewJobHandler ¶

func NewJobHandler(jobService JobService, changeLogService ChangeLogService, logger log.Logger) *JobHandler

func (*JobHandler) AddJobSpecifications ¶

func (jh *JobHandler) AddJobSpecifications(ctx context.Context, jobSpecRequest *pb.AddJobSpecificationsRequest) (*pb.AddJobSpecificationsResponse, error)

func (*JobHandler) BulkDeleteJobs ¶ added in v0.16.0

func (jh *JobHandler) BulkDeleteJobs(ctx context.Context, bulkDeleteRequest *pb.BulkDeleteJobsRequest) (*pb.BulkDeleteJobsResponse, error)

func (*JobHandler) ChangeJobNamespace ¶ added in v0.8.0

func (jh *JobHandler) ChangeJobNamespace(ctx context.Context, changeRequest *pb.ChangeJobNamespaceRequest) (*pb.ChangeJobNamespaceResponse, error)

func (*JobHandler) CheckJobSpecifications deprecated

func (*JobHandler) CheckJobSpecifications(_ *pb.CheckJobSpecificationsRequest, _ pb.JobSpecificationService_CheckJobSpecificationsServer) error

Deprecated: Do not use.

func (*JobHandler) DeleteJobSpecification ¶

func (jh *JobHandler) DeleteJobSpecification(ctx context.Context, deleteRequest *pb.DeleteJobSpecificationRequest) (*pb.DeleteJobSpecificationResponse, error)

func (*JobHandler) GetJobChangelog ¶ added in v0.13.0

func (jh *JobHandler) GetJobChangelog(ctx context.Context, req *pb.GetJobChangelogRequest) (*pb.GetJobChangelogResponse, error)

func (*JobHandler) GetJobSpecification ¶

func (jh *JobHandler) GetJobSpecification(ctx context.Context, req *pb.GetJobSpecificationRequest) (*pb.GetJobSpecificationResponse, error)

func (*JobHandler) GetJobSpecifications ¶

func (jh *JobHandler) GetJobSpecifications(ctx context.Context, req *pb.GetJobSpecificationsRequest) (*pb.GetJobSpecificationsResponse, error)

func (*JobHandler) GetJobTask ¶

func (jh *JobHandler) GetJobTask(ctx context.Context, req *pb.GetJobTaskRequest) (*pb.GetJobTaskResponse, error)

func (*JobHandler) GetWindow ¶

func (jh *JobHandler) GetWindow(_ context.Context, req *pb.GetWindowRequest) (*pb.GetWindowResponse, error)

func (*JobHandler) JobInspect ¶

func (jh *JobHandler) JobInspect(ctx context.Context, req *pb.JobInspectRequest) (*pb.JobInspectResponse, error)

func (*JobHandler) ListJobSpecification ¶

func (jh *JobHandler) ListJobSpecification(ctx context.Context, req *pb.ListJobSpecificationRequest) (*pb.ListJobSpecificationResponse, error)

func (*JobHandler) RefreshJobs ¶

func (jh *JobHandler) RefreshJobs(request *pb.RefreshJobsRequest, stream pb.JobSpecificationService_RefreshJobsServer) error

func (*JobHandler) ReplaceAllJobSpecifications ¶

func (jh *JobHandler) ReplaceAllJobSpecifications(stream pb.JobSpecificationService_ReplaceAllJobSpecificationsServer) error

func (*JobHandler) SyncJobsState ¶ added in v0.9.0

func (jh *JobHandler) SyncJobsState(ctx context.Context, req *pb.SyncJobsStateRequest) (*pb.SyncJobsStateResponse, error)

func (*JobHandler) UpdateJobSpecifications ¶

func (jh *JobHandler) UpdateJobSpecifications(ctx context.Context, jobSpecRequest *pb.UpdateJobSpecificationsRequest) (*pb.UpdateJobSpecificationsResponse, error)

func (*JobHandler) UpdateJobsState ¶ added in v0.9.0

func (jh *JobHandler) UpdateJobsState(ctx context.Context, req *pb.UpdateJobsStateRequest) (*pb.UpdateJobsStateResponse, error)

func (*JobHandler) UpsertJobSpecifications ¶ added in v0.14.0

func (jh *JobHandler) UpsertJobSpecifications(ctx context.Context, jobSpecRequest *pb.UpsertJobSpecificationsRequest) (*pb.UpsertJobSpecificationsResponse, error)

func (*JobHandler) Validate ¶ added in v0.12.0

func (jh *JobHandler) Validate(ctx context.Context, request *pb.ValidateRequest) (*pb.ValidateResponse, error)

type JobModificationService ¶ added in v0.14.0

type JobModificationService interface {
	Add(ctx context.Context, jobTenant tenant.Tenant, jobs []*job.Spec) ([]job.Name, error)
	Update(ctx context.Context, jobTenant tenant.Tenant, jobs []*job.Spec) ([]job.Name, error)
	Upsert(ctx context.Context, jobTenant tenant.Tenant, jobs []*job.Spec) ([]dto.UpsertResult, error)
	Delete(ctx context.Context, jobTenant tenant.Tenant, jobName job.Name, cleanFlag, forceFlag bool) (affectedDownstream []job.FullName, err error)
	ReplaceAll(ctx context.Context, jobTenant tenant.Tenant, jobs []*job.Spec, jobNamesWithInvalidSpec []job.Name, logWriter writer.LogWriter) error
	ChangeNamespace(ctx context.Context, jobSourceTenant, jobNewTenant tenant.Tenant, jobName job.Name) error
	BulkDeleteJobs(ctx context.Context, projectName tenant.ProjectName, jobsToDelete []*dto.JobToDeleteRequest) (map[string]dto.BulkDeleteTracker, error)
}

type JobQueryService ¶ added in v0.14.0

type JobQueryService interface {
	Get(ctx context.Context, jobTenant tenant.Tenant, jobName job.Name) (jobSpec *job.Job, err error)
	GetTaskInfo(ctx context.Context, task job.Task) (*plugin.Info, error)
	GetJobBasicInfo(ctx context.Context, jobTenant tenant.Tenant, jobName job.Name, spec *job.Spec) (*job.Job, writer.BufferedLogger)
	GetByFilter(ctx context.Context, filters ...filter.FilterOpt) (jobSpecs []*job.Job, err error)
	GetUpstreamsToInspect(ctx context.Context, subjectJob *job.Job, localJob bool) ([]*job.Upstream, error)
	GetDownstream(ctx context.Context, job *job.Job, localJob bool) ([]*job.Downstream, error)
}

type JobService ¶

type JobService interface {
	JobQueryService
	JobModificationService
	JobStatusService
}

type JobStatusService ¶ added in v0.14.0

type JobStatusService interface {
	Refresh(ctx context.Context, projectName tenant.ProjectName, namespaceNames, jobNames []string, logWriter writer.LogWriter) error
	SyncState(ctx context.Context, jobTenant tenant.Tenant, disabledJobNames, enabledJobNames []job.Name) error
	UpdateState(ctx context.Context, jobTenant tenant.Tenant, jobNames []job.Name, jobState job.State, remark string) error
	Validate(context.Context, dto.ValidateRequest) (map[job.Name][]dto.ValidateResult, error)
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL