txsource/queries: workload doing various queries

oasisprotocol · Mar 20, 2020 · 525bfad · 525bfad
1 parent 908195f
commit 525bfad
Show file tree

Hide file tree

Showing 11 changed files with 463 additions and 18 deletions.
diff --git a/.changelog/2769.feature.1.md b/.changelog/2769.feature.1.md
@@ -0,0 +1,4 @@
+txsource/queries: workload doing historical queries
+
+Queries workload continuously performs various historic queries using the
+exposed APIs and makes sure the responses make sense.
diff --git a/go/oasis-node/cmd/debug/txsource/txsource.go b/go/oasis-node/cmd/debug/txsource/txsource.go
@@ -22,7 +22,6 @@ import (
 	cmdFlags "github.com/oasislabs/oasis-core/go/oasis-node/cmd/common/flags"
 	cmdGrpc "github.com/oasislabs/oasis-core/go/oasis-node/cmd/common/grpc"
 	"github.com/oasislabs/oasis-core/go/oasis-node/cmd/debug/txsource/workload"
-	runtimeClient "github.com/oasislabs/oasis-core/go/runtime/client/api"
 )
 
 const (
@@ -95,9 +94,6 @@ func doRun(cmd *cobra.Command, args []string) error {
 	// Set up the consensus client.
 	cnsc := consensus.NewConsensusClient(conn)
 
-	// Set up the runtime client.
-	rtc := runtimeClient.NewRuntimeClient(conn)
-
 	// Wait for sync before transferring control to the workload.
 	ncc := api.NewNodeControllerClient(conn)
 	logger.Debug("waiting for node sync")
@@ -120,7 +116,7 @@ func doRun(cmd *cobra.Command, args []string) error {
 	}
 
 	logger.Debug("entering workload", "name", name)
-	if err = w.Run(ctx, rng, conn, cnsc, rtc, fundingAccount); err != nil {
+	if err = w.Run(ctx, rng, conn, cnsc, fundingAccount); err != nil {
 		logger.Error("workload error", "err", err)
 		return fmt.Errorf("workload %s: %w", name, err)
 	}

diff --git a/go/oasis-node/cmd/debug/txsource/workload/delegation.go b/go/oasis-node/cmd/debug/txsource/workload/delegation.go
@@ -13,7 +13,6 @@ import (
 	"github.com/oasislabs/oasis-core/go/common/logging"
 	consensus "github.com/oasislabs/oasis-core/go/consensus/api"
 	"github.com/oasislabs/oasis-core/go/consensus/api/transaction"
-	runtimeClient "github.com/oasislabs/oasis-core/go/runtime/client/api"
 	staking "github.com/oasislabs/oasis-core/go/staking/api"
 )
 
@@ -178,7 +177,6 @@ func (d *delegation) Run(
 	rng *rand.Rand,
 	conn *grpc.ClientConn,
 	cnsc consensus.ClientBackend,
-	rtc runtimeClient.RuntimeClient,
 	fundingAccount signature.Signer,
 ) error {
 	var err error

diff --git a/go/oasis-node/cmd/debug/txsource/workload/oversized.go b/go/oasis-node/cmd/debug/txsource/workload/oversized.go
@@ -13,7 +13,6 @@ import (
 	"github.com/oasislabs/oasis-core/go/common/logging"
 	consensus "github.com/oasislabs/oasis-core/go/consensus/api"
 	"github.com/oasislabs/oasis-core/go/consensus/api/transaction"
-	runtimeClient "github.com/oasislabs/oasis-core/go/runtime/client/api"
 	staking "github.com/oasislabs/oasis-core/go/staking/api"
 )
 
@@ -33,7 +32,6 @@ func (oversized) Run(
 	rng *rand.Rand,
 	conn *grpc.ClientConn,
 	cnsc consensus.ClientBackend,
-	rtc runtimeClient.RuntimeClient,
 	fundingAccount signature.Signer,
 ) error {
 	txSignerFactory := memorySigner.NewFactory()

diff --git a/go/oasis-node/cmd/debug/txsource/workload/parallel.go b/go/oasis-node/cmd/debug/txsource/workload/parallel.go
@@ -14,7 +14,6 @@ import (
 	"github.com/oasislabs/oasis-core/go/common/logging"
 	consensus "github.com/oasislabs/oasis-core/go/consensus/api"
 	"github.com/oasislabs/oasis-core/go/consensus/api/transaction"
-	runtimeClient "github.com/oasislabs/oasis-core/go/runtime/client/api"
 	staking "github.com/oasislabs/oasis-core/go/staking/api"
 )
 
@@ -39,7 +38,6 @@ func (parallel) Run(
 	rng *rand.Rand,
 	conn *grpc.ClientConn,
 	cnsc consensus.ClientBackend,
-	rtc runtimeClient.RuntimeClient,
 	fundingAccount signature.Signer,
 ) error {
 	ctx := context.Background()