dbsync

package

v2026.3.0 Latest Latest Go to latest Published: Mar 8, 2026 License: Apache-2.0 Imports: 30 Imported by: 0

Details

This section is empty.

View Source

var Module = fx.Module("dbsync",
	fx.Provide(
		New,
	),
)

func NewDB(p DBParams) (*sql.DB, error)

type DBParams struct {
	fx.In

	LC fx.Lifecycle

	Config *dbsyncconfig.Config
}

type Params struct {
	fx.In

	LC fx.Lifecycle

	Logger *zap.Logger
	Config *dbsyncconfig.Config
	DB     *sql.DB
	State  *dbsyncconfig.State
}

type Result struct {
	fx.Out

	Sync *Sync
}

type Sync struct {
	// contains filtered or unexported fields
}

func New(p Params) (*Sync, error)

func (s *Sync) RunStream(ctx context.Context)