Release steampipe-postgres-fdw v2.2.0

.claude/CLAUDE.md

@@ -0,0 +1,36 @@
+# Release Process
+
+## Files to update
+1. **`version/version.go`**: Update `fdwVersion` to the new version (e.g., `"2.2.0"`).
+2. **`CHANGELOG.md`**: Add a new entry at the top for the release version with the current date.
+
+## Commit
+- Commit message for release changes should always be the release version number (e.g., `v2.2.0`).
+
+## Release PRs
+When creating PRs for a release, always create two:
+1. Against `develop`: title should be `Merge branch '<branchname>' into develop`
+2. Against `main`: title should be `Release steampipe-postgres-fdw v<version>`
+
+## Tagging and Build
+1. Create a git tag matching the version (e.g., `v2.2.0`) on the release branch commit.
+2. Push the tag to origin. This triggers the **Build Draft Release** workflow (`.github/workflows/buildimage.yml`).
+3. The workflow builds the FDW shared library for all four platforms:
+   - Darwin x86_64 (`macos-15-intel`)
+   - Darwin ARM64 (`macos-latest`)
+   - Linux x86_64 (`ubuntu-22.04`)
+   - Linux ARM64 (`ubuntu-22.04-arm`)
+4. On success, it creates a **draft release** on GitHub with all build artifacts.
+5. Verify all build jobs pass before proceeding.
+
+## Publishing the FDW Image
+1. Trigger the **Publish FDW Image** workflow (`.github/workflows/publish.yml`) manually via `workflow_dispatch`.
+   - **Branch:** `develop`
+   - **Input `release`:** the version tag (e.g., `v2.2.0`)
+2. This workflow downloads the draft release assets and pushes the FDW image to `ghcr.io/turbot/steampipe/fdw:<version>`.
+3. Non-RC versions are also tagged as `latest`.
+
+## Testing a workflow change without releasing
+1. Push a temporary test tag (e.g., `v0.0.0-test-runner`) from the branch with the workflow change.
+2. Verify all build jobs pass.
+3. Clean up: delete the test tag (`git push origin --delete <tag>`) and the draft release (`gh release delete <tag> --yes`).

.github/workflows/buildimage.yml

@@ -43,7 +43,7 @@ jobs:
       - name: Setup Golang
         uses: actions/setup-go@0aaccfd150d50ccaeb58ebd88d36e91967a5f35b # v5.4.0
         with:
-          go-version: 1.24
+          go-version: 1.26
 
       - name: Fetching Go Cache Paths
         id: go-cache-paths
@@ -162,7 +162,7 @@ jobs:
       - name: Setup Golang
         uses: actions/setup-go@0aaccfd150d50ccaeb58ebd88d36e91967a5f35b # v5.4.0
         with:
-          go-version: 1.24
+          go-version: 1.26
 
       - name: Fetching Go Cache Paths
         id: go-cache-paths
@@ -248,7 +248,7 @@ jobs:
       - name: Setup GoLang
         uses: actions/setup-go@0aaccfd150d50ccaeb58ebd88d36e91967a5f35b # v5.4.0
         with:
-          go-version: 1.24
+          go-version: 1.26
 
       - name: Fetching Go Cache Paths
         id: go-cache-paths
@@ -333,7 +333,7 @@ jobs:
       - name: Setup GoLang
         uses: actions/setup-go@0aaccfd150d50ccaeb58ebd88d36e91967a5f35b # v5.4.0
         with:
-          go-version: 1.24
+          go-version: 1.26
 
       - name: Fetching Go Cache Paths
         id: go-cache-paths

.github/workflows/test.yml

@@ -13,7 +13,7 @@ jobs:
       - name: Set up Go
         uses: actions/setup-go@0aaccfd150d50ccaeb58ebd88d36e91967a5f35b # v5.4.0
         with:
