Merge pull request #1549 from memphisdev/RND-368-add-created-at-to-co…

…nnectors-on-get-station-overview-data-get-connector-details add-created-at-to-connectors-on-get-station-overview-data-get-connect…
superstreamlabs · Dec 21, 2023 · 3058fd2 · 3058fd2
2 parents f6638a1 + a4d381f
commit 3058fd2
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 10 deletions.
diff --git a/db/db.go b/db/db.go
@@ -613,7 +613,7 @@ func createTables(MetadataDbClient MetadataStorage) error {
 	db := MetadataDbClient.Client
 	ctx := MetadataDbClient.Ctx
 
-	tables := []string{alterTenantsTable, tenantsTable, alterUsersTable, usersTable, alterAuditLogsTable, auditLogsTable, alterConfigurationsTable, configurationsTable, alterIntegrationsTable, integrationsTable, alterSchemasTable, schemasTable, alterTagsTable, tagsTable, alterStationsTable, stationsTable, alterDlsMsgsTable, dlsMessagesTable, alterConsumersTable, consumersTable, alterSchemaVerseTable, schemaVersionsTable, alterProducersTable, producersTable, alterConnectionsTable, asyncTasksTable, alterAsyncTasks, testEventsTable, functionsTable, attachedFunctionsTable, sharedLocksTable, functionsEngineWorkersTable, scheduledFunctionWorkersTable, connectorsEngineWorkersTable, connectorsConnectionsTable, connectorsTable}
+	tables := []string{alterTenantsTable, tenantsTable, alterUsersTable, usersTable, alterAuditLogsTable, auditLogsTable, alterConfigurationsTable, configurationsTable, alterIntegrationsTable, integrationsTable, alterSchemasTable, schemasTable, alterTagsTable, tagsTable, alterStationsTable, stationsTable, alterDlsMsgsTable, dlsMessagesTable, alterConsumersTable, consumersTable, alterSchemaVerseTable, schemaVersionsTable, alterProducersTable, producersTable, alterConnectionsTable, asyncTasksTable, alterAsyncTasks, testEventsTable, functionsTable, attachedFunctionsTable, sharedLocksTable, functionsEngineWorkersTable, scheduledFunctionWorkersTable, connectorsEngineWorkersTable, connectorsConnectionsTable, connectorsTable, alterConnectorsTable, alterConnectorsConnectionsTable}
 
 	for _, table := range tables {
 		_, err := db.Exec(ctx, table)

diff --git a/db/db_cloud.go b/db/db_cloud.go
@@ -12,14 +12,16 @@
 package db
 
 const (
-	testEventsTable               = ``
-	functionsTable                = ``
-	attachedFunctionsTable        = ``
-	functionsEngineWorkersTable   = ``
-	scheduledFunctionWorkersTable = ``
-	connectorsEngineWorkersTable  = ``
-	connectorsConnectionsTable    = ``
-	connectorsTable               = ``
+	testEventsTable                 = ``
+	functionsTable                  = ``
+	attachedFunctionsTable          = ``
+	functionsEngineWorkersTable     = ``
+	scheduledFunctionWorkersTable   = ``
+	connectorsEngineWorkersTable    = ``
+	connectorsConnectionsTable      = ``
+	connectorsTable                 = ``
+	alterConnectorsTable            = ``
+	alterConnectorsConnectionsTable = ``
 )
 
 type FunctionSchema struct {
@@ -58,4 +60,4 @@ func DeleteAllTestEvents(tenantName string) error {
 
 func DeleteScheduledFunctionWorkersByTenant(tenantName string) error {
 	return nil
-}
+}