upstreamidentifier

package

v0.23.31 Latest Latest Go to latest Published: Mar 20, 2026 License: Apache-2.0 Imports: 10 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 ¶

type BQExtractorFunc
type BQUpstreamIdentifier
- func NewBQUpstreamIdentifier(logger log.Logger, parserFunc ParserFunc, bqExtractorFunc BQExtractorFunc, ...) (*BQUpstreamIdentifier, error)
- func (g BQUpstreamIdentifier) IdentifyResources(ctx context.Context, assets, config map[string]string) ([]resource.URN, error)
type EvalFunc
type ExtractorFunc
type MaxcomputeUpstreamIdentifier
- func NewMaxcomputeUpstreamIdentifier(logger log.Logger, parserFunc ParserFunc, extractorFunc ExtractorFunc, ...) (*MaxcomputeUpstreamIdentifier, error)
- func (g MaxcomputeUpstreamIdentifier) IdentifyResources(ctx context.Context, assets, config map[string]string) ([]resource.URN, error)
type ParserFunc
type UpstreamIdentifier
type UpstreamIdentifierFactory
- func NewUpstreamIdentifierFactory(logger log.Logger) (*UpstreamIdentifierFactory, error)
- func (u *UpstreamIdentifierFactory) GetBQUpstreamIdentifier(ctx context.Context, svcAcc string, evaluators ...evaluator.Evaluator) (UpstreamIdentifier, error)
- func (u *UpstreamIdentifierFactory) GetMaxcomputeUpstreamIdentifier(_ context.Context, svcAcc string, evaluators ...evaluator.Evaluator) (UpstreamIdentifier, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BQExtractorFunc ¶

type BQExtractorFunc func(context.Context, []bigquery.ResourceURN) (map[bigquery.ResourceURN]string, error)

type BQUpstreamIdentifier ¶

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

func NewBQUpstreamIdentifier ¶

func NewBQUpstreamIdentifier(logger log.Logger, parserFunc ParserFunc, bqExtractorFunc BQExtractorFunc, evaluatorFuncs ...EvalFunc) (*BQUpstreamIdentifier, error)

func (BQUpstreamIdentifier) IdentifyResources ¶

func (g BQUpstreamIdentifier) IdentifyResources(ctx context.Context, assets, config map[string]string) ([]resource.URN, error)

type EvalFunc ¶ added in v0.19.0

type EvalFunc func(assets, config map[string]string) (rawResource string)

EvalFunc returns raw string from a given asset

type ExtractorFunc ¶ added in v0.19.0

type ExtractorFunc func(ctx context.Context, resources []string) (map[string]string, error)

ExtractorFunc extracts the ddl from the given resource urns

type MaxcomputeUpstreamIdentifier ¶ added in v0.19.0

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

func NewMaxcomputeUpstreamIdentifier ¶ added in v0.19.0

func NewMaxcomputeUpstreamIdentifier(logger log.Logger, parserFunc ParserFunc, extractorFunc ExtractorFunc, evaluatorFuncs ...EvalFunc) (*MaxcomputeUpstreamIdentifier, error)

func (MaxcomputeUpstreamIdentifier) IdentifyResources ¶ added in v0.19.0

func (g MaxcomputeUpstreamIdentifier) IdentifyResources(ctx context.Context, assets, config map[string]string) ([]resource.URN, error)

type ParserFunc ¶

type ParserFunc func(rawResource string) (resources []string)

ParserFunc parses given raw and return list of resource urns

type UpstreamIdentifier ¶

type UpstreamIdentifier interface {
	IdentifyResources(ctx context.Context, assets, config map[string]string) ([]resource.URN, error)
}

type UpstreamIdentifierFactory ¶

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

func NewUpstreamIdentifierFactory ¶

func NewUpstreamIdentifierFactory(logger log.Logger) (*UpstreamIdentifierFactory, error)

func (*UpstreamIdentifierFactory) GetBQUpstreamIdentifier ¶

func (u *UpstreamIdentifierFactory) GetBQUpstreamIdentifier(ctx context.Context, svcAcc string, evaluators ...evaluator.Evaluator) (UpstreamIdentifier, error)

func (*UpstreamIdentifierFactory) GetMaxcomputeUpstreamIdentifier ¶ added in v0.19.0

func (u *UpstreamIdentifierFactory) GetMaxcomputeUpstreamIdentifier(_ context.Context, svcAcc string, evaluators ...evaluator.Evaluator) (UpstreamIdentifier, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
evaluator
parser

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