.github/renovate.json5

@@ -1,12 +1,14 @@
 {
   extends: [
-    "github>cloudquery/.github//.github/renovate-go-default.json5",
-    "github>cloudquery/.github//.github/renovate-node-default.json5",
+    'github>cloudquery/.github//.github/renovate-go-default.json5',
+    'github>cloudquery/.github//.github/renovate-node-default.json5',
   ],
   packageRules: [
     {
-      matchPackagePatterns: ["github.com/cloudquery/plugin-sdk/*"],
-      commitMessagePrefix: "chore(deps): ",
+      commitMessagePrefix: 'chore(deps): ',
+      matchPackageNames: [
+        '/github.com/cloudquery/plugin-sdk/*/',
+      ],
     },
   ],
 }

.github/workflows/lint_golang.yml

@@ -10,7 +10,7 @@ on:
 jobs:
   golangci:
     name: Lint with GolangCI
-    runs-on: large-ubuntu-plugin-sdk
+    runs-on: ubicloud-standard-8
     timeout-minutes: 10
     steps:
       - uses: actions/checkout@v4
@@ -20,4 +20,4 @@ jobs:
       - name: golangci-lint
         uses: golangci/golangci-lint-action@v6
         with:
-          version: v1.63.4
+          version: v1.64.5

.github/workflows/unittest.yml

@@ -11,7 +11,7 @@ jobs:
   unitests:
     strategy:
       matrix:
-        os: [large-ubuntu-plugin-sdk, large-windows-plugin-sdk, macos-latest]
+        os: [ubicloud-standard-8, large-windows-plugin-sdk, macos-latest]
     runs-on: ${{ matrix.os }}
     timeout-minutes: 15
     steps:
@@ -26,13 +26,13 @@ jobs:
       - name: Run tests
         run: make test
       - name: Run benchmark
-        if: matrix.os == 'large-ubuntu-plugin-sdk'
+        if: matrix.os == 'ubicloud-standard-8'
         run: make benchmark-ci
       - name: Save PR number
-        if: matrix.os == 'large-ubuntu-plugin-sdk' && github.event_name == 'pull_request'
+        if: matrix.os == 'ubicloud-standard-8' && github.event_name == 'pull_request'
         run: echo ${{ github.event.number }} > ./pr_number
       - name: Upload deltas
-        if: matrix.os == 'large-ubuntu-plugin-sdk'
+        if: matrix.os == 'ubicloud-standard-8'
         uses: actions/upload-artifact@v4
         with:
           name: delta-action-benchmarks

.golangci.yml

@@ -5,7 +5,6 @@ run:
 linters-settings:
   errcheck:
     check-blank: false
-    ignore: fmt:.*,[rR]ead|[wW]rite|[cC]lose,io:Copy
   gocritic:
     disabled-checks:
       - commentFormatting
@@ -87,3 +86,6 @@ linters:
     - unconvert
     - unparam
     - unused
+issues:
+  max-issues-per-linter: 0
+  max-same-issues: 0

.release-please-manifest.json

@@ -1,3 +1,3 @@
 {
-  ".": "4.73.4"
+  ".": "4.74.0"
 }

CHANGELOG.md

