schema

type AssetType ¶

type AssetType string

AssetType define an asset type

type AssetValidationFunc ¶ added in v0.0.66

type AssetValidationFunc func(string) bool

type Persistor ¶

type Persistor interface {
	SaveSchema(ctx context.Context, sourceName string, sg SchemaGraph) error
	LoadSchema(ctx context.Context, sourceName string) (SchemaGraph, error)
}

Persistor is a persistor of schema

type RelationKeyType ¶

type RelationKeyType string

RelationKeyType define a relation type

type RelationType ¶

type RelationType struct {
	FromType AssetType       `json:"from_type"`
	Type     RelationKeyType `json:"relation_type"`
	ToType   AssetType       `json:"to_type"`
}

RelationType define a relation type

type SchemaGraph ¶

type SchemaGraph struct {
	Vertices mapset.Set
	Edges    mapset.Set
}

SchemaGraph represent the graph of a source

func NewSchemaGraph() SchemaGraph

func (sg *SchemaGraph) AddAsset(assetType string) AssetType

func (sg *SchemaGraph) AddRelation(fromType AssetType, relationType string, toType AssetType) RelationType

func (sg *SchemaGraph) Assets() []AssetType

func (sg *SchemaGraph) Equal(other SchemaGraph) bool

func (sg *SchemaGraph) MarshalJSON() ([]byte, error)

func (sg *SchemaGraph) Merge(other SchemaGraph)

func (sg *SchemaGraph) Relations() []RelationType

func (sg *SchemaGraph) UnmarshalJSON(b []byte) error

type SchemaGraphJSON ¶

type SchemaGraphJSON struct {
	Vertices []AssetType    `json:"vertices"`
	Edges    []RelationType `json:"edges"`
}

SchemaGraphJSON is the json representation of a schema graph

type ValidationRegistry ¶ added in v0.0.66

type ValidationRegistry interface {
	Get(AssetType) ([]AssetValidationFunc, bool)
}

var (
	AssetValidationRegistry ValidationRegistry = utils.NewRegistry[AssetType, []AssetValidationFunc]()
)