deploytest

type Deployment struct {
	TestConfig *TestConfig

	// The test simulation is only used if the deployment is configured to use "sim" transport.
	Simulation *Simulation

	// The replicas of the deployment.
	TestReplicas []*TestReplica

	// Dummy clients to submit transactions to replicas over the (local loopback) network.
	Clients []*dummyclient.DummyClient
}

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

type FakeApp struct {
	ProtocolModule t.ModuleID

	// The state of the FakeApp only consists of a counter of processed transactions.
	TransactionsProcessed uint64
}

type FakeLink struct {
	FakeTransport *FakeTransport
	Source        t.NodeID
	DoneC         chan struct{}
	// contains filtered or unexported fields
}

type FakeTransport struct {
	// Buffers is source x dest
	Buffers   map[t.NodeID]map[t.NodeID]chan *events.EventList
	NodeSinks map[t.NodeID]chan *events.EventList
	// contains filtered or unexported fields
}

type LocalCryptoSystem interface {
	Crypto(id t.NodeID) (mirCrypto.Crypto, error)
	Module(id t.NodeID) (modules.Module, error)
}

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

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

type LocalTransportLayer interface {
	Link(source t.NodeID) (net.Transport, error)
	Membership() *trantorpbtypes.Membership
	Close()
}

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

type SimNode struct {
	*Simulation
	// contains filtered or unexported fields
}

type SimTransport struct {
	*Simulation
	// contains filtered or unexported fields
}

type Simulation struct {
	*testsim.Runtime
	// contains filtered or unexported fields
}

type TestConfig struct {
	// Optional information about the test.
	Info string

	// The test simulation is only used if the deployment is configured to use "sim" transport.
	Simulation *Simulation

	// IDs of nodes in this test.
	NodeIDs []t.NodeID

	// List of nodes.
	Membership *trantorpbtypes.Membership

	// The modules that will be run by each replica.
	NodeModules map[t.NodeID]modules.Modules

	// Number of clients in the tested deployment.
	NumClients int

	// The number of transactions each client submits during the execution of the deployment.
	NumFakeTXs int

	// The number of transactions sent over the network (by a single DummyClient)
	NumNetTXs int

	// The target module for the clients' transactions.
	FakeTXDestModule t.ModuleID

	// Directory where all the test-related files will be stored.
	// If empty, an OS-default temporary directory will be used.
	Directory string

	// Logger to use for producing diagnostic messages.
	Logger logging.Logger

	// TransportLayer to work with network transport.
	TransportLayer LocalTransportLayer

	// Fake applications of all the test replicas. Required for checking results.
	FakeApps map[t.NodeID]*FakeApp
}

type TestReplica struct {

	// ID of the replica as seen by the protocol.
	ID t.NodeID

	// The modules that the node will run.
	Modules modules.Modules

	// Name of the directory where the persisted state of this TestReplica will be stored,
	// along with the logs produced by running the replica.
	Dir string

	// Configuration of the node corresponding to this replica.
	Config *mir.NodeConfig

	// List of replica IDs constituting the (static) membership.
	NodeIDs []t.NodeID

	// List of replicas.
	Membership *trantorpbtypes.Membership

	// Node's representation within the simulation runtime
	Sim *SimNode

	// Node's process within the simulation runtime
	Proc *testsim.Process

	// Number of simulated transactions inserted in the test replica by a hypothetical client.
	NumFakeTXs int

	// ID of the module to which fake transactions should be sent.
	FakeTXDestModule t.ModuleID
}