committer

Documentation

Index

• type Committer
  • func NewCommitter(ctx context.Context, db *storage.VersionedDB, channel string, peer *comm.Peer, ...) (*Committer, error)
  • func (c *Committer) BlockHeight() (uint64, error)
  • func (c *Committer) PeerBlockHeight() (uint64, error)
  • func (c *Committer) Run() error
  • func (c *Committer) Stop()
  • func (c *Committer) WaitUntilSynced(ctx context.Context) error
• type Logger

Types

type Committer

type Committer struct {
	// contains filtered or unexported fields
}

func NewCommitter

func NewCommitter(ctx context.Context, db *storage.VersionedDB, channel string, peer *comm.Peer, signer fabrictx.Signer, logger Logger) (*Committer, error)

func (*Committer) BlockHeight

func (c *Committer) BlockHeight() (uint64, error)

func (*Committer) PeerBlockHeight

func (c *Committer) PeerBlockHeight() (uint64, error)

func (*Committer) Run

func (c *Committer) Run() error

func (*Committer) Stop

func (c *Committer) Stop()

func (*Committer) WaitUntilSynced

func (c *Committer) WaitUntilSynced(ctx context.Context) error

WaitUntilSynced blocks until the committer has processed all blocks up to the peer's current height. Returns an error if the context is canceled or times out.

type Logger

type Logger interface {
	Printf(format string, v ...any)
}