deploytest

Jul 3, 2023

Changes in this version

+ const TXListenPort

+ func NewNodeIDsDefaultWeights(nNodes int) map[t.NodeID]types.VoteWeight

+ func NewNodeIDsWeights(nNodes int, weightFunction func(t.NodeID) types.VoteWeight) map[t.NodeID]types.VoteWeight

type FakeApp

+ TransactionsProcessed uint64

type FakeTransport

+ func (ft *FakeTransport) Membership() *trantorpbtypes.Membership

type LocalGrpcTransport

+ func (t *LocalGrpcTransport) Membership() *trantorpbtypes.Membership

type LocalLibp2pTransport

+ func (t *LocalLibp2pTransport) Membership() *trantorpbtypes.Membership

type LocalTransportLayer

+ Membership func() *trantorpbtypes.Membership

type SimTransport

+ func (st *SimTransport) Membership() *trantorpbtypes.Membership

type TestConfig

+ FakeTXDestModule t.ModuleID

+ Membership *trantorpbtypes.Membership

+ NumFakeTXs int

+ NumNetTXs int

type TestReplica

+ FakeTXDestModule t.ModuleID

+ Membership *trantorpbtypes.Membership

+ NumFakeTXs int

Jan 13, 2023

Changes in this version

type FakeApp

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

+ func (fa *FakeApp) Checkpoint(_ *checkpoint.StableCheckpoint) error

type TestConfig

+ FakeApps map[t.NodeID]*FakeApp

Nov 15, 2022

Changes in this version

type Deployment

+ func (d *Deployment) EventLogFiles() map[t.NodeID]string

Nov 3, 2022

Changes in this version

+ const BaseListenPort

+ const RequestListenPort

+ func NewLogger(parentLogger logging.Logger) logging.Logger

+ func NewNodeIDs(nNodes int) []t.NodeID

+ func NewSimTimerModule(node *SimNode) modules.ActiveModule

+ type Deployment struct

+ Clients []*dummyclient.DummyClient

+ Simulation *Simulation

+ TestConfig *TestConfig

+ TestReplicas []*TestReplica

+ func NewDeployment(conf *TestConfig) (*Deployment, error)

+ func (d *Deployment) Run(ctx context.Context) (nodeErrors []error, heapObjects int64, heapAlloc int64)

+ type EventDelayFn func(e *eventpb.Event) time.Duration

+ type FakeApp struct

+ Membership map[t.NodeID]t.NodeAddress

+ ProtocolModule t.ModuleID

+ RequestsProcessed uint64

+ func NewFakeApp(protocolModule t.ModuleID, membership map[t.NodeID]t.NodeAddress) *FakeApp

+ func (fa *FakeApp) ApplyEvent(event *eventpb.Event) (*events.EventList, error)

+ func (fa *FakeApp) ApplyEvents(eventsIn *events.EventList) (*events.EventList, error)

+ func (fa *FakeApp) ImplementsModule()

+ func (fa *FakeApp) RestoreState(checkpoint *checkpointpb.StableCheckpoint) error

+ func (fa *FakeApp) Snapshot() []byte

+ type FakeLink struct

+ DoneC chan struct{}

+ FakeTransport *FakeTransport

+ Source t.NodeID

+ func (fl *FakeLink) ApplyEvents(ctx context.Context, eventList *events.EventList) error

+ func (fl *FakeLink) CloseOldConnections(newNodes map[t.NodeID]t.NodeAddress)

+ func (fl *FakeLink) Connect(nodes map[t.NodeID]t.NodeAddress)

+ func (fl *FakeLink) EventsOut() <-chan *events.EventList

+ func (fl *FakeLink) ImplementsModule()

+ func (fl *FakeLink) Send(dest t.NodeID, msg *messagepb.Message) error

+ func (fl *FakeLink) Start() error

+ func (fl *FakeLink) Stop()

+ func (fl *FakeLink) WaitFor(n int)

+ type FakeTransport struct

+ Buffers map[t.NodeID]map[t.NodeID]chan *events.EventList

