diff --git a/parser/pbf/lowlevel.go b/parser/pbf/lowlevel.go index 665c018..c354791 100644 --- a/parser/pbf/lowlevel.go +++ b/parser/pbf/lowlevel.go @@ -105,6 +105,7 @@ func readAndParseHeaderBlock(pos block) (*pbfHeader, error) { result := &pbfHeader{} timestamp := header.GetOsmosisReplicationTimestamp() result.Time = time.Unix(timestamp, 0 /* nanoseconds */) + result.Sequence = header.GetOsmosisReplicationSequenceNumber() return result, nil } @@ -116,7 +117,8 @@ type Pbf struct { } type pbfHeader struct { - Time time.Time + Time time.Time + Sequence int64 } func Open(filename string) (f *Pbf, err error) {