Versions in this module Expand all Collapse all v0 v0.7.1 Jul 25, 2023 v0.7.0 Jul 20, 2023 Changes in this version + const ConcurrentLimit + const ConcurrentTicketPerSec + func NewExternalUpstreamResolver(resourceManagerConfigs []config.ResourceManager) (*extUpstreamResolver, error) + func NewInternalUpstreamResolver(jobRepository JobRepository) *internalUpstreamResolver + type ExternalUpstreamResolver interface + BulkResolve func(context.Context, []*job.WithUpstream, writer.LogWriter) ([]*job.WithUpstream, error) + Resolve func(ctx context.Context, jobWithUpstream *job.WithUpstream, lw writer.LogWriter) (*job.WithUpstream, error) + func NewTestExternalUpstreamResolver(optimusResourceManagers []resourcemanager.ResourceManager) ExternalUpstreamResolver + type InternalUpstreamResolver interface + BulkResolve func(context.Context, tenant.ProjectName, []*job.WithUpstream) ([]*job.WithUpstream, error) + Resolve func(context.Context, *job.WithUpstream) (*job.WithUpstream, error) + type JobRepository interface + GetAllByResourceDestination func(ctx context.Context, resourceDestination job.ResourceURN) ([]*job.Job, error) + GetByJobName func(ctx context.Context, projectName tenant.ProjectName, jobName job.Name) (*job.Job, error) + ResolveUpstreams func(ctx context.Context, projectName tenant.ProjectName, jobNames []job.Name) (map[job.Name][]*job.Upstream, error) + type ResourceManager interface + GetOptimusUpstreams func(ctx context.Context, unresolvedDependency *job.Upstream) ([]*job.Upstream, error) + type UpstreamResolver struct + func NewUpstreamResolver(jobRepository JobRepository, externalUpstreamResolver ExternalUpstreamResolver, ...) *UpstreamResolver + func (u UpstreamResolver) BulkResolve(ctx context.Context, projectName tenant.ProjectName, jobs []*job.Job, ...) ([]*job.WithUpstream, error) + func (u UpstreamResolver) Resolve(ctx context.Context, subjectJob *job.Job, logWriter writer.LogWriter) ([]*job.Upstream, error)
Go to main page