+ NodeSinks map[t.NodeID]chan *events.EventList

+ func NewFakeTransport(nodeIDs []t.NodeID) *FakeTransport

+ func (ft *FakeTransport) Close()

+ func (ft *FakeTransport) Link(source t.NodeID) (net.Transport, error)

+ func (ft *FakeTransport) Nodes() map[t.NodeID]t.NodeAddress

+ func (ft *FakeTransport) RecvC(dest t.NodeID) <-chan *events.EventList

+ func (ft *FakeTransport) Send(source, dest t.NodeID, msg *messagepb.Message)

+ type LocalCryptoSystem interface

+ Crypto func(id t.NodeID) mirCrypto.Crypto

+ Module func(id t.NodeID) modules.Module

+ func NewLocalCryptoSystem(cryptoType string, nodeIDs []t.NodeID, logger logging.Logger) LocalCryptoSystem

+ type LocalGrpcTransport struct

+ func NewLocalGrpcTransport(nodeIDs []t.NodeID, logger logging.Logger) *LocalGrpcTransport

+ func (t *LocalGrpcTransport) Close()

+ func (t *LocalGrpcTransport) Link(sourceID t.NodeID) (net.Transport, error)

+ func (t *LocalGrpcTransport) Nodes() map[t.NodeID]t.NodeAddress

+ type LocalLibp2pTransport struct

+ func NewLocalLibp2pTransport(nodeIDs []t.NodeID, logger logging.Logger) *LocalLibp2pTransport

+ func (t *LocalLibp2pTransport) Close()

+ func (t *LocalLibp2pTransport) Link(sourceID t.NodeID) (net.Transport, error)

+ func (t *LocalLibp2pTransport) Nodes() map[t.NodeID]t.NodeAddress

+ type LocalTransportLayer interface

+ Close func()

+ Link func(source t.NodeID) (net.Transport, error)

+ Nodes func() map[t.NodeID]t.NodeAddress

+ func NewLocalTransportLayer(sim *Simulation, transportType string, nodeIDs []t.NodeID, ...) LocalTransportLayer

+ type MessageDelayFn func(from, to t.NodeID) time.Duration

+ type SimNode struct

+ func (n *SimNode) SendEvents(proc *testsim.Process, eventList *events.EventList)

+ func (n *SimNode) Start(proc *testsim.Process, walEvents *events.EventList)

+ func (n *SimNode) WrapModule(id t.ModuleID, m modules.Module) modules.Module

+ func (n *SimNode) WrapModules(mods modules.Modules) modules.Modules

+ type SimTransport struct

+ func NewSimTransport(s *Simulation, nodeIDs []t.NodeID, delayFn MessageDelayFn) *SimTransport

+ func (st *SimTransport) Close()

+ func (st *SimTransport) Link(source t.NodeID) (net.Transport, error)

+ func (st *SimTransport) Nodes() map[t.NodeID]t.NodeAddress

+ type Simulation struct

+ func NewSimulation(rnd *rand.Rand, nodeIDs []t.NodeID, delayFn EventDelayFn) *Simulation

+ func (s *Simulation) Node(id t.NodeID) *SimNode

+ type TestConfig struct

+ Directory string

+ FakeRequestsDestModule t.ModuleID

+ Info string

+ Logger logging.Logger

+ NodeIDs []t.NodeID

+ NodeModules map[t.NodeID]modules.Modules

+ Nodes map[t.NodeID]t.NodeAddress

+ NumClients int

+ NumFakeRequests int

+ NumNetRequests int

+ Simulation *Simulation

+ TransportLayer LocalTransportLayer

+ type TestReplica struct

+ Config *mir.NodeConfig

+ Dir string

+ FakeRequestsDestModule t.ModuleID

+ ID t.NodeID

+ Modules modules.Modules

+ NodeIDs []t.NodeID

+ Nodes map[t.NodeID]t.NodeAddress

+ NumFakeRequests int

+ Proc *testsim.Process

+ Sim *SimNode

+ func (tr *TestReplica) EventLogFile() string

+ func (tr *TestReplica) Run(ctx context.Context) error