preparation

package

v0.7.0 Latest Latest Go to latest Published: Apr 15, 2026 License: Apache-2.0, MIT Imports: 31 Imported by: 0

Details

This section is empty.

This section is empty.

func OpenRepo(ctx context.Context, cfg appconfig.RepoConfig, opts ...sqlrepo.Option) (*sqlrepo.Repo, error)

OpenRepo opens a database connection and applies migrations. If cfg.IsPostgres(), it connects to PostgreSQL; otherwise it uses SQLite.

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

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 WithAssumeUnchangedSources(assume bool) Option

func WithBlobUploadParallelism(blobUploadParallelism int) Option

func WithEventBus(bus bus.Bus) Option

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

func WithMaxNodesPerIndex(maxNodesPerIndex int) Option

func WithReplicas(replicas uint) Option

WithReplicas sets the number of replicas to use when uploading blobs, including the original. The default is 3 replicas.

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

type StorachaClient = storacha.Client