Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions sei-db/ledger_db/parquet/wal.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package parquet

import (
"context"
"encoding/binary"
"fmt"
"os"
Expand Down Expand Up @@ -109,6 +110,7 @@ func NewWAL(logger dbLogger.Logger, dir string) (dbwal.GenericWAL[WALEntry], err
return nil, err
}
return dbwal.NewWAL(
context.Background(),
encodeWALEntry,
decodeWALEntry,
logger,
Expand Down
3 changes: 3 additions & 0 deletions sei-db/wal/changelog.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
package wal

import (
"context"

"github.com/sei-protocol/sei-chain/sei-db/common/logger"
"github.com/sei-protocol/sei-chain/sei-db/proto"
)
Expand All @@ -12,6 +14,7 @@ type ChangelogWAL = GenericWAL[proto.ChangelogEntry]
// This is a convenience wrapper that handles serialization automatically.
func NewChangelogWAL(logger logger.Logger, dir string, config Config) (ChangelogWAL, error) {
return NewWAL(
context.Background(),
func(e proto.ChangelogEntry) ([]byte, error) { return e.Marshal() },
func(data []byte) (proto.ChangelogEntry, error) {
var e proto.ChangelogEntry
Expand Down
Loading
Loading