inmemory

Documentation

Index

• type Network
  • func NewNetworkWithNumOfNodes(nodeOrder []primitives.NodeAddress, nodeConfigs []config.NodeConfig, ...) *Network
  • func (n *Network) CreateAndStartNodes(ctx context.Context, numOfNodesToStart int)
  • func (n *Network) Destroy()
  • func (n *Network) GetTransactionReceiptProof(ctx context.Context, txHash primitives.Sha256, nodeIndex int) *client.GetTransactionReceiptProofResponse
  • func (n *Network) GetTransactionStatus(ctx context.Context, txHash primitives.Sha256, nodeIndex int) *client.GetTransactionStatusResponse
  • func (n *Network) GetVirtualChainId() primitives.VirtualChainId
  • func (n *Network) MetricRegistry(nodeIndex int) metric.Registry
  • func (n *Network) PublicApi(nodeIndex int) services.PublicApi
  • func (n *Network) RunQuery(ctx context.Context, builder *protocol.SignedQueryBuilder, nodeIndex int) *client.RunQueryResponse
  • func (n *Network) SendTransaction(ctx context.Context, builder *protocol.SignedTransactionBuilder, nodeIndex int) (*client.SendTransactionResponse, primitives.Sha256)
  • func (n *Network) SendTransactionInBackground(ctx context.Context, builder *protocol.SignedTransactionBuilder, nodeIndex int)
• type Node
  • func (n *Node) Destroy()
  • func (n *Node) ExtractBlocks() ([]*protocol.BlockPairContainer, error)
  • func (n *Node) GetPublicApi() services.PublicApi
  • func (n *Node) Started() bool
• type NodeDependencies

Types

type Network

type Network struct {
	govnr.TreeSupervisor
	Nodes          []*Node
	Logger         log.Logger
	Transport      adapter.Transport
	Management     management.Provider
	VirtualChainId primitives.VirtualChainId
	MaybeClock     txPoolAdapter.Clock
}

Represents an in-process network connecting a group of in-memory Nodes together using the provided Transport

func NewNetworkWithNumOfNodes

func NewNetworkWithNumOfNodes(nodeOrder []primitives.NodeAddress, nodeConfigs []config.NodeConfig, parent log.Logger, transport adapter.Transport, managementProvider management.Provider, maybeClock txPoolAdapter.Clock, provider nodeDependencyProvider) *Network

func (*Network) CreateAndStartNodes

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

func (*Network) Destroy

func (n *Network) Destroy()

func (*Network) GetTransactionReceiptProof

func (n *Network) GetTransactionReceiptProof(ctx context.Context, txHash primitives.Sha256, nodeIndex int) *client.GetTransactionReceiptProofResponse

func (*Network) GetTransactionStatus

func (n *Network) GetTransactionStatus(ctx context.Context, txHash primitives.Sha256, nodeIndex int) *client.GetTransactionStatusResponse

func (*Network) GetVirtualChainId

func (n *Network) GetVirtualChainId() primitives.VirtualChainId

func (*Network) MetricRegistry

func (n *Network) MetricRegistry(nodeIndex int) metric.Registry

func (*Network) PublicApi

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

func (*Network) RunQuery

func (n *Network) RunQuery(ctx context.Context, builder *protocol.SignedQueryBuilder, nodeIndex int) *client.RunQueryResponse

func (*Network) SendTransaction

func (n *Network) SendTransaction(ctx context.Context, builder *protocol.SignedTransactionBuilder, nodeIndex int) (*client.SendTransactionResponse, primitives.Sha256)

func (*Network) SendTransactionInBackground

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

type Node

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

Represents an in-memory Orbs node, that uses in-memory storage and communicates with its peers via in-memory gossip Useful for in-process tests and simulating Orbs chains during development

func (*Node) Destroy

func (n *Node) Destroy()

func (*Node) ExtractBlocks

func (n *Node) ExtractBlocks() ([]*protocol.BlockPairContainer, error)

func (*Node) GetPublicApi

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

func (*Node) Started

func (n *Node) Started() bool

type NodeDependencies

type NodeDependencies struct {
	Compiler                           nativeProcessorAdapter.Compiler
	EtherConnection                    ethereumAdapter.EthereumConnection
	BlockPersistence                   blockStorageAdapter.BlockPersistence
	StatePersistence                   stateStorageAdapter.StatePersistence
	StateBlockHeightReporter           stateStorageAdapter.BlockHeightReporter
	TransactionPoolBlockHeightReporter *synchronization.BlockTracker
}