From a4d381fceb683011fd4b6652a223e82f940767cd Mon Sep 17 00:00:00 2001 From: shohamroditimemphis Date: Thu, 21 Dec 2023 13:19:17 +0200 Subject: [PATCH] add-created-at-to-connectors-on-get-station-overview-data-get-connector-details --- db/db.go | 2 +- db/db_cloud.go | 20 +++++++++++--------- 2 files changed, 12 insertions(+), 10 deletions(-) diff --git a/db/db.go b/db/db.go index 035d0911c..0958184fc 100644 --- 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 index 7fb6c1e4a..ffba68a68 100644 --- 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 -} \ No newline at end of file +}