Merge pull request #2766 from oasislabs/ptrus/feature/txsource-delega…

…tion-commission

go/txsource: commission schedule amendments workload

.changelog/2766.feature.md

@@ -0,0 +1,3 @@
+go/txsource: add a commission schedule amendments workload
+
+The added workload generated commission schedule amendment requests.

go/consensus/tendermint/apps/staking/query.go

@@ -23,6 +23,7 @@ type Query interface {
 	Delegations(context.Context, signature.PublicKey) (map[signature.PublicKey]*staking.Delegation, error)
 	DebondingDelegations(context.Context, signature.PublicKey) (map[signature.PublicKey][]*staking.DebondingDelegation, error)
 	Genesis(context.Context) (*staking.Genesis, error)
+	ConsensusParameters(context.Context) (*staking.ConsensusParameters, error)
 }
 
 // QueryFactory is the staking query factory.
@@ -105,6 +106,10 @@ func (sq *stakingQuerier) DebondingDelegations(ctx context.Context, id signature
 	return sq.state.DebondingDelegationsFor(id)
 }
 
+func (sq *stakingQuerier) ConsensusParameters(ctx context.Context) (*staking.ConsensusParameters, error) {
+	return sq.state.ConsensusParameters()
+}
+
 func (app *stakingApplication) QueryFactory() interface{} {
 	return &QueryFactory{app}
 }

go/consensus/tendermint/staking/staking.go

@@ -140,6 +140,14 @@ func (tb *tendermintBackend) StateToGenesis(ctx context.Context, height int64) (
 	return q.Genesis(ctx)
 }
 
+func (tb *tendermintBackend) ConsensusParameters(ctx context.Context, height int64) (*api.ConsensusParameters, error) {
+	q, err := tb.querier.QueryAt(ctx, height)
+	if err != nil {
+		return nil, err
+	}
+
+	return q.ConsensusParameters(ctx)
+}
 func (tb *tendermintBackend) Cleanup() {
 	<-tb.closedCh
 }