-          go-version: 1.24
+          go-version: 1.26
 
       - name: golangci-lint
         uses: golangci/golangci-lint-action@55c2c1448f86e01eaae002a5a3a9624417608d84 # v6.5.2
@@ -30,7 +30,7 @@ jobs:
       - name: Set up Go
         uses: actions/setup-go@0aaccfd150d50ccaeb58ebd88d36e91967a5f35b # v5.4.0
         with:
-          go-version: 1.24
+          go-version: 1.26
 
       - name: Checkout Steampipe
         uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4.2.2

.gitignore

@@ -7,6 +7,7 @@
 steampipe_postgres_fdw.h
 # generated C imports
 0_prebuild.go
+prebuild.go
 
 # Binaries for programs and plugins
 *.exe
@@ -27,4 +28,4 @@ build-*/
 # intermediate files from clang
 *.bc
 # work directory created by the standalone fdw building
-/work
+/work

CHANGELOG.md

@@ -1,3 +1,15 @@
+## v2.2.0 [2026-02-27]
+_Whats new_
+- Compiled with Go 1.26.
+- Add support for propagation of OpenTelemetry context from clients. ([#568](https://github.com/turbot/steampipe-postgres-fdw/pull/568))
+- Add support for propagation of OpenTelemetry context from clients with SQLcommenter. ([#569](https://github.com/turbot/steampipe-postgres-fdw/pull/569))
+
+_Bug fixes_
+- Fix OpenTelemetry metric names to only contain `[A-Za-z0-9_.-]`. ([#595](https://github.com/turbot/steampipe-postgres-fdw/pull/595))
+
+_Dependencies_
+- Bump `github.com/go-git/go-git/v5` to remediate vulnerabilities.
+
 ## v2.1.5 [2026-02-06]
 _Bug fixes_
 - Fix memory leaks caused by unfreed `C.CString()` allocations across multiple functions. ([#618](https://github.com/turbot/steampipe-postgres-fdw/pull/618), [#620](https://github.com/turbot/steampipe-postgres-fdw/pull/620), [#622](https://github.com/turbot/steampipe-postgres-fdw/pull/622), [#624](https://github.com/turbot/steampipe-postgres-fdw/pull/624), [#631](https://github.com/turbot/steampipe-postgres-fdw/pull/631))

CLAUDE.md

@@ -0,0 +1,32 @@
+# Release Process
+
+## Changelog commits
+- Commit message for release changelog changes should always be the release version number (e.g., `v2.1.5`).
+
+## Release PRs
+When creating PRs for a release, always create two:
+1. Against `develop`: title should be `Merge branch '<branchname>' into develop`
+2. Against `main`: title should be `Release steampipe-postgres-fdw v<version>`
+
+## Tagging and Build
+1. Create a git tag matching the version (e.g., `v2.1.5`) on the release branch commit.
+2. Push the tag to origin. This triggers the **Build Draft Release** workflow (`.github/workflows/buildimage.yml`).
+3. The workflow builds the FDW shared library for all four platforms:
+   - Darwin x86_64 (`macos-15-intel`)
+   - Darwin ARM64 (`macos-latest`)
+   - Linux x86_64 (`ubuntu-22.04`)
+   - Linux ARM64 (`ubuntu-22.04-arm`)
+4. On success, it creates a **draft release** on GitHub with all build artifacts.
+5. Verify all build jobs pass before proceeding.
+
+## Publishing the FDW Image
+1. Trigger the **Publish FDW Image** workflow (`.github/workflows/publish.yml`) manually via `workflow_dispatch`.
+   - **Branch:** `develop`
+   - **Input `release`:** the version tag (e.g., `v2.1.5`)
+2. This workflow downloads the draft release assets and pushes the FDW image to `ghcr.io/turbot/steampipe/fdw:<version>`.
+3. Non-RC versions are also tagged as `latest`.
+
+## Testing a workflow change without releasing
+1. Push a temporary test tag (e.g., `v0.0.0-test-runner`) from the branch with the workflow change.
+2. Verify all build jobs pass.
+3. Clean up: delete the test tag (`git push origin --delete <tag>`) and the draft release (`gh release delete <tag> --yes`).

README.md

@@ -32,7 +32,7 @@ Steps:
 1. Change to the cloned directory
 1. Run the following commands:
 ```
-$ make
+$ make install
 ```
 
 This will compile the FDW (`steampipe_postgres_fdw.so`) along with the `control` and `sql` file in the `build-$PLATFORM` directory. This will install the compiled FDW into the default Steampipe installation directory (`~/.steampipe`) - if it exists.

fdw.go

@@ -19,6 +19,7 @@ import (
 	"net"
 	"net/http"
 	"os"
+	"strings"
 	"time"
 	"unsafe"
 
@@ -172,6 +173,30 @@ func goFdwGetRelSize(state *C.FdwPlanState, root *C.PlannerInfo, rows *C.double,
 
 	tableOpts := GetFTableOptions(types.Oid(state.foreigntableid))
 
+	// Extract trace context if available
+	var traceContext string
+	if state.trace_context_string != nil {
+		traceContext = C.GoString(state.trace_context_string)
+		log.Printf("[TRACE] Extracted trace context from session: %s", traceContext)
+
+		if len(traceContext) > 0 {
+			log.Printf("[DEBUG] Trace context length: %d characters", len(traceContext))
+			if strings.Contains(traceContext, "traceparent=") {
+				log.Printf("[DEBUG] Trace context contains traceparent field")
+			} else {
+				log.Printf("[WARN] Trace context missing traceparent field - may be malformed")
+			}
+		}
+	} else {
+		log.Printf("[DEBUG] No trace context found in session variables")
+	}
+
+	// Add trace context to options for hub layer
+	if traceContext != "" {
+		tableOpts["trace_context"] = traceContext
+		log.Printf("[DEBUG] Added trace context to table options")
+	}
+
 	// build columns
 	var columns []string
 	if state.target_list != nil {
@@ -299,6 +324,21 @@ func goFdwBeginForeignScan(node *C.ForeignScanState, eflags C.int) {
 	plan := (*C.ForeignScan)(unsafe.Pointer(node.ss.ps.plan))
 	var execState *C.FdwExecState = C.initializeExecState(unsafe.Pointer(plan.fdw_private))
 
+	// Extract trace context from session variables for scan operation
+	var traceContext string
+	if traceContextPtr := C.getTraceContext(); traceContextPtr != nil {
+		traceContext = C.GoString(traceContextPtr)
+		log.Printf("[TRACE] Extracted trace context from session for scan: %s", traceContext)
+	} else {
+		log.Printf("[DEBUG] No trace context found in session variables for scan")
+	}
+
+	// Add trace context to options for hub layer
+	if traceContext != "" {
+		opts["trace_context"] = traceContext
+		log.Printf("[DEBUG] Added trace context to scan options")
+	}
+
 	log.Printf("[INFO] goFdwBeginForeignScan, canPushdownAllSortFields %v", execState.canPushdownAllSortFields)
 	var columns []string
 	if execState.target_list != nil {

fdw/common.h

@@ -67,6 +67,8 @@ typedef struct FdwPlanState
   int width;
   // the number of rows to return (limit+offset). -1 means no limit
   int limit;
+  // OpenTelemetry trace context extracted from session variables
+  char *trace_context_string;
 
 } FdwPlanState;
 
@@ -133,4 +135,4 @@ List *deserializeDeparsedSortGroup(List *items);
 OpExpr *canonicalOpExpr(OpExpr *opExpr, Relids base_relids);
 ScalarArrayOpExpr *canonicalScalarArrayOpExpr(ScalarArrayOpExpr *opExpr, Relids base_relids);
 char *getOperatorString(Oid opoid);
-#endif // FDW_COMMON_H
+#endif // FDW_COMMON_H