preparation

package

v0.2.0 Latest Latest Go to latest Published: Dec 5, 2025 License: Apache-2.0, MIT Imports: 27 Imported by: 0

Details

This section is empty.

This section is empty.

func OpenRepo(ctx context.Context, dbPath string) (*sqlrepo.Repo, error)

type API struct {
	Repo    Repo
	Spaces  spaces.API
	Uploads uploads.API
	Sources sources.API
	DAGs    dags.API
	Scans   scans.API
}

func NewAPI(repo Repo, client StorachaClient, options ...Option) API

func (a API) AddSourceToSpace(ctx context.Context, spaceDID did.DID, sourceID id.SourceID) error

func (a API) CreateSource(ctx context.Context, name string, path string, options ...sourcesmodel.SourceOption) (*sourcesmodel.Source, error)

func (a API) ExecuteUpload(ctx context.Context, upload *uploadsmodel.Upload) (cid.Cid, error)

func (a API) FindOrCreateSpace(ctx context.Context, spaceDID did.DID, name string, options ...spacesmodel.SpaceOption) (*spacesmodel.Space, error)

func (a API) FindOrCreateUploads(ctx context.Context, spaceDID did.DID) ([]*uploadsmodel.Upload, error)

func (a API) GetUploadByID(ctx context.Context, uploadID id.UploadID) (*uploadsmodel.Upload, error)

type Option func(cfg *config) error

Option is an option configuring the API.

func WithGetLocalFSForPathFn(getLocalFSForPathFn func(path string) (fs.FS, error)) Option

func WithMaxNodesPerIndex(maxNodesPerIndex int) Option

func WithShardUploadParallelism(shardUploadParallelism int) Option

type Repo interface {
	spaces.Repo
	uploads.Repo
	sources.Repo
	scans.Repo
	dags.Repo
	shards.Repo
}

type StorachaClient = storacha.Client