resolver

package

v0.26.2 Latest Latest Go to latest Published: Jul 23, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/goto/optimus

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewDexUpstreamResolver(l log.Logger, client service.ThirdPartyClient, ...) *dexUpstreamResolver
func NewExternalUpstreamResolver(resourceManagerConfigs []config.ResourceManager) (*extUpstreamResolver, error)
func NewInternalUpstreamResolver(jobRepository JobRepository) *internalUpstreamResolver
type ExternalUpstreamResolver
- func NewTestExternalUpstreamResolver(optimusResourceManagers []resourcemanager.ResourceManager) ExternalUpstreamResolver
type InternalUpstreamResolver
type JobRepository
type ResourceManager
type TenantDetailsGetter
type ThirdPartyUpstreamResolver
- func NewThirdPartyUpstreamResolvers(l log.Logger, tenantDetailsGetter TenantDetailsGetter, ...) ([]ThirdPartyUpstreamResolver, error)
type UpstreamResolver
- func NewUpstreamResolver(jobRepository JobRepository, externalUpstreamResolver ExternalUpstreamResolver, ...) *UpstreamResolver

Constants ¶

View Source

const (
	ConcurrentTicketPerSec = 50
	ConcurrentLimit        = 100
)

Variables ¶

This section is empty.

Functions ¶

func NewDexUpstreamResolver ¶ added in v0.22.14

func NewDexUpstreamResolver(l log.Logger, client service.ThirdPartyClient, tenantDetailsGetter TenantDetailsGetter) *dexUpstreamResolver

func NewExternalUpstreamResolver ¶

func NewExternalUpstreamResolver(resourceManagerConfigs []config.ResourceManager) (*extUpstreamResolver, error)

NewExternalUpstreamResolver creates a new instance of externalUpstreamResolver

func NewInternalUpstreamResolver ¶

func NewInternalUpstreamResolver(jobRepository JobRepository) *internalUpstreamResolver

Types ¶

type ExternalUpstreamResolver ¶

type ExternalUpstreamResolver interface {
	Resolve(ctx context.Context, jobWithUpstream *job.WithUpstream, lw writer.LogWriter) (*job.WithUpstream, error)
	BulkResolve(context.Context, []*job.WithUpstream, writer.LogWriter) ([]*job.WithUpstream, error)
}

func NewTestExternalUpstreamResolver ¶

func NewTestExternalUpstreamResolver(
	optimusResourceManagers []resourcemanager.ResourceManager,
) ExternalUpstreamResolver

type InternalUpstreamResolver ¶

type InternalUpstreamResolver interface {
	Resolve(context.Context, *job.WithUpstream) (*job.WithUpstream, error)
	BulkResolve(context.Context, tenant.ProjectName, []*job.WithUpstream) ([]*job.WithUpstream, error)
}

type JobRepository ¶

type JobRepository interface {
	ResolveUpstreams(ctx context.Context, projectName tenant.ProjectName, jobNames []job.Name) (map[job.Name][]*job.Upstream, error)

	GetAllByResourceDestination(ctx context.Context, resourceDestination resource.URN) ([]*job.Job, error)
	GetByJobName(ctx context.Context, projectName tenant.ProjectName, jobName job.Name) (*job.Job, error)
}

type ResourceManager ¶

type ResourceManager interface {
	GetOptimusUpstreams(ctx context.Context, unresolvedDependency *job.Upstream) ([]*job.Upstream, error)
}

type TenantDetailsGetter ¶ added in v0.22.14

type TenantDetailsGetter interface {
	GetDetails(ctx context.Context, jobTenant tenant.Tenant) (*tenant.WithDetails, error)
}

type ThirdPartyUpstreamResolver ¶ added in v0.22.14

type ThirdPartyUpstreamResolver interface {
	BulkResolve(ctx context.Context, jobsWithUpstreams []*job.WithUpstream, lw writer.LogWriter) ([]*job.WithUpstream, error)
	Resolve(ctx context.Context, jobWithUpstream *job.WithUpstream, lw writer.LogWriter) (*job.WithUpstream, error)
}

func NewThirdPartyUpstreamResolvers ¶ added in v0.22.14

func NewThirdPartyUpstreamResolvers(l log.Logger, tenantDetailsGetter TenantDetailsGetter, upstreamResolvers ...config.UpstreamResolver) ([]ThirdPartyUpstreamResolver, error)

type UpstreamResolver ¶

type UpstreamResolver struct {
	// contains filtered or unexported fields
}

func NewUpstreamResolver ¶

func NewUpstreamResolver(jobRepository JobRepository, externalUpstreamResolver ExternalUpstreamResolver, internalUpstreamResolver InternalUpstreamResolver, thirdPartyUpstreamResolvers ...ThirdPartyUpstreamResolver) *UpstreamResolver

func (UpstreamResolver) BulkResolve ¶

func (u UpstreamResolver) BulkResolve(ctx context.Context, jobs []*job.Job, logWriter writer.LogWriter) ([]*job.WithUpstream, error)

func (UpstreamResolver) CheckStaticResolvable ¶ added in v0.11.0

func (u UpstreamResolver) CheckStaticResolvable(ctx context.Context, tnnt tenant.Tenant, incomingJobs []*job.Job, logWriter writer.LogWriter) error

func (UpstreamResolver) Resolve ¶

func (u UpstreamResolver) Resolve(ctx context.Context, subjectJob *job.Job, logWriter writer.LogWriter) ([]*job.Upstream, error)

Source Files ¶

View all Source files

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