impl

Documentation

Index

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

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 NewReservationManager

func NewReservationManager(
	repo repositories.RepositoryInterface,
	heartbeatGracePeriodMultiplier time.Duration,
	maxHeartbeatInterval time.Duration,
	nowFunc NowFunc,
	reservationScope promutils.Scope,
) interfaces.ReservationManager

Creates a new reservation manager with the specified properties

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)
	DeleteData(ctx context.Context, dataModel models.ArtifactData) error
}

ArtifactDataStore stores and retrieves ArtifactData values in a data.pb

func NewArtifactDataStore

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

type NowFunc

type NowFunc func() time.Time