fabric batch operations

Signed-off-by: Fedor Partanskiy <fedor.partanskiy@atme.com>

Author: pfi79

core/chaincode/chaincode_support.go

@@ -73,6 +73,8 @@ type ChaincodeSupport struct {
 	Runtime                Runtime
 	TotalQueryLimit        int
 	UserRunsCC             bool
+	UseWriteBatch          bool
+	MaxSizeWriteBatch      uint32
 }
 
 // Launch starts executing chaincode if it is not already running. This method
@@ -126,6 +128,8 @@ func (cs *ChaincodeSupport) HandleChaincodeStream(stream ccintf.ChaincodeStream)
 		AppConfig:              cs.AppConfig,
 		Metrics:                cs.HandlerMetrics,
 		TotalQueryLimit:        cs.TotalQueryLimit,
+		UseWriteBatch:          cs.UseWriteBatch,
+		MaxSizeWriteBatch:      cs.MaxSizeWriteBatch,
 	}
 
 	return handler.ProcessStream(stream)

core/chaincode/config.go

@@ -16,21 +16,24 @@ import (
 )
 
 const (
-	defaultExecutionTimeout = 30 * time.Second
-	minimumStartupTimeout   = 5 * time.Second
+	defaultExecutionTimeout  = 30 * time.Second
+	minimumStartupTimeout    = 5 * time.Second
+	defaultMaxSizeWriteBatch = 1000
 )
 
 type Config struct {
-	TotalQueryLimit int
-	TLSEnabled      bool
-	Keepalive       time.Duration
-	ExecuteTimeout  time.Duration
-	InstallTimeout  time.Duration
-	StartupTimeout  time.Duration
-	LogFormat       string
-	LogLevel        string
-	ShimLogLevel    string
-	SCCAllowlist    map[string]bool
+	TotalQueryLimit   int
+	TLSEnabled        bool
+	Keepalive         time.Duration
+	ExecuteTimeout    time.Duration
+	InstallTimeout    time.Duration
+	StartupTimeout    time.Duration
+	LogFormat         string
+	LogLevel          string
+	ShimLogLevel      string
+	SCCAllowlist      map[string]bool
+	UseWriteBatch     bool
+	MaxSizeWriteBatch uint32
 }
 
 func GlobalConfig() *Config {
@@ -71,6 +74,13 @@ func (c *Config) load() {
 	if viper.IsSet("ledger.state.totalQueryLimit") {
 		c.TotalQueryLimit = viper.GetInt("ledger.state.totalQueryLimit")
 	}
+	if viper.IsSet("chaincode.additionalParams.useWriteBatch") {
+		c.UseWriteBatch = viper.GetBool("chaincode.additionalParams.useWriteBatch")
+	}
+	c.MaxSizeWriteBatch = viper.GetUint32("ledger.state.maxSizeWriteBatch")
+	if c.MaxSizeWriteBatch <= 0 {
+		c.MaxSizeWriteBatch = defaultMaxSizeWriteBatch
+	}
 }
 
 func parseBool(s string) bool {