multiclient

package

v0.1.0 Latest Latest Go to latest Published: Mar 3, 2021 License: Apache-2.0, BSD-2-Clause Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type MultiClient struct {
	Timeout time.Duration
	// contains filtered or unexported fields
}

MultiClient allows to send webapi requests in parallel to multiple wasp nodes

func New(hosts []string, httpClient ...func() http.Client) *MultiClient

New creates a new instance of MultiClient

func (m *MultiClient) ActivateChain(chainid coretypes.ChainID) error

ActivateChain sends a request to activate a chain in all wasp nodes

func (m *MultiClient) DKSharesGet(sharedAddress *address.Address) ([]*model.DKSharesInfo, error)

DKSharesGet retrieves distributed key info with specific ChainID from multiple hosts.

func (m *MultiClient) DeactivateChain(chainid coretypes.ChainID) error

DeactivateChain sends a request to deactivate a chain in all wasp nodes

func (m *MultiClient) Do(f func(int, *client.WaspClient) error) error

Do executes a callback once for each node in parallel, then wraps all error results into a single one

func (m *MultiClient) DoWithQuorum(f func(int, *client.WaspClient) error, quorum int) error

Do executes a callback once for each node in parallel, then wraps all error results into a single one

func (m *MultiClient) Len() int

func (m *MultiClient) PutChainRecord(bd *registry.ChainRecord) error

PutChainRecord calls PutChainRecord in all wasp nodes

func (m *MultiClient) UploadData(fieldValues [][]byte, quorum ...int) error

UploadBlobDataWithQuorum upload data chunks to the blob cache in the registries of at least quorum nodes.

func (m *MultiClient) WaitUntilAllRequestsProcessed(tx *sctransaction.Transaction, timeout time.Duration) error

WaitUntilAllRequestsProcessed blocks until all requests in the given transaction have been processed by all nodes

func (m *MultiClient) WaitUntilRequestProcessed(chainId *coretypes.ChainID, reqId *coretypes.RequestID, timeout time.Duration) error

WaitUntilRequestProcessed blocks until the request has been processed by all nodes