database

package

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

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/storacha/piri

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func ProvideAggregatorDB(lc fx.Lifecycle, cfg app.StorageConfig) (*sql.DB, error)
func ProvideEgressTrackerDB(lc fx.Lifecycle, cfg app.StorageConfig) (*sql.DB, error)
func ProvideReplicatorDB(lc fx.Lifecycle, cfg app.StorageConfig) (*sql.DB, error)
func ProvideTaskEngineDB(lc fx.Lifecycle, cfg app.StorageConfig) (*gorm.DB, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var Module = fx.Module("database",
	fx.Provide(
		fx.Annotate(
			ProvideReplicatorDB,
			fx.ResultTags(`name:"replicator_db"`),
		),
		fx.Annotate(
			ProvideTaskEngineDB,
			fx.ResultTags(`name:"engine_db"`),
		),
		fx.Annotate(
			ProvideAggregatorDB,
			fx.ResultTags(`name:"aggregator_db"`),
		),
		fx.Annotate(
			ProvideEgressTrackerDB,
			fx.ResultTags(`name:"egress_tracker_db"`),
		),
	),
)

Functions ¶

func ProvideAggregatorDB ¶ added in v0.0.13

func ProvideAggregatorDB(lc fx.Lifecycle, cfg app.StorageConfig) (*sql.DB, error)

func ProvideEgressTrackerDB ¶ added in v0.0.15

func ProvideEgressTrackerDB(lc fx.Lifecycle, cfg app.StorageConfig) (*sql.DB, error)

ProvideEgressTrackerDB provides the SQLite database for the egress tracker job queue

func ProvideReplicatorDB ¶

func ProvideReplicatorDB(lc fx.Lifecycle, cfg app.StorageConfig) (*sql.DB, error)

ProvideReplicatorDB provides the SQLite database for the replicator job queue

func ProvideTaskEngineDB ¶ added in v0.0.13

func ProvideTaskEngineDB(lc fx.Lifecycle, cfg app.StorageConfig) (*gorm.DB, error)

Types ¶

This section is empty.

Source Files ¶

View all Source files

provider.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL