trantor

Jan 13, 2023

Changes in this version

+ func GenesisCheckpoint(initialAppState []byte, params Params, logger logging.Logger) (*checkpoint.StableCheckpoint, error)

+ type AppLogic interface

+ ApplyTXs func(txs []*requestpb.Request) error

+ Checkpoint func(checkpoint *checkpoint.StableCheckpoint) error

+ NewEpoch func(nr t.EpochNr) (map[t.NodeID]t.NodeAddress, error)

+ RestoreState func(checkpoint *checkpoint.StableCheckpoint) error

+ Snapshot func() ([]byte, error)

+ func AppLogicFromStatic(staticAppLogic StaticAppLogic, membership map[t.NodeID]t.NodeAddress) AppLogic

+ type AppModule struct

+ func NewAppModule(appLogic AppLogic, transport net.Transport, protocolModule t.ModuleID) *AppModule

+ func (m *AppModule) ApplyEvent(event *eventpb.Event) (*events.EventList, error)

+ func (m *AppModule) ApplyEvents(eventsIn *events.EventList) (*events.EventList, error)

+ func (m *AppModule) ImplementsModule()

+ type Params struct

+ Iss *issutil.ModuleParams

+ Mempool *simplemempool.ModuleParams

+ Net libp2p.Params

+ func DefaultParams(initialMembership map[t.NodeID]t.NodeAddress) Params

+ func (p *Params) AdjustSpeed(maxProposeDelay time.Duration) *Params

+ type StaticAppLogic interface

+ ApplyTXs func(txs []*requestpb.Request) error

+ Checkpoint func(checkpoint *checkpoint.StableCheckpoint) error

+ RestoreState func(checkpoint *checkpoint.StableCheckpoint) error

+ Snapshot func() ([]byte, error)

+ type System struct

+ func New(ownID t.NodeID, transport net.Transport, ...) (*System, error)

+ func (sys *System) Modules() modules.Modules

+ func (sys *System) PerturbMessages(params *eventmangler.ModuleParams) error

+ func (sys *System) Start() error

+ func (sys *System) Stop()

+ func (sys *System) WithModule(moduleID t.ModuleID, module modules.Module) *System