Documentation
¶
Index ¶
- func Retry(timeout time.Duration, f func() error) error
- type 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 (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
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type GrpcClient ¶ added in v0.10.2
type GrpcClient struct {
// contains filtered or unexported fields
}
func NewGrpcClient ¶ added in v0.10.2
func NewGrpcClient(t *testing.T, port string) *GrpcClient
func (*GrpcClient) GetAddressByAlias ¶ added in v0.10.3
func (c *GrpcClient) GetAddressByAlias(t *testing.T, alias string) []byte
func (*GrpcClient) GetAssetBalance ¶ added in v0.10.2
func (c *GrpcClient) GetAssetBalance(t *testing.T, address proto.WavesAddress, id []byte) *waves.Amount
func (*GrpcClient) GetAssetsInfo ¶ added in v0.10.5
func (c *GrpcClient) GetAssetsInfo(t *testing.T, id []byte) *g.AssetInfoResponse
func (*GrpcClient) GetHeight ¶ added in v0.10.2
func (c *GrpcClient) GetHeight(t *testing.T) *client.BlocksHeight
func (*GrpcClient) GetWavesBalance ¶ added in v0.10.2
func (c *GrpcClient) GetWavesBalance(t *testing.T, address proto.WavesAddress) *g.BalanceResponse_WavesBalances
type HttpClient ¶ added in v0.10.2
type HttpClient struct {
// contains filtered or unexported fields
}
func NewHttpClient ¶ added in v0.10.2
func NewHttpClient(t *testing.T, port string) *HttpClient
func (*HttpClient) AssetBalance ¶ added in v0.10.3
func (c *HttpClient) AssetBalance(t *testing.T, address proto.WavesAddress, assetId crypto.Digest) *client.AssetsBalanceAndAsset
func (*HttpClient) ConnectedPeers ¶ added in v0.10.4
func (c *HttpClient) ConnectedPeers() ([]*client.PeersConnectedRow, *client.Response, error)
func (*HttpClient) GetAssetDetails ¶ added in v0.10.5
func (c *HttpClient) GetAssetDetails(assetID crypto.Digest) (*client.AssetsDetail, error)
func (*HttpClient) GetHeight ¶ added in v0.10.2
func (c *HttpClient) GetHeight(t *testing.T) *client.BlocksHeight
func (*HttpClient) PrintMsg ¶ added in v0.10.2
func (c *HttpClient) PrintMsg(t *testing.T, msg string)
func (*HttpClient) TransactionBroadcast ¶ added in v0.10.2
func (c *HttpClient) TransactionBroadcast(transaction proto.Transaction) (*client.Response, error)
func (*HttpClient) TransactionInfo ¶ added in v0.10.2
func (c *HttpClient) TransactionInfo(t *testing.T, ID crypto.Digest) proto.Transaction
func (*HttpClient) TransactionInfoRaw ¶ added in v0.10.2
func (c *HttpClient) TransactionInfoRaw(id crypto.Digest) (proto.Transaction, *client.Response, error)
func (*HttpClient) WavesBalance ¶ added in v0.10.3
func (c *HttpClient) WavesBalance(t *testing.T, address proto.WavesAddress) *client.AddressesBalance
type NodeClients ¶ added in v0.10.2
type NodeClients struct {
HttpClient *HttpClient
GrpcClient *GrpcClient
}
func NewNodeClient ¶ added in v0.10.2
func NewNodeClient(t *testing.T, httpPort string, grpcPort string) *NodeClients
type NodesClients ¶ added in v0.10.2
type NodesClients struct {
GoClients *NodeClients
ScalaClients *NodeClients
}
func NewNodesClients ¶ added in v0.10.2
func NewNodesClients(t *testing.T, ports *d.Ports) *NodesClients
func (*NodesClients) SendEndMessage ¶ added in v0.10.2
func (c *NodesClients) SendEndMessage(t *testing.T)
func (*NodesClients) SendStartMessage ¶ added in v0.10.2
func (c *NodesClients) SendStartMessage(t *testing.T)
func (*NodesClients) StateHashCmp ¶ added in v0.10.2
func (*NodesClients) WaitForConnectedPeers ¶ added in v0.10.4
func (c *NodesClients) WaitForConnectedPeers(timeout time.Duration) (error, error)
func (*NodesClients) WaitForHeight ¶ added in v0.10.4
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 ¶ added in v0.10.2
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 ¶ added in v0.10.6
func (c *NodesClients) WaitForStateHashEquality(t *testing.T)
func (*NodesClients) WaitForTransaction ¶ added in v0.10.2
Source Files
Click to show internal directories.
Click to hide internal directories.