mirror of
https://github.com/hyperledger/fabric-samples.git
synced 2026-06-19 08:15:08 +00:00
3c67f51e2e
The high-throughput sample used the deprecated Go SDK. This change updates the sample to use the currently supported Fabric Gateway client API and adds some automated testing to ensure the sample works correctly. Signed-off-by: Mark S. Lewis <Mark.S.Lewis@outlook.com>
39 lines
876 B
Go
39 lines
876 B
Go
/*
|
|
Copyright 2020 IBM All Rights Reserved.
|
|
|
|
SPDX-License-Identifier: Apache-2.0
|
|
*/
|
|
|
|
package functions
|
|
|
|
import (
|
|
"fmt"
|
|
"sync"
|
|
|
|
"github.com/hyperledger/fabric-gateway/pkg/client"
|
|
)
|
|
|
|
// ManyUpdates allows you to push many cuncurrent updates to a variable
|
|
func ManyUpdates(contract *client.Contract, function, variableName, change, sign string) ([]byte, error) {
|
|
var wg sync.WaitGroup
|
|
|
|
for i := 0; i < 1000; i++ {
|
|
wg.Add(1)
|
|
go func() ([]byte, error) {
|
|
defer wg.Done()
|
|
result, err := contract.SubmitTransaction(function, variableName, change, sign)
|
|
if err != nil {
|
|
return result, fmt.Errorf("failed to evaluate transaction: %v", err)
|
|
}
|
|
return result, nil
|
|
}()
|
|
}
|
|
|
|
wg.Wait()
|
|
|
|
result, err := contract.EvaluateTransaction("get", variableName)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("failed to evaluate transaction: %v", err)
|
|
}
|
|
return result, err
|
|
}
|