sqlfx

var GoquModule = fx.Module("geck/persistence/sql/goqu",
	fx.Invoke(
		func() {
			goqu.SetTimeLocation(time.UTC)
		},
	),
)

GoquModule is the `uber/fx` module of the goqu package.

var InterceptorModule = fx.Module("geck/persistence/sql/interceptors",
	fx.Provide(
		func(deps databaseInterceptorsDeps) gecksql.DB {
			opts := make([]gecksql.DatabaseOption, 0, len(deps.Interceptors))
			for _, interceptor := range deps.Interceptors {
				opts = append(opts, gecksql.WithInterceptor(interceptor))
			}
			return gecksql.NewDB(deps.Database, opts...)
		},
	),
)

InterceptorModule is a `uber/fx` module providing gecksql.DBInterceptor instances so driver-specific submodules can integrate additional behavior (e.g. observability, transaction contexts) into their concrete implementations of gecksql.DB.

var ObservabilityModule = fx.Module("geck/persistence/sql/interceptors/observability",
	fx.Provide(
		AsDBInterceptor(gecksql.NewDatabaseLogger),
	),
)

ObservabilityModule is a `uber/fx` module providing gecksql.DBInterceptor instances so driver-specific submodules can integrate observability tools (i.e. logging, metrics, tracing) into their concrete implementations of gecksql.DB.

Requires to be declared along InterceptorModule.

var TransactionModule = fx.Module("geck/persistence/sql/interceptors/tx",
	fx.Provide(
		AsDBInterceptor(gecksql.NewDatabaseTxPropagator),
	),
)

TransactionModule is a `uber/fx` module providing a gecksql.DatabaseTxPropagator instance (as gecksql.DBInterceptor) so driver-specific submodules can integrate transaction propagation features into their concrete implementations of gecksql.DB.

Requires to be declared along InterceptorModule.