parent
59a0f52883
commit
9d7879fff4
|
@ -62,11 +62,11 @@ func NewLibSqlDB(primaryUrl string, migrationFiles embed.FS, opts ...Options) (*
|
||||||
}
|
}
|
||||||
|
|
||||||
if l.readYourWrites != nil {
|
if l.readYourWrites != nil {
|
||||||
lsOpts = append(lsOpts, libsql.WithReadYourWrites(&l.readYourWrites))
|
lsOpts = append(lsOpts, libsql.WithReadYourWrites(*l.readYourWrites))
|
||||||
}
|
}
|
||||||
|
|
||||||
connector, err := libsql.NewEmbeddedReplicaConnector(dbPath, primaryUrl,
|
connector, err := libsql.NewEmbeddedReplicaConnector(dbPath, primaryUrl,
|
||||||
lsOpts,
|
lsOpts...,
|
||||||
)
|
)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("error creating connector | %w", err)
|
return nil, fmt.Errorf("error creating connector | %w", err)
|
||||||
|
|
Loading…
Reference in New Issue