Merge pull request #93 from rubenv/master

Include replication sequence in pbf header.
master
Oliver Tonnhofer 2016-03-10 18:16:27 +01:00
commit 137739f54b
1 changed files with 3 additions and 1 deletions

View File

@ -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) {