linkinfo

type CompositeSource ¶

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

CompositeSource is a Source that aggregates multiple underlying Sources. It queries each Source in order and returns the first successful result.

func NewCompositeSource(sources ...Source) *CompositeSource

func (s *CompositeSource) LookupLink(
	ctx context.Context,
	typeA string,
	typeB string,
) (*LinkInfo, bool, error)

type LinkInfo ¶

type LinkInfo struct {
	ResourceTypeA         string
	ResourceTypeB         string
	AnnotationDefinitions map[string]*provider.LinkAnnotationDefinition
	CardinalityA          provider.LinkCardinality
	CardinalityB          provider.LinkCardinality
	Origin                LinkInfoOrigin
}

type LinkInfoOrigin ¶

type LinkInfoOrigin string

LinkInfoOrigin indicates where the link info was sourced from, which can be used for telemetry and debugging purposes.

const (
	// LinkInfoOriginProvider indicates that the link info was sourced from a concrete provider plugin.
	LinkInfoOriginProvider LinkInfoOrigin = "provider"
	// LinkInfoOriginTransformer indicates that the link info was sourced from an abstract transformer plugin.
	LinkInfoOriginTransformer LinkInfoOrigin = "transformer"
)

type ProviderSource ¶

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

ProviderSource is a Source that retrieves link info from provider plugins.

func NewProviderSource(linkRegistry provider.LinkRegistry) *ProviderSource

func (s *ProviderSource) LookupLink(
	ctx context.Context,
	typeA string,
	typeB string,
) (*LinkInfo, bool, error)

type Source ¶

type Source interface {
	// LookupLink finds link info for (typeA, typeB). Returns ok=false if no
	// link exists in this source in either direction.
	LookupLink(
		ctx context.Context,
		typeA string,
		typeB string,
	) (*LinkInfo, bool, error)
}

Source exposes cardinality information and annotation definitions for a pair of linked resource types that supports both concrete provider and abstract transformer links.

type TransformerSource ¶

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

TransformerSource is a Source that retrieves link info from transformer plugins.

func NewTransformerSource(transformers map[string]transform.SpecTransformer) *TransformerSource

func (s *TransformerSource) LookupLink(
	ctx context.Context,
	typeA string,
	typeB string,
) (*LinkInfo, bool, error)