Add MaxConcurrency to GetConfig - for use when using Get hydrate as a column hydrate function. Closes #353

Author: kaidaguerre

plugin/get_config.go

@@ -22,6 +22,8 @@ type GetConfig struct {
 	ShouldIgnoreError ErrorPredicate
 	IgnoreConfig      *IgnoreConfig
 	RetryConfig       *RetryConfig
+	// max concurrency - this applies when the get function is ALSO used as a column hydrate function
+	MaxConcurrency int
 }
 
 // initialise the GetConfig

plugin/table.go

@@ -139,6 +139,7 @@ func (t *Table) buildHydrateConfigMap() {
 			ShouldIgnoreError: get.ShouldIgnoreError,
 			IgnoreConfig:      get.IgnoreConfig,
 			RetryConfig:       get.RetryConfig,
+			MaxConcurrency:    get.MaxConcurrency,
 		}
 	}