DBState enum for postgres

wader · Jul 20, 2022 · 3b81d99 · 3b81d99
1 parent 0107d12
commit 3b81d99
Show file tree

Hide file tree

Showing 4 changed files with 38 additions and 6 deletions.
diff --git a/format/postgres/common/common.go b/format/postgres/common/common.go
@@ -0,0 +1,23 @@
+package common
+
+import "github.com/wader/fq/pkg/scalar"
+
+//typedef enum DBState
+//{
+//	DB_STARTUP = 0,
+//	DB_SHUTDOWNED,
+//	DB_SHUTDOWNED_IN_RECOVERY,
+//	DB_SHUTDOWNING,
+//	DB_IN_CRASH_RECOVERY,
+//	DB_IN_ARCHIVE_RECOVERY,
+//	DB_IN_PRODUCTION
+//} DBState;
+var DBState = scalar.UToScalar{
+	0: {Sym: "DB_STARTUP"},
+	1: {Sym: "DB_SHUTDOWNED"},
+	2: {Sym: "DB_SHUTDOWNED_IN_RECOVERY"},
+	3: {Sym: "DB_SHUTDOWNING"},
+	4: {Sym: "DB_IN_CRASH_RECOVERY"},
+	5: {Sym: "DB_IN_ARCHIVE_RECOVERY"},
+	6: {Sym: "DB_IN_PRODUCTION"},
+}
diff --git a/format/postgres/flavours/pgproee14/pg_control.go b/format/postgres/flavours/pgproee14/pg_control.go
@@ -1,6 +1,9 @@
 package pgproee14
 
-import "github.com/wader/fq/pkg/decode"
+import (
+	"github.com/wader/fq/format/postgres/common"
+	"github.com/wader/fq/pkg/decode"
+)
 
 // type = struct ControlFileData {
 /*    0      |     8 */ // uint64 system_identifier;
@@ -84,7 +87,7 @@ func DecodePgControl(d *decode.D, in any) any {
 	d.FieldU64("system_identifier")
 	d.FieldU32("pg_control_version")
 	d.FieldU32("catalog_version_no")
-	d.FieldU32("state")
+	d.FieldU32("state", common.DBState)
 	d.U32()
 
 	/*   24      |     8 */ // pg_time_t time;

diff --git a/format/postgres/flavours/postgres11/pg_control.go b/format/postgres/flavours/postgres11/pg_control.go
@@ -1,6 +1,9 @@
 package postgres11
 
-import "github.com/wader/fq/pkg/decode"
+import (
+	"github.com/wader/fq/format/postgres/common"
+	"github.com/wader/fq/pkg/decode"
+)
 
 // type = struct ControlFileData {
 /*    0      |     8 */ // uint64 system_identifier;
@@ -82,7 +85,7 @@ func DecodePgControl(d *decode.D, in any) any {
 	d.FieldU64("system_identifier")
 	d.FieldU32("pg_control_version")
 	d.FieldU32("catalog_version_no")
-	d.FieldU32("state")
+	d.FieldU32("state", common.DBState)
 	d.U32()
 
 	/*   24      |     8 */ // pg_time_t time;

diff --git a/format/postgres/flavours/postgres14/pg_control.go b/format/postgres/flavours/postgres14/pg_control.go
@@ -1,6 +1,9 @@
 package postgres14
 
-import "github.com/wader/fq/pkg/decode"
+import (
+	"github.com/wader/fq/format/postgres/common"
+	"github.com/wader/fq/pkg/decode"
+)
 
 // type = struct ControlFileData {
 /*    0      |     8 */ // uint64 system_identifier;
@@ -80,7 +83,7 @@ func DecodePgControl(d *decode.D, in any) any {
 	d.FieldU64("system_identifier")
 	d.FieldU32("pg_control_version")
 	d.FieldU32("catalog_version_no")
-	d.FieldU32("state")
+	d.FieldU32("state", common.DBState)
 	d.U32()
 
 	/*   24      |     8 */ // pg_time_t time;