@@ -5,6 +5,29 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [4.74.0](https://github.com/cloudquery/plugin-sdk/compare/v4.73.4...v4.74.0) (2025-03-07)
+
+
+### Features
+
+* Add description to time JSONschema ([#2083](https://github.com/cloudquery/plugin-sdk/issues/2083)) ([fc27b14](https://github.com/cloudquery/plugin-sdk/commit/fc27b14c801d44ffba458fc676a6e3f0d577dfec))
+* Add way to get Configtype time value for hashing ([#2077](https://github.com/cloudquery/plugin-sdk/issues/2077)) ([ed27292](https://github.com/cloudquery/plugin-sdk/commit/ed27292685e032027802410265e92e96fbfc375e))
+* Add WithNullableFieldTransformer to transformers.TransformWithStruct options ([#2084](https://github.com/cloudquery/plugin-sdk/issues/2084)) ([2175946](https://github.com/cloudquery/plugin-sdk/commit/217594694dfa253f1534aead73c3481978210a9d))
+
+
+### Bug Fixes
+
+* **deps:** Update aws-sdk-go-v2 monorepo ([#2074](https://github.com/cloudquery/plugin-sdk/issues/2074)) ([091e2c7](https://github.com/cloudquery/plugin-sdk/commit/091e2c7c028717a8dc91cf6440bd6307468f2fdc))
+* **deps:** Update aws-sdk-go-v2 monorepo ([#2080](https://github.com/cloudquery/plugin-sdk/issues/2080)) ([14ad9db](https://github.com/cloudquery/plugin-sdk/commit/14ad9db4509fdf38516b7140b519af040ea8f218))
+* **deps:** Update aws-sdk-go-v2 monorepo ([#2085](https://github.com/cloudquery/plugin-sdk/issues/2085)) ([3da5572](https://github.com/cloudquery/plugin-sdk/commit/3da55726a9264d8d74883d40886de122f0377e1c))
+* **deps:** Update module github.com/cloudquery/cloudquery-api-go to v1.13.6 ([#2089](https://github.com/cloudquery/plugin-sdk/issues/2089)) ([4faff6a](https://github.com/cloudquery/plugin-sdk/commit/4faff6a844959875d43a5ceb8e1d18ca9d35e3ce))
+* **deps:** Update module github.com/cloudquery/plugin-pb-go to v1.26.7 ([#2076](https://github.com/cloudquery/plugin-sdk/issues/2076)) ([dbdae2f](https://github.com/cloudquery/plugin-sdk/commit/dbdae2f4829cfd440e395dfaa9047e12f87d1fb2))
+* **deps:** Update module github.com/cloudquery/plugin-pb-go to v1.26.8 ([#2090](https://github.com/cloudquery/plugin-sdk/issues/2090)) ([c4c9cd6](https://github.com/cloudquery/plugin-sdk/commit/c4c9cd60e35cd50e6567afdfc9901381bb293dd7))
+* **deps:** Update module github.com/goccy/go-json to v0.10.5 ([#2086](https://github.com/cloudquery/plugin-sdk/issues/2086)) ([b238237](https://github.com/cloudquery/plugin-sdk/commit/b23823758f6a0d74a7ab9a96c3dfd5bdc09dce40))
+* **deps:** Update module github.com/google/go-cmp to v0.7.0 ([#2088](https://github.com/cloudquery/plugin-sdk/issues/2088)) ([1895ddf](https://github.com/cloudquery/plugin-sdk/commit/1895ddf6d5438df771a16f2ad33e14c9ee77cbd4))
+* **deps:** Update module google.golang.org/protobuf to v1.36.5 ([#2081](https://github.com/cloudquery/plugin-sdk/issues/2081)) ([833b19c](https://github.com/cloudquery/plugin-sdk/commit/833b19c406de76be59c19bb9c53695c675468325))
+* Ignore context cancelled errors. ([#2091](https://github.com/cloudquery/plugin-sdk/issues/2091)) ([bc50fd3](https://github.com/cloudquery/plugin-sdk/commit/bc50fd3d2be414edba8f8ad5bb7739a012840bf1))
+
 ## [4.73.4](https://github.com/cloudquery/plugin-sdk/compare/v4.73.3...v4.73.4) (2025-02-03)
 
 

configtype/time.go

@@ -2,6 +2,7 @@ package configtype
 
 import (
 	"encoding/json"
+	"errors"
 	"fmt"
 	"math"
 	"regexp"
@@ -15,9 +16,10 @@ import (
 // when a time type is required. We wrap the time.Time type so that
 // the spec can be extended in the future to support other types of times
 type Time struct {
-	input    string
-	time     time.Time
-	duration *timeDuration
+	input       string
+	time        time.Time
+	duration    *timeDuration
+	hashNowFunc func() time.Time
 }
 
 func ParseTime(s string) (Time, error) {
@@ -85,6 +87,19 @@ func (Time) JSONSchema() *jsonschema.Schema {
 		Type:    "string",
 		Pattern: timePattern,
 		Title:   "CloudQuery configtype.Time",
+		Description: "Allows for defining timestamps in both absolute(RFC3339) and relative formats. " +
+			"Absolute timestamp example: `2024-01-01T12:00:00+00:00`.\n" +
+			"Relative timestamps can take this format:\n" +
+			"- `now`\n" +
+			"- `x seconds [ago|from now]`\n" +
+			"- `x minutes [ago|from now]`\n" +
+			"- `x hours [ago|from now]`\n" +
+			"- `x days [ago|from now]`\n" +
+			"`until` field usage:\n" +
+			"- `until: now`\n" +
+			"- `until: 2 days ago`\n" +
+			"- `until: 10 months 3 days 4h20m from now`\n" +
+			"- `until: 2024-01-01T12:00:00+00:00`",
 	}
 }
 
@@ -130,6 +145,19 @@ func (t Time) String() string {
 	return t.input
 }
 
+func (t Time) Hash() (uint64, error) {
+	nowFunc := t.hashNowFunc
+	if nowFunc == nil {
+		nowFunc = time.Now
+	}
+	at := t.AsTime(nowFunc())
+	return uint64(at.UnixNano()), nil
+}
+
+func (t *Time) SetHashNowFunc(f func() time.Time) {
+	t.hashNowFunc = f
+}
+
 type timeDuration struct {
 	input string
 
@@ -185,13 +213,13 @@ func parseTimeDuration(s string) (timeDuration, error) {
 			inValue = false
 		case part == "ago":
 			if d.sign != 0 {
-				return timeDuration{}, fmt.Errorf("invalid duration format: more than one sign specifier")
+				return timeDuration{}, errors.New("invalid duration format: more than one sign specifier")
 			}
 
 			d.sign = -1
 		case part == "from":
 			if d.sign != 0 {
-				return timeDuration{}, fmt.Errorf("invalid duration format: more than one sign specifier")
+				return timeDuration{}, errors.New("invalid duration format: more than one sign specifier")
 			}
 
 			inSign = true

configtype/time_test.go

@@ -9,6 +9,7 @@ import (
 	"github.com/cloudquery/plugin-sdk/v4/configtype"
 	"github.com/cloudquery/plugin-sdk/v4/plugin"
 	"github.com/invopop/jsonschema"
+	"github.com/mitchellh/hashstructure/v2"
 	"github.com/stretchr/testify/require"
 )
 
@@ -151,3 +152,63 @@ func TestTime_JSONSchema(t *testing.T) {
 		})
 	}
 }
+
+func TestTime_Hashing(t *testing.T) {
+	hnf := func() time.Time { return time.Date(2000, 1, 1, 0, 0, 0, 0, time.UTC) }
+	cases := []struct {
+		a           configtype.Time
+		b           configtype.Time
+		hashNowFunc func() time.Time
+		equal       bool
+	}{
+		{
+			a:           func() configtype.Time { ct, _ := configtype.ParseTime("10m"); return ct }(),
+			b:           func() configtype.Time { ct, _ := configtype.ParseTime("10m"); return ct }(),
+			hashNowFunc: hnf,
+			equal:       true,
+		},
+		{
+			a:     func() configtype.Time { ct, _ := configtype.ParseTime("10m"); return ct }(),
+			b:     func() configtype.Time { ct, _ := configtype.ParseTime("10m"); return ct }(),
+			equal: false,
+		},
+		{
+			a:     func() configtype.Time { ct, _ := configtype.ParseTime("10m"); return ct }(),
+			b:     func() configtype.Time { ct, _ := configtype.ParseTime("1m"); return ct }(),
+			equal: false,
+		},
+		{
+			a:           func() configtype.Time { ct, _ := configtype.ParseTime("2021-09-01T00:00:00Z"); return ct }(),
+			b:           func() configtype.Time { ct, _ := configtype.ParseTime("2012-01-02T01:02:03Z"); return ct }(),
+			hashNowFunc: hnf,
+			equal:       false,
+		},
+		{
+			a:           func() configtype.Time { ct, _ := configtype.ParseTime("-50m30s"); return ct }(),
+			b:           func() configtype.Time { ct, _ := configtype.ParseTime("50 minutes 30 seconds ago"); return ct }(),
+			hashNowFunc: hnf,
+			equal:       true,
+		},
+		{
+			a:           func() configtype.Time { ct, _ := configtype.ParseTime("50m30s"); return ct }(),
+			b:           func() configtype.Time { ct, _ := configtype.ParseTime("50 minutes 30 seconds from now"); return ct }(),
+			hashNowFunc: hnf,
+			equal:       true,
+		},
+	}
+	for _, tc := range cases {
+		tc.a.SetHashNowFunc(tc.hashNowFunc)
+		hashA, err := hashstructure.Hash(tc.a, hashstructure.FormatV2, nil)
+		require.NoError(t, err)
+		time.Sleep(1 * time.Second)
+		tc.b.SetHashNowFunc(tc.hashNowFunc)
+		hashB, err := hashstructure.Hash(tc.b, hashstructure.FormatV2, nil)
+		require.NoError(t, err)
+
+		if tc.equal {
+			require.Equal(t, hashA, hashB)
+			continue
+		}
+		require.NotEqual(t, hashA, hashB)
+	}
+}

docs/markdown.go

@@ -39,7 +39,10 @@ func (g *Generator) renderTablesAsMarkdown(dir string) error {
 		return fmt.Errorf("failed to create file %v: %v", outputPath, err)
 	}
 	defer f.Close()
-	f.WriteString(content)
+	_, err = f.WriteString(content)
+	if err != nil {
+		return fmt.Errorf("failed to write content to file %v: %v", outputPath, err)
+	}
 	return nil
 }
 
@@ -76,8 +79,11 @@ func (g *Generator) renderTable(dir string, table *schema.Table) error {
 		return fmt.Errorf("failed to create file %v: %v", outputPath, err)
 	}
 	defer f.Close()
-	f.WriteString(content)
-	return f.Close()
+	_, err = f.WriteString(content)
+	if err != nil {
+		return fmt.Errorf("failed to write content to file %v: %v", outputPath, err)
+	}
+	return nil
 }
 
 func formatMarkdown(s string) string {

examples/simple_plugin/go.mod

@@ -4,40 +4,40 @@ go 1.22.7
 
 require (
 	github.com/apache/arrow-go/v18 v18.1.0
-	github.com/cloudquery/plugin-sdk/v4 v4.73.3
+	github.com/cloudquery/plugin-sdk/v4 v4.73.4
 	github.com/rs/zerolog v1.33.0
 )
 
 require (
 	github.com/adrg/xdg v0.5.3 // indirect
 	github.com/apache/arrow/go/v13 v13.0.0-20230731205701-112f94971882 // indirect
 	github.com/apapsch/go-jsonmerge/v2 v2.0.0 // indirect
-	github.com/aws/aws-sdk-go-v2 v1.34.0 // indirect
-	github.com/aws/aws-sdk-go-v2/config v1.29.2 // indirect
-	github.com/aws/aws-sdk-go-v2/credentials v1.17.55 // indirect
-	github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.25 // indirect
-	github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.29 // indirect
-	github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.29 // indirect
-	github.com/aws/aws-sdk-go-v2/internal/ini v1.8.2 // indirect
-	github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.2 // indirect
-	github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.10 // indirect
-	github.com/aws/aws-sdk-go-v2/service/licensemanager v1.29.13 // indirect
-	github.com/aws/aws-sdk-go-v2/service/marketplacemetering v1.25.12 // indirect
-	github.com/aws/aws-sdk-go-v2/service/sso v1.24.12 // indirect
-	github.com/aws/aws-sdk-go-v2/service/ssooidc v1.28.11 // indirect
-	github.com/aws/aws-sdk-go-v2/service/sts v1.33.10 // indirect
+	github.com/aws/aws-sdk-go-v2 v1.36.2 // indirect
+	github.com/aws/aws-sdk-go-v2/config v1.29.7 // indirect
+	github.com/aws/aws-sdk-go-v2/credentials v1.17.60 // indirect
+	github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.29 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.33 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.33 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/ini v1.8.3 // indirect
+	github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.3 // indirect
+	github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.14 // indirect
+	github.com/aws/aws-sdk-go-v2/service/licensemanager v1.29.18 // indirect
+	github.com/aws/aws-sdk-go-v2/service/marketplacemetering v1.25.16 // indirect
+	github.com/aws/aws-sdk-go-v2/service/sso v1.24.16 // indirect
+	github.com/aws/aws-sdk-go-v2/service/ssooidc v1.28.15 // indirect
+	github.com/aws/aws-sdk-go-v2/service/sts v1.33.15 // indirect
 	github.com/aws/smithy-go v1.22.2 // indirect
 	github.com/bahlo/generic-list-go v0.2.0 // indirect
 	github.com/buger/jsonparser v1.1.1 // indirect
 	github.com/cenkalti/backoff/v4 v4.3.0 // indirect
-	github.com/cloudquery/cloudquery-api-go v1.13.5 // indirect
-	github.com/cloudquery/plugin-pb-go v1.26.6 // indirect
+	github.com/cloudquery/cloudquery-api-go v1.13.6 // indirect
+	github.com/cloudquery/plugin-pb-go v1.26.8 // indirect
 	github.com/cloudquery/plugin-sdk/v2 v2.7.0 // indirect
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/ghodss/yaml v1.0.0 // indirect
 	github.com/go-logr/logr v1.4.2 // indirect
 	github.com/go-logr/stdr v1.2.2 // indirect
-	github.com/goccy/go-json v0.10.4 // indirect
+	github.com/goccy/go-json v0.10.5 // indirect
 	github.com/google/flatbuffers v24.12.23+incompatible // indirect
 	github.com/google/uuid v1.6.0 // indirect
 	github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.2.0 // indirect
@@ -86,7 +86,7 @@ require (
 	google.golang.org/genproto/googleapis/api v0.0.0-20250115164207-1a7da9e5054f // indirect
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20250115164207-1a7da9e5054f // indirect
 	google.golang.org/grpc v1.70.0 // indirect
-	google.golang.org/protobuf v1.36.4 // indirect
+	google.golang.org/protobuf v1.36.5 // indirect
 	gopkg.in/yaml.v2 v2.4.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )