Documentation
¶
Index ¶
- Variables
- func ConstructWireFrame(magic protocol.Magic, cmd topics.Topic, payload *bytes.Buffer) ([]byte, error)
- func Profile1(index int, node *DuskNode, walletPath string)
- func Profile2(index int, node *DuskNode, walletPath string)
- func WriteFrame(buf *bytes.Buffer) (*bytes.Buffer, error)
- type DuskNode
- type Network
- func (n *Network) Bootstrap(workspace string) error
- func (n *Network) LoadWalletCmd(ind uint, password string) (string, error)
- func (n *Network) PublishTopic(nodeIndex uint, topic, payload string) error
- func (n *Network) SendBidCmd(ind uint, amount, locktime uint64) ([]byte, error)
- func (n *Network) SendQuery(nodeIndex uint, query string, result interface{}) error
- func (n *Network) SendWireMsg(ind uint, msg []byte, writeTimeout int) error
- func (n *Network) StartNode(i int, node *DuskNode, workspace string) error
- func (n *Network) Teardown()
- func (n *Network) WaitUntil(t *testing.T, ind uint, targetHeight uint64, waitFor time.Duration, ...)
- func (n *Network) WaitUntilTx(t *testing.T, ind uint, txID string) string
- type Profiles
Constants ¶
This section is empty.
Variables ¶
var ( // EnableHarness a test CLI param to enable harness bootstrapping EnableHarness = flag.Bool("enable", false, "Enable Test Harness bootstrapping") // RPCNetworkType a test CLI param to set jsonrpc network type (unix or tcp) RPCNetworkType = flag.String("rpc_transport", "unix", "JSON-RPC transport type (unix/tcp)") // KeepAlive a test CLI param to keep harness running even after all tests have passed // It's useful when additional manual tests should be done KeepAlive = flag.Bool("keepalive", false, "Keep Test Harness alive after tests pass") // ErrDisabledHarness yields a disabled test harness ErrDisabledHarness = errors.New("disabled test harness") )
Functions ¶
func ConstructWireFrame ¶
func ConstructWireFrame(magic protocol.Magic, cmd topics.Topic, payload *bytes.Buffer) ([]byte, error)
ConstructWireFrame creates a frame according to the wire protocol
Types ¶
type DuskNode ¶
type DuskNode struct {
Id string //nolint
ConfigProfileID string
// fields represents a dusk-blockchain instance
Cfg config.Registry
Gql *graphql.Client
// dusk-blockchain node directory
Dir string
}
DuskNode is the struct representing a node instance in the local Network
func NewDuskNode ¶
NewDuskNode instantiates a new DuskNode
type Network ¶
type Network struct {
Nodes []*DuskNode
// contains filtered or unexported fields
}
Network describes the current network configuration in terms of nodes and processes
func (*Network) Bootstrap ¶
Bootstrap performs all actions needed to initialize and start a local network This network is alive by the end of all tests execution
func (*Network) LoadWalletCmd ¶ added in v0.3.0
LoadWalletCmd sends gRPC command LoadWallet and returns pubkey (if loaded)
func (*Network) PublishTopic ¶
PublishTopic publishes an event bus topic to the specified node via rpc call
func (*Network) SendBidCmd ¶ added in v0.3.0
SendBidCmd sends gRPC command SendBid and returns tx hash
func (*Network) SendWireMsg ¶
SendWireMsg sends a P2P message to the specified network node NB: Handshaking procedure must be performed prior to the message sending
Source Files