Move NameAndExclude set contruction to constructor

flow/activities/flowable.go

@@ -187,14 +187,7 @@ func (a *FlowableActivity) StartFlow(ctx context.Context,
 
 	tblNameMapping := make(map[string]model.NameAndExclude)
 	for _, v := range input.FlowConnectionConfigs.TableMappings {
-		exclude := make(map[string]struct{}, len(v.Exclude))
-		for _, col := range v.Exclude {
-			exclude[col] = struct{}{}
-		}
-		tblNameMapping[v.SourceTableIdentifier] = model.NameAndExclude{
-			Name:    v.DestinationTableIdentifier,
-			Exclude: exclude,
-		}
+		tblNameMapping[v.SourceTableIdentifier] = model.NewNameAndExclude(v.DestinationTableIdentifier, v.Exclude)
 	}
 
 	idleTimeout := utils.GetEnvInt("PEERDB_CDC_IDLE_TIMEOUT_SECONDS", 10)

flow/model/model.go

@@ -17,6 +17,14 @@ type NameAndExclude struct {
 	Exclude map[string]struct{}
 }
 
+func NewNameAndExclude(name string, exclude []string) NameAndExclude {
+	exset := make(map[string]struct{}, len(exclude))
+	for _, col := range exclude {
+		exset[col] = struct{}{}
+	}
+	return NameAndExclude{Name: name, Exclude: exset}
+}
+
 type PullRecordsRequest struct {
 	// FlowJobName is the name of the flow job.
 	FlowJobName string