Skip to content

Commit

Permalink
feat(store): add tail header
Browse files Browse the repository at this point in the history
  • Loading branch information
cristaloleg committed Jun 18, 2024
1 parent 672fc95 commit ffb18c9
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions store/store.go
Original file line number Diff line number Diff line change
Expand Up @@ -51,6 +51,8 @@ type Store[H header.Header[H]] struct {
writesDn chan struct{}
// writeHead maintains the current write head
writeHead atomic.Pointer[H]
// tailHeader maintains the current tail header.
tailHeader atomic.Pointer[H]
// pending keeps headers pending to be written in one batch
pending *batch[H]

Expand Down Expand Up @@ -121,6 +123,8 @@ func (s *Store[H]) Init(ctx context.Context, initial H) error {
return err
}

s.tailHeader.Store(&initial)

log.Infow("initialized head", "height", initial.Height(), "hash", initial.Hash())
s.heightSub.Pub(initial)
return nil
Expand Down

0 comments on commit ffb18c9

Please sign in to comment.