database

package

v0.2.3 Latest Latest Go to latest Published: Mar 20, 2026 License: Apache-2.0, MIT Imports: 13 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 ¶

Constants
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 ¶

View Source

const (
	SchemaReplicator    = "replicator"
	SchemaAggregator    = "aggregator"
	SchemaEgressTracker = "egress_tracker"
	SchemaScheduler     = "scheduler"
)

PostgreSQL schema names for each logical database

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)

ProvideAggregatorDB provides the database for the aggregator job queue. Supports both SQLite (default) and PostgreSQL backends.

func ProvideEgressTrackerDB ¶ added in v0.0.15

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

ProvideEgressTrackerDB provides the database for the egress tracker job queue. Supports both SQLite (default) and PostgreSQL backends.

func ProvideReplicatorDB ¶

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

ProvideReplicatorDB provides the database for the replicator job queue. Supports both SQLite (default) and PostgreSQL backends.

func ProvideTaskEngineDB ¶ added in v0.0.13

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

ProvideTaskEngineDB provides the GORM database for the task engine scheduler. Supports both SQLite (default) and PostgreSQL backends.

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