lint2

PeerDB-io · Oct 13, 2023 · af9e493 · af9e493
1 parent 6b37a36
commit af9e493
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go
@@ -29,6 +29,10 @@ type EventHubConnector struct {
 	hubManager   *EventHubManager
 }
 
+const (
+	metadataSchemaName = "peerdb_eventhub_metadata"
+)
+
 // NewEventHubConnector creates a new EventHubConnector.
 func NewEventHubConnector(
 	ctx context.Context,
@@ -41,7 +45,7 @@ func NewEventHubConnector(
 	}
 
 	hubManager := NewEventHubManager(ctx, defaultAzureCreds, config)
-	metadataSchemaName := "peerdb_eventhub_metadata"
+
 	pgMetadata, err := metadataStore.NewPostgresMetadataStore(ctx, config.GetMetadataDb(),
 		metadataSchemaName)
 	if err != nil {

diff --git a/flow/connectors/s3/s3.go b/flow/connectors/s3/s3.go
@@ -22,6 +22,10 @@ type S3Connector struct {
 	creds      utils.S3PeerCredentials
 }
 
+const (
+	metadataSchemaName = "peerdb_s3_metadata"
+)
+
 func NewS3Connector(ctx context.Context,
 	config *protos.S3Config) (*S3Connector, error) {
 	keyID := ""
@@ -55,7 +59,7 @@ func NewS3Connector(ctx context.Context,
 	if err != nil {
 		return nil, fmt.Errorf("failed to create S3 client: %w", err)
 	}
-	metadataSchemaName := "peerdb_s3_metadata"
+
 	pgMetadata, err := metadataStore.NewPostgresMetadataStore(ctx,
 		config.GetMetadataDb(), metadataSchemaName)
 	if err != nil {