inmemory

Documentation

Index

• type Network
  • func NewNetwork(logger log.BasicLogger, transport adapter.Transport) Network
  • func (n *Network) AddNode(nodeKeyPair *keys.Ed25519KeyPair, cfg config.NodeConfig, ...)
  • func (n *Network) CallMethod(ctx context.Context, tx *protocol.TransactionBuilder, nodeIndex int) chan uint64
  • func (n *Network) CreateAndStartNodes(ctx context.Context, numOfNodesToStart int)
  • func (n *Network) GetBlockPersistence(nodeIndex int) blockStorageAdapter.InMemoryBlockPersistence
  • func (n *Network) GetStatePersistence(i int) stateStorageAdapter.TamperingStatePersistence
  • func (n *Network) PublicApi(nodeIndex int) services.PublicApi
  • func (n *Network) SendTransaction(ctx context.Context, tx *protocol.SignedTransactionBuilder, nodeIndex int) chan *client.SendTransactionResponse
  • func (n *Network) SendTransactionInBackground(ctx context.Context, tx *protocol.SignedTransactionBuilder, nodeIndex int)
  • func (n *Network) Size() int
  • func (n *Network) WaitForTransactionInState(ctx context.Context, txhash primitives.Sha256)
• type NetworkDriver
• type Node
  • func (n *Node) GetCompiler() nativeProcessorAdapter.Compiler
  • func (n *Node) GetPublicApi() services.PublicApi
  • func (n *Node) Started() bool
  • func (n *Node) WaitForTransactionInState(ctx context.Context, txhash primitives.Sha256)

Types

type Network

type Network struct {
	Nodes     []*Node
	Logger    log.BasicLogger
	Transport adapter.Transport
}

func NewNetwork

func NewNetwork(logger log.BasicLogger, transport adapter.Transport) Network

func (*Network) AddNode

func (n *Network) AddNode(nodeKeyPair *keys.Ed25519KeyPair, cfg config.NodeConfig, compiler nativeProcessorAdapter.Compiler, logger log.BasicLogger)

func (*Network) CallMethod

func (n *Network) CallMethod(ctx context.Context, tx *protocol.TransactionBuilder, nodeIndex int) chan uint64

func (*Network) CreateAndStartNodes

func (n *Network) CreateAndStartNodes(ctx context.Context, numOfNodesToStart int)

func (*Network) GetBlockPersistence

func (n *Network) GetBlockPersistence(nodeIndex int) blockStorageAdapter.InMemoryBlockPersistence

func (*Network) GetStatePersistence

func (n *Network) GetStatePersistence(i int) stateStorageAdapter.TamperingStatePersistence

func (*Network) PublicApi

func (n *Network) PublicApi(nodeIndex int) services.PublicApi

func (*Network) SendTransaction

func (n *Network) SendTransaction(ctx context.Context, tx *protocol.SignedTransactionBuilder, nodeIndex int) chan *client.SendTransactionResponse

func (*Network) SendTransactionInBackground

func (n *Network) SendTransactionInBackground(ctx context.Context, tx *protocol.SignedTransactionBuilder, nodeIndex int)

func (*Network) Size

func (n *Network) Size() int

func (*Network) WaitForTransactionInState

func (n *Network) WaitForTransactionInState(ctx context.Context, txhash primitives.Sha256)

type NetworkDriver

type NetworkDriver interface {
	contracts.ContractAPI
	PublicApi(nodeIndex int) services.PublicApi
	Size() int
}

type Node

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

func (*Node) GetCompiler

func (n *Node) GetCompiler() nativeProcessorAdapter.Compiler

func (*Node) GetPublicApi

func (n *Node) GetPublicApi() services.PublicApi

func (*Node) Started

func (n *Node) Started() bool

func (*Node) WaitForTransactionInState

func (n *Node) WaitForTransactionInState(ctx context.Context, txhash primitives.Sha256)