node_client

Documentation

Index

• func Retry(timeout time.Duration, f func() error) error
• type GrpcClient
  • func NewGrpcClient(t *testing.T, port string) *GrpcClient
  • func (c *GrpcClient) GetAddressByAlias(t *testing.T, alias string) []byte
  • func (c *GrpcClient) GetAssetBalance(t *testing.T, address proto.WavesAddress, id []byte) *waves.Amount
  • func (c *GrpcClient) GetAssetsInfo(t *testing.T, id []byte) *g.AssetInfoResponse
  • func (c *GrpcClient) GetHeight(t *testing.T) *client.BlocksHeight
  • func (c *GrpcClient) GetWavesBalance(t *testing.T, address proto.WavesAddress) *g.BalanceResponse_WavesBalances
• type HttpClient
  • func NewHttpClient(t *testing.T, port string) *HttpClient
  • func (c *HttpClient) AssetBalance(t *testing.T, address proto.WavesAddress, assetId crypto.Digest) *client.AssetsBalanceAndAsset
  • func (c *HttpClient) ConnectedPeers() ([]*client.PeersConnectedRow, *client.Response, error)
  • func (c *HttpClient) GetAssetDetails(assetID crypto.Digest) (*client.AssetsDetail, error)
  • func (c *HttpClient) GetHeight(t *testing.T) *client.BlocksHeight
  • func (c *HttpClient) PrintMsg(t *testing.T, msg string)
  • func (c *HttpClient) StateHash(t *testing.T, height uint64) *proto.StateHash
  • func (c *HttpClient) TransactionBroadcast(transaction proto.Transaction) (*client.Response, error)
  • func (c *HttpClient) TransactionInfo(t *testing.T, ID crypto.Digest) proto.Transaction
  • func (c *HttpClient) TransactionInfoRaw(id crypto.Digest) (proto.Transaction, *client.Response, error)
  • func (c *HttpClient) WavesBalance(t *testing.T, address proto.WavesAddress) *client.AddressesBalance
• type NodeClients
  • func NewNodeClient(t *testing.T, httpPort string, grpcPort string) *NodeClients
• type NodesClients
  • func NewNodesClients(t *testing.T, ports *d.Ports) *NodesClients
  • func (c *NodesClients) SendEndMessage(t *testing.T)
  • func (c *NodesClients) SendStartMessage(t *testing.T)
  • func (c *NodesClients) StateHashCmp(t *testing.T, height uint64) (*proto.StateHash, *proto.StateHash, bool)
  • func (c *NodesClients) WaitForConnectedPeers(timeout time.Duration) (error, error)
  • func (c *NodesClients) WaitForHeight(t *testing.T, height uint64) uint64
  • func (c *NodesClients) WaitForNewHeight(t *testing.T) uint64
  • func (c *NodesClients) WaitForStateHashEquality(t *testing.T)
  • func (c *NodesClients) WaitForTransaction(id crypto.Digest, timeout time.Duration) (error, error)

Functions

func Retry

func Retry(timeout time.Duration, f func() error) error

Types

type GrpcClient

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

func NewGrpcClient

func NewGrpcClient(t *testing.T, port string) *GrpcClient

func (*GrpcClient) GetAddressByAlias

func (c *GrpcClient) GetAddressByAlias(t *testing.T, alias string) []byte

func (*GrpcClient) GetAssetBalance

func (c *GrpcClient) GetAssetBalance(t *testing.T, address proto.WavesAddress, id []byte) *waves.Amount

func (*GrpcClient) GetAssetsInfo

func (c *GrpcClient) GetAssetsInfo(t *testing.T, id []byte) *g.AssetInfoResponse

func (*GrpcClient) GetHeight

func (c *GrpcClient) GetHeight(t *testing.T) *client.BlocksHeight

func (*GrpcClient) GetWavesBalance

func (c *GrpcClient) GetWavesBalance(t *testing.T, address proto.WavesAddress) *g.BalanceResponse_WavesBalances

type HttpClient

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

func NewHttpClient

func NewHttpClient(t *testing.T, port string) *HttpClient

func (*HttpClient) AssetBalance

func (c *HttpClient) AssetBalance(t *testing.T, address proto.WavesAddress, assetId crypto.Digest) *client.AssetsBalanceAndAsset

func (*HttpClient) ConnectedPeers

func (c *HttpClient) ConnectedPeers() ([]*client.PeersConnectedRow, *client.Response, error)

func (*HttpClient) GetAssetDetails

func (c *HttpClient) GetAssetDetails(assetID crypto.Digest) (*client.AssetsDetail, error)

func (*HttpClient) GetHeight

func (c *HttpClient) GetHeight(t *testing.T) *client.BlocksHeight

func (*HttpClient) PrintMsg

func (c *HttpClient) PrintMsg(t *testing.T, msg string)

func (*HttpClient) StateHash

func (c *HttpClient) StateHash(t *testing.T, height uint64) *proto.StateHash

func (*HttpClient) TransactionBroadcast

func (c *HttpClient) TransactionBroadcast(transaction proto.Transaction) (*client.Response, error)

func (*HttpClient) TransactionInfo

func (c *HttpClient) TransactionInfo(t *testing.T, ID crypto.Digest) proto.Transaction

func (*HttpClient) TransactionInfoRaw

func (c *HttpClient) TransactionInfoRaw(id crypto.Digest) (proto.Transaction, *client.Response, error)

func (*HttpClient) WavesBalance

func (c *HttpClient) WavesBalance(t *testing.T, address proto.WavesAddress) *client.AddressesBalance

type NodeClients

type NodeClients struct {
	HttpClient *HttpClient
	GrpcClient *GrpcClient
}

func NewNodeClient

func NewNodeClient(t *testing.T, httpPort string, grpcPort string) *NodeClients

type NodesClients

type NodesClients struct {
	GoClients    *NodeClients
	ScalaClients *NodeClients
}

func NewNodesClients

func NewNodesClients(t *testing.T, ports *d.Ports) *NodesClients

func (*NodesClients) SendEndMessage

func (c *NodesClients) SendEndMessage(t *testing.T)

func (*NodesClients) SendStartMessage

func (c *NodesClients) SendStartMessage(t *testing.T)

func (*NodesClients) StateHashCmp

func (c *NodesClients) StateHashCmp(t *testing.T, height uint64) (*proto.StateHash, *proto.StateHash, bool)

func (*NodesClients) WaitForConnectedPeers

func (c *NodesClients) WaitForConnectedPeers(timeout time.Duration) (error, error)

func (*NodesClients) WaitForHeight

func (c *NodesClients) WaitForHeight(t *testing.T, height uint64) uint64

WaitForHeight waits for nodes to get on given height. Exits if nodes' height already equal or greater than requested. Function returns actual nodes' height.

func (*NodesClients) WaitForNewHeight

func (c *NodesClients) WaitForNewHeight(t *testing.T) uint64

WaitForNewHeight waits for nodes to generate new block. Returns the height that was *before* generation of new block.

func (*NodesClients) WaitForStateHashEquality

func (c *NodesClients) WaitForStateHashEquality(t *testing.T)

func (*NodesClients) WaitForTransaction

func (c *NodesClients) WaitForTransaction(id crypto.Digest, timeout time.Duration) (error, error)