simulator

package
v1.0.0-rc1.2-debug Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 4, 2022 License: MIT Imports: 41 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GenesisTime = time.Date(2022, 7, 1, 0, 0, 0, 0, time.UTC)

Functions

func GetAccount added in v1.0.0 

func GetAccount[T protocol.Account](sim *Simulator, accountUrl *url.URL) T

func InitFromSnapshot added in v1.0.0 

func InitFromSnapshot(t TB, db *database.Database, exec *Executor, filename string)

func NormalizeEnvelope 

func NormalizeEnvelope(t TB, envelope *protocol.Envelope) []*chain.Delivery

func Query 

func Query(t TB, db *database.Database, exec *Executor, req query.Request, prove bool) interface{}

Types

type ExecEntry 

type ExecEntry struct {
	BlockIndex uint64

	Partition  *config.Partition
	Database   *database.Database
	Executor   *block.Executor
	API        *client.Client
	Validators [][]byte

	// SubmitHook can be used to control how envelopes are submitted to the
	// partition. It is not safe to change SubmitHook concurrently with calls to
	// Submit.
	SubmitHook func([]*chain.Delivery) ([]*chain.Delivery, bool)
	// contains filtered or unexported fields
}

func (ExecEntry) Errorf added in v1.0.0 

func (t ExecEntry) Errorf(format string, args ...interface{})

func (ExecEntry) Fatalf added in v1.0.0 

func (t ExecEntry) Fatalf(format string, args ...interface{})

func (ExecEntry) Logf added in v1.0.0 

func (t ExecEntry) Logf(format string, args ...interface{})

func (*ExecEntry) Submit 

func (x *ExecEntry) Submit(pretend bool, envelopes ...*protocol.Envelope) []*chain.Delivery

Submit adds the envelopes to the next block's queue.

By adding transactions to the next block and swaping queues when a block is executed, we roughly simulate the process Tendermint uses to build blocks.

type Simulator 

type Simulator struct {
	Logger     log.Logger
	Partitions []config.Partition
	Executors  map[string]*ExecEntry
	// contains filtered or unexported fields
}

func New 

func New(t TB, bvnCount int) *Simulator

func NewWith added in v1.0.0 

func NewWith(t TB, opts SimulatorOptions) *Simulator

func (*Simulator) CreateAccount 

func (s *Simulator) CreateAccount(account protocol.Account)

func (*Simulator) CreateIdentity 

func (s *Simulator) CreateIdentity(identityUrl *url.URL, pubKey ...[]byte)

func (*Simulator) CreateKeyBook 

func (s *Simulator) CreateKeyBook(bookUrl *url.URL, pubKey ...[]byte)

func (*Simulator) CreateKeyPage 

func (s *Simulator) CreateKeyPage(bookUrl *url.URL, pubKey ...[]byte)

func (*Simulator) CreateLiteTokenAccount added in v1.0.0 

func (s *Simulator) CreateLiteTokenAccount(key []byte, token *url.URL, credits, tokens uint64) *url.URL

func (Simulator) Errorf 

func (t Simulator) Errorf(format string, args ...interface{})

func (*Simulator) ExecuteBlock 

func (s *Simulator) ExecuteBlock(statusChan chan<- *protocol.TransactionStatus)

ExecuteBlock executes a block after submitting envelopes. If a status channel is provided, statuses will be sent to the channel as transactions are executed. Once the block is complete, the status channel will be closed (if provided).

func (*Simulator) ExecuteBlocks 

func (s *Simulator) ExecuteBlocks(n int)

ExecuteBlocks executes a number of blocks. This is useful for things like waiting for a block to be anchored.

func (Simulator) Fatalf 

func (t Simulator) Fatalf(format string, args ...interface{})

func (*Simulator) InitFromGenesis added in v1.0.0 

func (s *Simulator) InitFromGenesis()

func (*Simulator) InitFromGenesisWith added in v1.0.0 

func (s *Simulator) InitFromGenesisWith(values *core.GlobalValues)

func (*Simulator) InitFromSnapshot added in v1.0.0 

func (s *Simulator) InitFromSnapshot(filename func(string) string)

func (Simulator) Logf 

func (t Simulator) Logf(format string, args ...interface{})

func (*Simulator) MustSubmitAndExecuteBlock 

func (s *Simulator) MustSubmitAndExecuteBlock(envelopes ...*protocol.Envelope) []*protocol.Envelope

MustSubmitAndExecuteBlock executes a block with the envelopes and fails the test if any envelope fails.

func (*Simulator) NewServer added in v1.0.0 

func (s *Simulator) NewServer() http.Handler

func (*Simulator) Partition added in v1.0.0 

func (s *Simulator) Partition(id string) *ExecEntry

func (*Simulator) PartitionFor added in v1.0.0 

func (s *Simulator) PartitionFor(url *url.URL) *ExecEntry

func (*Simulator) Query 

func (s *Simulator) Query(url *url.URL, req query.Request, prove bool) interface{}

func (*Simulator) Router 

func (s *Simulator) Router() routing.Router

func (*Simulator) SetRouteFor 

func (s *Simulator) SetRouteFor(account *url.URL, partition string)

func (*Simulator) Setup added in v1.0.0 

func (sim *Simulator) Setup(opts SimulatorOptions)

func (*Simulator) Submit 

func (s *Simulator) Submit(envelopes ...*protocol.Envelope) ([]*protocol.Envelope, error)

func (*Simulator) SubmitAndExecuteBlock 

func (s *Simulator) SubmitAndExecuteBlock(envelopes ...*protocol.Envelope) ([]*protocol.TransactionStatus, error)

SubmitAndExecuteBlock executes a block with the envelopes.

func (*Simulator) UpdateAccount 

func (s *Simulator) UpdateAccount(accountUrl *url.URL, fn func(account protocol.Account))

func (*Simulator) WaitForTransaction added in v1.0.0 

func (s *Simulator) WaitForTransaction(statusCheck func(*protocol.TransactionStatus) bool, txnHash []byte, n int) (*protocol.Transaction, *protocol.TransactionStatus, []*url.TxID)

func (*Simulator) WaitForTransactionFlow 

func (s *Simulator) WaitForTransactionFlow(statusCheck func(*protocol.TransactionStatus) bool, txnHash []byte) ([]*protocol.TransactionStatus, []*protocol.Transaction)

func (*Simulator) WaitForTransactions 

func (s *Simulator) WaitForTransactions(status func(*protocol.TransactionStatus) bool, envelopes ...*protocol.Envelope) ([]*protocol.TransactionStatus, []*protocol.Transaction)

type SimulatorOptions added in v1.0.0 

type SimulatorOptions struct {
	BvnCount        int
	LogLevels       string
	OpenDB          func(partition string, nodeIndex int, logger log.Logger) *database.Database
	FactomAddresses func() (io.Reader, error)
}

type TB 

type TB interface {
	Name() string
	Log(...interface{})
	Fail()
	FailNow()
	Helper()
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.