update UI and lint

PeerDB-io · Dec 13, 2023 · ff82804 · ff82804
1 parent a26e26b
commit ff82804
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 1 deletion.
diff --git a/flow/connectors/kafka/kafka.go b/flow/connectors/kafka/kafka.go
@@ -162,7 +162,6 @@ func (c *KafkaConnector) GetLastOffset(jobName string) (*protos.LastSyncState, e
 	lastMessage, readErr := c.consumer.ReadMessage(60 * time.Second)
 	if readErr != nil {
 		if strings.Contains(readErr.Error(), "Timed out") {
-
 			return nil, nil
 		}
 		return nil, fmt.Errorf("unable to read latest offset: %w", readErr)

diff --git a/ui/components/PeerTypeComponent.tsx b/ui/components/PeerTypeComponent.tsx
@@ -22,6 +22,8 @@ export const DBTypeToGoodText = (ptype: DBType) => {
       return 'SQL Server';
     case DBType.MONGO:
       return 'MongoDB';
+    case DBType.KAFKA:
+      return 'Kafka';
     case DBType.UNRECOGNIZED:
       return 'Unrecognised';
   }

diff --git a/ui/prisma/schema.prisma b/ui/prisma/schema.prisma
@@ -155,6 +155,7 @@ model peer_slot_size {
   confirmed_flush_lsn String?
   slot_size           BigInt?
   updated_at          DateTime @default(now()) @db.Timestamp(6)
+  wal_status          String?
 
   @@index([slot_name], map: "index_slot_name")
   @@schema("peerdb_stats")