consensus

Documentation

Index

• type Synchronizer
  • func (s *Synchronizer) CloseChan() <-chan struct{}
  • func (s *Synchronizer) Init(cdb *db.Database, mdb, tdb *badger.DB, gc *gossip.Client, gh *gossip.Handlers, ...)
  • func (s *Synchronizer) Safe() bool
  • func (s *Synchronizer) Start()
  • func (s *Synchronizer) Stop()

Types

type Synchronizer

type Synchronizer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Synchronizer controls logic hand off between services This system coordinates what services may run under what conditions The system operates as a scheduler as well as a reactor to external events.

func (*Synchronizer) CloseChan

func (s *Synchronizer) CloseChan() <-chan struct{}

func (*Synchronizer) Init

func (s *Synchronizer) Init(cdb *db.Database, mdb, tdb *badger.DB, gc *gossip.Client, gh *gossip.Handlers, ep *evidence.Pool, eng *lstate.Engine, app *application.Application, ah *admin.Handlers, pman *peering.PeerManager, storage dynamics.StorageGetter)

Init initializes the struct.

func (*Synchronizer) Safe

func (s *Synchronizer) Safe() bool

func (*Synchronizer) Start

func (s *Synchronizer) Start()

Start will start the Synchronizer.

func (*Synchronizer) Stop

func (s *Synchronizer) Stop()

Stop terminates the Synchronizer and all managed services.