impl

Documentation

Index

• func NewArtifactManager(repo repositories.RepositoryInterface, store *storage.DataStore, ...) interfaces.ArtifactManager
• func NewDatasetManager(repo repositories.RepositoryInterface, store *storage.DataStore, ...) interfaces.DatasetManager
• func NewTagManager(repo repositories.RepositoryInterface, store *storage.DataStore, ...) interfaces.TagManager
• type ArtifactDataStore
  • func NewArtifactDataStore(store *storage.DataStore, storagePrefix storage.DataReference) ArtifactDataStore

Functions

func NewArtifactManager

func NewArtifactManager(repo repositories.RepositoryInterface, store *storage.DataStore, storagePrefix storage.DataReference, artifactScope promutils.Scope) interfaces.ArtifactManager

func NewDatasetManager

func NewDatasetManager(repo repositories.RepositoryInterface, store *storage.DataStore, datasetScope promutils.Scope) interfaces.DatasetManager

func NewTagManager

func NewTagManager(repo repositories.RepositoryInterface, store *storage.DataStore, tagScope promutils.Scope) interfaces.TagManager

Types

type ArtifactDataStore

type ArtifactDataStore interface {
	PutData(ctx context.Context, artifact datacatalog.Artifact, data datacatalog.ArtifactData) (storage.DataReference, error)
	GetData(ctx context.Context, dataModel models.ArtifactData) (*core.Literal, error)
}

ArtifactDataStore stores and retrieves ArtifactData values in a data.pb

func NewArtifactDataStore

func NewArtifactDataStore(store *storage.DataStore, storagePrefix storage.DataReference) ArtifactDataStore