perf: add optional sync

cmd/blockqueue/http.go

@@ -47,7 +47,10 @@ func (h *Http) Run(ctx context.Context, args []string) error {
 	}
 	db := blockqueue.NewDb(sqlite)
 
-	etcd, err := etcd.New(cfg.Etcd.Path)
+	etcd, err := etcd.New(
+		cfg.Etcd.Path,
+		etcd.WithSync(cfg.Etcd.Sync),
+	)
 	if err != nil {
 		slog.Error("failed to open etcd database", "error", err)
 		return err

cmd/blockqueue/main.go

@@ -143,6 +143,7 @@ type SQLiteConfig struct {
 
 type EtcdConfig struct {
 	Path string `yaml:"path"`
+	Sync bool   `yaml:"sync"`
 }
 
 type JobConfig struct {

config.yaml.example

@@ -8,4 +8,5 @@ sqlite:
   db_name: "blockqueue"
   busy_timeout: 5000
 etcd:
-  path: "etcdb"
+  path: "etcdb"
+  sync: false

pkg/etcd/etcd.go

@@ -8,11 +8,35 @@ type Etcd struct {
 	db *nutsdb.DB
 }
 
-func New(dbName string) (*Etcd, error) {
+type option struct {
+	// sync represents if call Sync() function.
+	// if SyncEnable is false, high write performance but potential data loss likely.
+	// if SyncEnable is true, slower but persistent.
+	sync bool
+}
+
+type opt func(*option)
+
+func WithSync(sync bool) opt {
+	return func(o *option) {
+		o.sync = sync
+	}
+}
+
+func New(dbName string, opts ...opt) (*Etcd, error) {
+	opt := &option{
+		sync: true,
+	}
+
+	for _, o := range opts {
+		o(opt)
+	}
+
 	db, err := nutsdb.Open(
 		nutsdb.DefaultOptions,
 		nutsdb.WithDir(dbName),
 		nutsdb.WithEntryIdxMode(nutsdb.HintKeyAndRAMIdxMode),
+		nutsdb.WithSyncEnable(opt.sync),
 	)
 	if err != nil {
 		return &Etcd{}, err