go fmt

PeerDB-io · Nov 10, 2023 · 5800dc8 · 5800dc8
1 parent 834ea32
commit 5800dc8
Show file tree

Hide file tree

Showing 5 changed files with 10 additions and 10 deletions.
diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
@@ -191,8 +191,8 @@ func (a *FlowableActivity) StartFlow(ctx context.Context,
 		for _, col := range v.Exclude {
 			exclude[col] = struct{}{}
 		}
-		tblNameMapping[v.SourceTableIdentifier] = model.NameAndExclude {
-			Name: v.DestinationTableIdentifier,
+		tblNameMapping[v.SourceTableIdentifier] = model.NameAndExclude{
+			Name:    v.DestinationTableIdentifier,
 			Exclude: exclude,
 		}
 	}

diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go
@@ -782,10 +782,10 @@ func (c *PostgresConnector) SetupReplication(signal *SlotSignal, req *protos.Set
 		return fmt.Errorf("error checking for replication slot and publication: %w", err)
 	}
 
-	tableNameMapping := make(map[string]model.NameAndExclude);
+	tableNameMapping := make(map[string]model.NameAndExclude)
 	for k, v := range req.TableNameMapping {
-		tableNameMapping[k] = model.NameAndExclude {
-			Name: v,
+		tableNameMapping[k] = model.NameAndExclude{
+			Name:    v,
 			Exclude: make(map[string]struct{}, 0),
 		}
 	}

diff --git a/flow/model/model.go b/flow/model/model.go
@@ -13,7 +13,7 @@ import (
 )
 
 type NameAndExclude struct {
-	Name string
+	Name    string
 	Exclude map[string]struct{}
 }
 

diff --git a/flow/workflows/setup_flow.go b/flow/workflows/setup_flow.go
@@ -201,9 +201,9 @@ func (s *SetupFlowExecution) fetchTableSchemaAndSetupNormalizedTables(
 			if mapping.SourceTableIdentifier == srcTableName {
 				if len(mapping.Exclude) != 0 {
 					tableSchema = &protos.TableSchema{
-						TableIdentifier: tableSchema.TableIdentifier,
-						Columns: maps.Clone(tableSchema.Columns),
-						PrimaryKeyColumns: tableSchema.PrimaryKeyColumns,
+						TableIdentifier:       tableSchema.TableIdentifier,
+						Columns:               maps.Clone(tableSchema.Columns),
+						PrimaryKeyColumns:     tableSchema.PrimaryKeyColumns,
 						IsReplicaIdentityFull: tableSchema.IsReplicaIdentityFull,
 					}
 					for _, exclude := range mapping.Exclude {

diff --git a/flow/workflows/snapshot_flow.go b/flow/workflows/snapshot_flow.go
@@ -12,10 +12,10 @@ import (
 	"github.com/PeerDB-io/peer-flow/shared"
 	"github.com/google/uuid"
 	logrus "github.com/sirupsen/logrus"
-	"golang.org/x/exp/maps"
 	"go.temporal.io/sdk/log"
 	"go.temporal.io/sdk/temporal"
 	"go.temporal.io/sdk/workflow"
+	"golang.org/x/exp/maps"
 )
 
 type SnapshotFlowExecution struct {