upstreamidentifier

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 map[string]string) ([]resource.URN, error)
• type EvalAssetFunc
• 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)

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 ...EvalAssetFunc) (*BQUpstreamIdentifier, error)

func (BQUpstreamIdentifier) IdentifyResources

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

type EvalAssetFunc

type EvalAssetFunc func(assets map[string]string) (rawResource string)

EvalAssetFunc returns raw string from a given asset

type ParserFunc

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

ParserFunc parses given raw and return list of resource urns

type UpstreamIdentifier

type UpstreamIdentifier interface {
	IdentifyResources(ctx context.Context, assets 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)