Skip to content

Commit 05fb374

Browse files
michaelmcneesMichael McNeesclaude
authored
feat(connector): enterprise and cloud connector batch (batch 3) (#149)
* feat(connector): Stripe, Okta, Shopify, Mailchimp, OneDrive, QuickBooks, and RabbitMQ connectors Adds 17 new connector actions across 7 services: - stripe/create_charge, stripe/create_customer, stripe/create_refund - okta/list_users, okta/create_user - shopify/list_orders, shopify/list_products, shopify/create_order - mailchimp/list_members, mailchimp/add_member - onedrive/upload, sharepoint/list_items - quickbooks/create_invoice, quickbooks/list_invoices - rabbitmq/publish, rabbitmq/consume Also adds parseJSONBody shared helper to tools.go and github.com/rabbitmq/amqp091-go v1.11.0 as the AMQP protocol client. Closes #94, #108, #109, #111, #112, #114, #115 Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * fix(connector): address Codex review comments on OneDrive and RabbitMQ - OneDrive: remove url.PathEscape on filePath to preserve literal "/" separators in Graph API path templates (escaping produced %2F which resolved to a file literally named "documents%2Fhello.txt") - RabbitMQ: ack each message inside the consume loop when auto_ack=false so messages are not requeued when the channel closes on return Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * fix(connector): address CodeRabbit review on saas-connector batch - rabbitmq: validate params before dialing (exchange/routing_key/body for publish, queue for consume) so invalid requests fail without a connection - rabbitmq: use amqp.DialConfig with net.Dialer.DialContext so the dial respects context cancellation - rabbitmq: default auto_ack=false (at-least-once); true opts into at-most-once - onedrive: add escapePath helper to encode individual path segments without escaping "/" separators, so nested folders work with Graph path addressing - onedrive_test: assert request URL path to catch future slash-escaping regressions - quickbooks: reject where/order_by values that contain structural keywords (maxresults, startposition, orderby) to prevent clause injection - shopify: extract shopifyAPIURL package-level helper, removing three identical apiURL methods - go.mod: go mod tidy promotes amqp091-go from indirect to direct Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * fix: exempt /metrics, /healthz, /readyz from auth; numeric UID in Dockerfile - server: register /metrics, /healthz, and /readyz on a top-level mux so Kubernetes probes and Prometheus scrapers bypass API key auth entirely. All other routes fall through to the auth/rate-limit-wrapped apiMux. - Dockerfile: create the mantle user with explicit -u 10001 -g 10001 and switch to USER 10001:10001 so kubelet can verify runAsNonRoot: true without a numeric runAsUser override in the Helm chart. Closes #139 Closes #137 Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * feat(connector): enterprise and cloud connector batch (batch 3) Adds 39 new connector actions across 17 integrations: Microsoft: entra/list_users, entra/create_user, entra/add_group_member, teams/send_message, teams/send_adaptive_card CRM/Ticketing: hubspot/create_contact, hubspot/search_contacts, jira/create_issue, jira/search_issues, salesforce/query, salesforce/create_record Google: drive/upload, drive/list_files, sheets/read_range, sheets/append_rows, gcp/publish, gcp/invoke_cloud_run GitHub: github/dispatch_workflow (added to existing file) Cloud: azure/blob_upload, azure/blob_download, azure/invoke_function, databricks/execute_sql, databricks/submit_job, bigquery/query, bigquery/insert_rows AWS: aws/invoke_lambda, aws/send_sqs, aws/publish_sns Messaging: kafka/produce, kafka/consume Database: snowflake/query, mysql/query, mysql/execute, mssql/query, mssql/execute, redshift/query Kubernetes: k8s/apply, k8s/create_job, k8s/get_pod_status All connectors follow the established pattern: baseURL injection for testing, dual-shape credential extraction, LimitReader on HTTP responses, 170 unit tests via httptest.NewServer with no external dependencies. Closes #113 Closes #97 Closes #107 Closes #106 Closes #93 Closes #87 Closes #86 Closes #85 Closes #88 Closes #92 Closes #91 Closes #89 Closes #90 Closes #78 Closes #79 Closes #82 Closes #105 Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * fix(connectors): address Copilot and Gosec review feedback Gosec (unblocks CI): - kubernetes.go: change //nolint:gosec → // #nosec G402 for TLS InsecureSkipVerify so gosec native suppression is recognized Copilot feedback applied: - teams.go: drain response body via io.LimitReader (bounded discard) - entra.go: same bounded discard for add_group_member response - kubernetes.go: add k8sPlural() to handle irregular pluralization (Ingress→ingresses, NetworkPolicy→networkpolicies); handle io.ReadAll error when reading server-side apply response - kubernetes_test.go: replace recursive containsStr with strings.Contains - kafka.go: remove 'partition' from KafkaProduceConnector docstring (param is not implemented) - bigquery.go: handle fmt.Sscanf error in parseIntString - mysql.go: use mysqldrv.Config.FormatDSN() for safe DSN encoding (handles passwords with '@', ':', '/' characters); omit last_insert_id from MSSQL execute result when driver returns error (SQL Server does not support LastInsertId) - snowflake.go: remove duplicate blank import (named import already registers the driver via init()) - aws.go, provider_bedrock.go: add #nosec G115 for safe int32 narrowing Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * fix(connector): address CodeRabbit feedback on connector-batch-3 - azure/invoke_function: error on non-2xx responses; url.QueryEscape function key - gcp/invoke_cloud_run: error on non-2xx responses - github/dispatch_workflow: url.PathEscape workflowID in path - drive/upload: use multipart.NewWriter for random boundary (prevents boundary collision) - k8s: url.PathEscape namespace/name in resource paths and get_pod_status - salesforce: url.PathEscape objectType in create_record path Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * feat(connector): BigQuery pagination/row typing + SQL bound parameters BigQuery: - Poll until jobComplete with context-bounded retry (500ms interval, configurable for tests) - Paginate through pageToken until max_rows satisfied - Return []map[string]any rows keyed by schema field names (was [][]string positional) - NULL values → nil, RECORD types → nested map, REPEATED fields → slice - bqParseValue recursively handles nested RECORD and REPEATED+RECORD combinations MySQL, MSSQL, Redshift, Snowflake: - Accept optional args: []any for parameterized query/execute - MySQL/MSSQL use ? placeholders; Redshift uses $1/$2; Snowflake uses ? - Passes args... to QueryContext/ExecContext — driver handles escaping Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> * fix(connectors): address CodeRabbit round-2 review feedback - kubernetes: support cluster-scoped resources (empty namespace omits /namespaces/{ns}), add MinVersion TLS 1.2, propagate "default" namespace only in inherently-namespaced connectors (create_job, get_pod_status) - mysql: fix Redshift DSN to use pgx URL format so special chars in credentials are properly percent-encoded - snowflake: replace duplicated row-scanning loop with shared scanSQLRows helper - entra: read response body before status check in add_group_member so errors include the API's error message - bedrock: add explicit math.MaxInt32 bounds check before int32 narrowing cast and remove #nosec suppression Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> --------- Co-authored-by: Michael McNees <mmcnees@Michaels-MacBook-Pro.local> Co-authored-by: Claude Sonnet 4.6 <noreply@anthropic.com>
1 parent 52d3860 commit 05fb374

40 files changed

Lines changed: 6912 additions & 71 deletions

‎go.work‎

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,3 @@
1-
go 1.25.0
2-
3-
toolchain go1.25.0
1+
go 1.25.7
42

53
use ./packages/engine

‎go.work.sum‎

Lines changed: 4 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
cloud.google.com/go v0.121.0 h1:pgfwva8nGw7vivjZiRfrmglGWiCJBP+0OmDpenG/Fwg=
12
cloud.google.com/go/accessapproval v1.8.6 h1:UkmDPCKvj24bkGVrvgJPcgSDkmIPw/bAmOiDb9avOiE=
23
cloud.google.com/go/accessapproval v1.8.6/go.mod h1:FfmTs7Emex5UvfnnpMkhuNkRCP85URnBFt5ClLxhZaQ=
34
cloud.google.com/go/accesscontextmanager v1.9.6 h1:2LnncRqfYB8NEdh9+FeYxAt9POTW/0zVboktnRlO11w=
@@ -226,8 +227,6 @@ cloud.google.com/go/websecurityscanner v1.7.6 h1:cIPKJKZA3l7D8DfL4nxce8HGOWXBw3W
226227
cloud.google.com/go/websecurityscanner v1.7.6/go.mod h1:ucaaTO5JESFn5f2pjdX01wGbQ8D6h79KHrmO2uGZeiY=
227228
cloud.google.com/go/workflows v1.14.2 h1:phBz5TOAES0YGogxZ6Q7ISSudaf618lRhE3euzBpE9U=
228229
cloud.google.com/go/workflows v1.14.2/go.mod h1:5nqKjMD+MsJs41sJhdVrETgvD5cOK3hUcAs8ygqYvXQ=
229-
filippo.io/edwards25519 v1.2.0 h1:crnVqOiS4jqYleHd9vaKZ+HKtHfllngJIiOpNpoJsjo=
230-
filippo.io/edwards25519 v1.2.0/go.mod h1:xzAOLCNug/yB62zG1bQ8uziwrIqIuxhctzJT18Q77mc=
231230
github.com/ClickHouse/ch-go v0.71.0 h1:bUdZ/EZj/LcVHsMqaRUP2holqygrPWQKeMjc6nZoyRM=
232231
github.com/ClickHouse/ch-go v0.71.0/go.mod h1:NwbNc+7jaqfY58dmdDUbG4Jl22vThgx1cYjBw0vtgXw=
233232
github.com/ClickHouse/clickhouse-go/v2 v2.43.0 h1:fUR05TrF1GyvLDa/mAQjkx7KbgwdLRffs2n9O3WobtE=
@@ -238,15 +237,14 @@ github.com/alecthomas/kingpin/v2 v2.4.0 h1:f48lwail6p8zpO1bC4TxtqACaGqHYA22qkHjH
238237
github.com/alecthomas/kingpin/v2 v2.4.0/go.mod h1:0gyi0zQnjuFk8xrkNKamJoyUo382HRL7ATRpFZCw6tE=
239238
github.com/alecthomas/units v0.0.0-20211218093645-b94a6e3cc137 h1:s6gZFSlWYmbqAuRjVTiNNhvNRfY2Wxp9nhfyel4rklc=
240239
github.com/alecthomas/units v0.0.0-20211218093645-b94a6e3cc137/go.mod h1:OMCwj8VM1Kc9e19TLln2VL61YJF0x1XFtfdL4JdbSyE=
241-
github.com/andybalholm/brotli v1.2.0 h1:ukwgCxwYrmACq68yiUqwIWnGY0cTPox/M94sVwToPjQ=
242-
github.com/andybalholm/brotli v1.2.0/go.mod h1:rzTDkvFWvIrjDXZHkuS16NPggd91W3kUSvPlQ1pLaKY=
243240
github.com/antihax/optional v1.0.0 h1:xK2lYat7ZLaVVcIuj82J8kIro4V6kDe0AUDFboUCwcg=
244241
github.com/antihax/optional v1.0.0/go.mod h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kdvxnR2qWY=
245242
github.com/coder/websocket v1.8.14 h1:9L0p0iKiNOibykf283eHkKUHHrpG7f65OE3BhhO7v9g=
246243
github.com/coder/websocket v1.8.14/go.mod h1:NX3SzP+inril6yawo5CQXx8+fk145lPDC6pumgx0mVg=
247244
github.com/containerd/typeurl/v2 v2.2.0 h1:6NBDbQzr7I5LHgp34xAXYF5DOTQDn05X58lsPEmzLso=
248245
github.com/containerd/typeurl/v2 v2.2.0/go.mod h1:8XOOxnyatxSWuG8OfsZXVnAF4iZfedjS/8UHSPJnX4g=
249246
github.com/cpuguy83/go-md2man/v2 v2.0.6 h1:XJtiaUW6dEEqVuZiMTn1ldk455QWwEIsMIJlo5vtkx0=
247+
github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM=
250248
github.com/elastic/go-sysinfo v1.15.4 h1:A3zQcunCxik14MgXu39cXFXcIw2sFXZ0zL886eyiv1Q=
251249
github.com/elastic/go-sysinfo v1.15.4/go.mod h1:ZBVXmqS368dOn/jvijV/zHLfakWTYHBZPk3G244lHrU=
252250
github.com/elastic/go-windows v1.0.2 h1:yoLLsAsV5cfg9FLhZ9EXZ2n2sQFKeDYrHenkcivY4vI=
@@ -262,12 +260,9 @@ github.com/go-sql-driver/mysql v1.9.3 h1:U/N249h2WzJ3Ukj8SowVFjdtZKfu9vlLZxjPXV1
262260
github.com/go-sql-driver/mysql v1.9.3/go.mod h1:qn46aNg1333BRMNU69Lq93t8du/dwxI64Gl8i5p1WMU=
263261
github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q=
264262
github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q=
263+
github.com/golang-jwt/jwt v3.2.1+incompatible h1:73Z+4BJcrTC+KczS6WvTPvRGOp1WmfEP4Q1lOd9Z/+c=
265264
github.com/golang-jwt/jwt/v4 v4.5.2 h1:YtQM7lnr8iZ+j5q71MGKkNw9Mn7AjHM68uc9g5fXeUI=
266265
github.com/golang-jwt/jwt/v4 v4.5.2/go.mod h1:m21LjoU+eqJr34lmDMbreY2eSTRJ1cv77w39/MY0Ch0=
267-
github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 h1:au07oEsX2xN0ktxqI+Sida1w446QrXBRJ0nee3SNZlA=
268-
github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0=
269-
github.com/golang-sql/sqlexp v0.1.0 h1:ZCD6MBpcuOVfGVqsEmY5/4FtYiKz6tSyUv9LPEDei6A=
270-
github.com/golang-sql/sqlexp v0.1.0/go.mod h1:J4ad9Vo8ZCWQ2GMrC4UCQy1JpCbwU9m3EOqtpKwwwHI=
271266
github.com/golang/glog v1.2.5 h1:DrW6hGnjIhtvhOIiAKT6Psh/Kd/ldepEa81DKeiRJ5I=
272267
github.com/golang/glog v1.2.5/go.mod h1:6AhwSGph0fcJtXVM/PEHPqZlFeoLxhs7/t5UDAwmO+w=
273268
github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da h1:oI5xCqsCo564l8iNU+DwB5epxmsaqB+rhGL0m5jtYqE=
@@ -310,6 +305,7 @@ github.com/paulmach/orb v0.12.0 h1:z+zOwjmG3MyEEqzv92UN49Lg1JFYx0L9GpGKNVDKk1s=
310305
github.com/paulmach/orb v0.12.0/go.mod h1:5mULz1xQfs3bmQm63QEJA6lNGujuRafwA5S/EnuLaLU=
311306
github.com/pierrec/lz4/v4 v4.1.25 h1:kocOqRffaIbU5djlIBr7Wh+cx82C0vtFb0fOurZHqD0=
312307
github.com/pierrec/lz4/v4 v4.1.25/go.mod h1:EoQMVJgeeEOMsCqCzqFm2O0cJvljX2nGZjcRIPL34O4=
308+
github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 h1:Jamvg5psRIccs7FGNTlIRMkT8wgtp5eCXdBlqhYGL6U=
313309
github.com/rogpeppe/fastuuid v1.2.0 h1:Ppwyp6VYCF1nvBTXL3trRso7mXMlRrw9ooo375wvi2s=
314310
github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ=
315311
github.com/russross/blackfriday v1.6.0 h1:KqfZb0pUVN2lYqZUYRddxF4OR8ZMURnJIG5Y3VRLtww=
@@ -319,8 +315,6 @@ github.com/santhosh-tekuri/jsonschema/v5 v5.3.1 h1:lZUw3E0/J3roVtGQ+SCrUrg3ON6Ng
319315
github.com/santhosh-tekuri/jsonschema/v5 v5.3.1/go.mod h1:uToXkOrWAZ6/Oc07xWQrPOhJotwFIyu2bBVN41fcDUY=
320316
github.com/segmentio/asm v1.2.1 h1:DTNbBqs57ioxAD4PrArqftgypG4/qNpXoJx8TVXxPR0=
321317
github.com/segmentio/asm v1.2.1/go.mod h1:BqMnlJP91P8d+4ibuonYZw9mfnzI9HfxselHZr5aAcs=
322-
github.com/shopspring/decimal v1.4.0 h1:bxl37RwXBklmTi0C79JfXCEBD1cqqHt0bbgBAGFp81k=
323-
github.com/shopspring/decimal v1.4.0/go.mod h1:gawqmDU56v4yIKSwfBSFip1HdCCXN8/+DMd9qYNcwME=
324318
github.com/shurcooL/sanitized_anchor_name v1.0.0/go.mod h1:1NzhyTcUVG4SuEtjjoZeVRXNmyL/1OwPU0+IJeTBvfc=
325319
github.com/spiffe/go-spiffe/v2 v2.6.0 h1:l+DolpxNWYgruGQVV0xsfeya3CsC7m8iBzDnMpsbLuo=
326320
github.com/spiffe/go-spiffe/v2 v2.6.0/go.mod h1:gm2SeUoMZEtpnzPNs2Csc0D/gX33k1xIx7lEzqblHEs=
@@ -329,18 +323,12 @@ github.com/tursodatabase/libsql-client-go v0.0.0-20251219100830-236aa1ff8acc/go.
329323
github.com/urfave/cli/v2 v2.3.0/go.mod h1:LJmUH05zAU44vOAcrfzZQKsZbVcdbOG8rtL3/XcUArI=
330324
github.com/vertica/vertica-sql-go v1.3.5 h1:IrfH2WIgzZ45yDHyjVFrXU2LuKNIjF5Nwi90a6cfgUI=
331325
github.com/vertica/vertica-sql-go v1.3.5/go.mod h1:jnn2GFuv+O2Jcjktb7zyc4Utlbu9YVqpHH/lx63+1M4=
332-
github.com/xdg-go/scram v1.2.0 h1:bYKF2AEwG5rqd1BumT4gAnvwU/M9nBp2pTSxeZw7Wvs=
333-
github.com/xdg-go/scram v1.2.0/go.mod h1:3dlrS0iBaWKYVt2ZfA4cj48umJZ+cAEbR6/SjLA88I8=
334-
github.com/xdg-go/stringprep v1.0.4 h1:XLI/Ng3O1Atzq0oBs3TWm+5ZVgkq2aqdlvP9JtoZ6c8=
335-
github.com/xdg-go/stringprep v1.0.4/go.mod h1:mPGuuIYwz7CmR2bT9j4GbQqutWS1zV24gijq1dTyGkM=
336326
github.com/xhit/go-str2duration/v2 v2.1.0 h1:lxklc02Drh6ynqX+DdPyp5pCKLUQpRT8bp8Ydu2Bstc=
337327
github.com/xhit/go-str2duration/v2 v2.1.0/go.mod h1:ohY8p+0f07DiV6Em5LKB0s2YpLtXVyJfNt1+BlmyAsU=
338328
github.com/ydb-platform/ydb-go-genproto v0.0.0-20260128080146-c4ed16b24b37 h1:kUXMT/fM/DpDT66WQgRUf3I8VOAWjypkMf52W5PChwA=
339329
github.com/ydb-platform/ydb-go-genproto v0.0.0-20260128080146-c4ed16b24b37/go.mod h1:Er+FePu1dNUieD+XTMDduGpQuCPssK5Q4BjF+IIXJ3I=
340330
github.com/ydb-platform/ydb-go-sdk/v3 v3.127.0 h1:OfHS9ZkZgCy6y/CJ9N8123DXrgaY2BPxWsQiQ8e3wC8=
341331
github.com/ydb-platform/ydb-go-sdk/v3 v3.127.0/go.mod h1:stS1mQYjbJvwwYaYzKyFY9eMiuVXWWXQA6T+SpOLg9c=
342-
github.com/youmark/pkcs8 v0.0.0-20240726163527-a2c0da244d78 h1:ilQV1hzziu+LLM3zUTJ0trRztfwgjqKnBWNtSRkbmwM=
343-
github.com/youmark/pkcs8 v0.0.0-20240726163527-a2c0da244d78/go.mod h1:aL8wCCfTfSfmXjznFBSZNN13rSJjlIOI1fUNAtF7rmI=
344332
github.com/yuin/goldmark v1.4.13 h1:fVcFKWvrslecOb/tg+Cc05dkeYx540o0FuFt3nUVDoE=
345333
github.com/ziutek/mymysql v1.5.4 h1:GB0qdRGsTwQSBVYuVShFBKaXSnSnYYC2d9knnE1LHFs=
346334
github.com/ziutek/mymysql v1.5.4/go.mod h1:LMSpPZ6DbqWFxNCHW77HeMg9I646SAhApZ/wKdgO/C0=

‎packages/engine/go.mod‎

Lines changed: 56 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -1,37 +1,44 @@
11
module github.com/dvflw/mantle
22

3-
go 1.25.0
3+
go 1.25.7
44

55
require (
66
cloud.google.com/go/secretmanager v1.16.0
77
github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.13.1
88
github.com/Azure/azure-sdk-for-go/sdk/security/keyvault/azsecrets v1.4.0
9-
github.com/aws/aws-sdk-go-v2 v1.41.4
9+
github.com/aws/aws-sdk-go-v2 v1.41.9
1010
github.com/aws/aws-sdk-go-v2/config v1.32.12
1111
github.com/aws/aws-sdk-go-v2/credentials v1.19.12
1212
github.com/aws/aws-sdk-go-v2/service/bedrockruntime v1.50.2
13+
github.com/aws/aws-sdk-go-v2/service/lambda v1.90.3
1314
github.com/aws/aws-sdk-go-v2/service/s3 v1.97.1
1415
github.com/aws/aws-sdk-go-v2/service/secretsmanager v1.41.4
16+
github.com/aws/aws-sdk-go-v2/service/sns v1.39.19
17+
github.com/aws/aws-sdk-go-v2/service/sqs v1.42.29
1518
github.com/coreos/go-oidc/v3 v3.17.0
1619
github.com/docker/docker v28.5.2+incompatible
1720
github.com/emersion/go-imap/v2 v2.0.0-beta.8
1821
github.com/go-git/go-git/v5 v5.18.0
19-
github.com/golang-jwt/jwt/v5 v5.3.0
22+
github.com/go-sql-driver/mysql v1.10.0
23+
github.com/golang-jwt/jwt/v5 v5.3.1
2024
github.com/google/cel-go v0.27.0
2125
github.com/googleapis/gax-go/v2 v2.15.0
2226
github.com/jackc/pgx/v5 v5.8.0
27+
github.com/microsoft/go-mssqldb v1.10.0
2328
github.com/pressly/goose/v3 v3.27.0
2429
github.com/prometheus/client_golang v1.23.2
2530
github.com/rabbitmq/amqp091-go v1.11.0
2631
github.com/redis/go-redis/v9 v9.20.0
32+
github.com/snowflakedb/gosnowflake v1.19.1
2733
github.com/spf13/cobra v1.10.2
2834
github.com/spf13/viper v1.21.0
2935
github.com/stretchr/testify v1.11.1
3036
github.com/testcontainers/testcontainers-go v0.41.0
3137
github.com/testcontainers/testcontainers-go/modules/postgres v0.41.0
38+
github.com/twmb/franz-go v1.21.2
3239
go.mongodb.org/mongo-driver/v2 v2.6.0
3340
golang.org/x/oauth2 v0.35.0
34-
golang.org/x/term v0.41.0
41+
golang.org/x/term v0.43.0
3542
golang.org/x/time v0.15.0
3643
gopkg.in/yaml.v3 v3.0.1
3744
)
@@ -43,18 +50,27 @@ require (
4350
cloud.google.com/go/compute/metadata v0.9.0 // indirect
4451
cloud.google.com/go/iam v1.5.2 // indirect
4552
dario.cat/mergo v1.0.2 // indirect
46-
github.com/Azure/azure-sdk-for-go/sdk/azcore v1.20.0 // indirect
47-
github.com/Azure/azure-sdk-for-go/sdk/internal v1.11.2 // indirect
53+
filippo.io/edwards25519 v1.2.0 // indirect
54+
github.com/99designs/go-keychain v0.0.0-20191008050251-8e49817e8af4 // indirect
55+
github.com/99designs/keyring v1.2.2 // indirect
56+
github.com/Azure/azure-sdk-for-go/sdk/azcore v1.21.1 // indirect
57+
github.com/Azure/azure-sdk-for-go/sdk/internal v1.12.0 // indirect
4858
github.com/Azure/azure-sdk-for-go/sdk/security/keyvault/internal v1.2.0 // indirect
59+
github.com/Azure/azure-sdk-for-go/sdk/storage/azblob v1.0.0 // indirect
4960
github.com/Azure/go-ansiterm v0.0.0-20250102033503-faa5f7b0171c // indirect
5061
github.com/AzureAD/microsoft-authentication-library-for-go v1.6.0 // indirect
62+
github.com/BurntSushi/toml v1.4.0 // indirect
5163
github.com/Microsoft/go-winio v0.6.2 // indirect
5264
github.com/ProtonMail/go-crypto v1.1.6 // indirect
65+
github.com/andybalholm/brotli v1.2.0 // indirect
5366
github.com/antlr4-go/antlr/v4 v4.13.1 // indirect
54-
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.7.7 // indirect
67+
github.com/apache/arrow-go/v18 v18.4.0 // indirect
68+
github.com/apache/thrift v0.22.0 // indirect
69+
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.7.11 // indirect
5570
github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.18.20 // indirect
56-
github.com/aws/aws-sdk-go-v2/internal/configsources v1.4.20 // indirect
57-
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.7.20 // indirect
71+
github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.16.15 // indirect
72+
github.com/aws/aws-sdk-go-v2/internal/configsources v1.4.25 // indirect
73+
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.7.25 // indirect
5874
github.com/aws/aws-sdk-go-v2/internal/ini v1.8.6 // indirect
5975
github.com/aws/aws-sdk-go-v2/internal/v4a v1.4.21 // indirect
6076
github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.13.7 // indirect
@@ -65,7 +81,7 @@ require (
6581
github.com/aws/aws-sdk-go-v2/service/sso v1.30.13 // indirect
6682
github.com/aws/aws-sdk-go-v2/service/ssooidc v1.35.17 // indirect
6783
github.com/aws/aws-sdk-go-v2/service/sts v1.41.9 // indirect
68-
github.com/aws/smithy-go v1.24.2 // indirect
84+
github.com/aws/smithy-go v1.26.0 // indirect
6985
github.com/beorn7/perks v1.0.1 // indirect
7086
github.com/cenkalti/backoff/v4 v4.3.0 // indirect
7187
github.com/cespare/xxhash/v2 v2.3.0 // indirect
@@ -76,39 +92,53 @@ require (
7692
github.com/containerd/platforms v0.2.1 // indirect
7793
github.com/cpuguy83/dockercfg v0.3.2 // indirect
7894
github.com/cyphar/filepath-securejoin v0.4.1 // indirect
79-
github.com/davecgh/go-spew v1.1.1 // indirect
95+
github.com/danieljoos/wincred v1.2.2 // indirect
96+
github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
8097
github.com/distribution/reference v0.6.0 // indirect
8198
github.com/docker/go-connections v0.6.0 // indirect
8299
github.com/docker/go-units v0.5.0 // indirect
100+
github.com/dvsekhvalnov/jose2go v1.7.0 // indirect
83101
github.com/ebitengine/purego v0.10.0 // indirect
84102
github.com/emersion/go-message v0.18.2 // indirect
85103
github.com/emersion/go-sasl v0.0.0-20241020182733-b788ff22d5a6 // indirect
86104
github.com/emirpasic/gods v1.18.1 // indirect
87105
github.com/felixge/httpsnoop v1.0.4 // indirect
88106
github.com/fsnotify/fsnotify v1.9.0 // indirect
107+
github.com/gabriel-vasile/mimetype v1.4.7 // indirect
89108
github.com/go-git/gcfg v1.5.1-0.20230307220236-3a3c6141e376 // indirect
90109
github.com/go-git/go-billy/v5 v5.8.0 // indirect
91110
github.com/go-jose/go-jose/v4 v4.1.3 // indirect
92111
github.com/go-logr/logr v1.4.3 // indirect
93112
github.com/go-logr/stdr v1.2.2 // indirect
94113
github.com/go-ole/go-ole v1.2.6 // indirect
95114
github.com/go-viper/mapstructure/v2 v2.4.0 // indirect
115+
github.com/goccy/go-json v0.10.5 // indirect
116+
github.com/godbus/dbus v0.0.0-20190726142602-4481cbc300e2 // indirect
117+
github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 // indirect
118+
github.com/golang-sql/sqlexp v0.1.0 // indirect
96119
github.com/golang/groupcache v0.0.0-20241129210726-2c02b8208cf8 // indirect
120+
github.com/golang/snappy v1.0.0 // indirect
121+
github.com/google/flatbuffers v25.2.10+incompatible // indirect
97122
github.com/google/s2a-go v0.1.9 // indirect
98123
github.com/google/uuid v1.6.0 // indirect
99124
github.com/googleapis/enterprise-certificate-proxy v0.3.6 // indirect
100125
github.com/grpc-ecosystem/grpc-gateway/v2 v2.28.0 // indirect
126+
github.com/gsterjov/go-libsecret v0.0.0-20161001094733-a6f4afe4910c // indirect
101127
github.com/inconshreveable/mousetrap v1.1.0 // indirect
102128
github.com/jackc/pgpassfile v1.0.0 // indirect
103129
github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 // indirect
104130
github.com/jackc/puddle/v2 v2.2.2 // indirect
105131
github.com/jbenet/go-context v0.0.0-20150711004518-d14ea06fba99 // indirect
106132
github.com/kevinburke/ssh_config v1.2.0 // indirect
107-
github.com/klauspost/compress v1.18.4 // indirect
133+
github.com/klauspost/asmfmt v1.3.2 // indirect
134+
github.com/klauspost/compress v1.18.6 // indirect
135+
github.com/klauspost/cpuid/v2 v2.2.11 // indirect
108136
github.com/kylelemons/godebug v1.1.0 // indirect
109137
github.com/lufia/plan9stats v0.0.0-20211012122336-39d0f177ccd0 // indirect
110138
github.com/magiconair/properties v1.8.10 // indirect
111139
github.com/mfridman/interpolate v0.0.2 // indirect
140+
github.com/minio/asm2plan9s v0.0.0-20200509001527-cdd76441f9d8 // indirect
141+
github.com/minio/c2goasm v0.0.0-20190812172519-36a3d3bbc4f3 // indirect
112142
github.com/moby/docker-image-spec v1.3.1 // indirect
113143
github.com/moby/go-archive v0.2.0 // indirect
114144
github.com/moby/patternmatcher v0.6.0 // indirect
@@ -117,14 +147,16 @@ require (
117147
github.com/moby/sys/userns v0.1.0 // indirect
118148
github.com/moby/term v0.5.2 // indirect
119149
github.com/morikuni/aec v1.0.0 // indirect
150+
github.com/mtibben/percent v0.2.1 // indirect
120151
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
121152
github.com/opencontainers/go-digest v1.0.0 // indirect
122153
github.com/opencontainers/image-spec v1.1.1 // indirect
123154
github.com/pelletier/go-toml/v2 v2.2.4 // indirect
155+
github.com/pierrec/lz4/v4 v4.1.26 // indirect
124156
github.com/pjbgf/sha1cd v0.3.2 // indirect
125157
github.com/pkg/browser v0.0.0-20240102092130-5ac0b6a4141c // indirect
126158
github.com/pkg/errors v0.9.1 // indirect
127-
github.com/pmezard/go-difflib v1.0.0 // indirect
159+
github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
128160
github.com/power-devops/perfstat v0.0.0-20240221224432-82ca36839d55 // indirect
129161
github.com/prometheus/client_model v0.6.2 // indirect
130162
github.com/prometheus/common v0.66.1 // indirect
@@ -133,6 +165,7 @@ require (
133165
github.com/sergi/go-diff v1.3.2-0.20230802210424-5b0b94c5c0d3 // indirect
134166
github.com/sethvargo/go-retry v0.3.0 // indirect
135167
github.com/shirou/gopsutil/v4 v4.26.2 // indirect
168+
github.com/shopspring/decimal v1.4.0 // indirect
136169
github.com/sirupsen/logrus v1.9.3 // indirect
137170
github.com/skeema/knownhosts v1.3.1 // indirect
138171
github.com/sourcegraph/conc v0.3.1-0.20240121214520-5f936abd7ae8 // indirect
@@ -142,12 +175,14 @@ require (
142175
github.com/subosito/gotenv v1.6.0 // indirect
143176
github.com/tklauser/go-sysconf v0.3.16 // indirect
144177
github.com/tklauser/numcpus v0.11.0 // indirect
178+
github.com/twmb/franz-go/pkg/kmsg v1.13.1 // indirect
145179
github.com/xanzy/ssh-agent v0.3.3 // indirect
146180
github.com/xdg-go/pbkdf2 v1.0.0 // indirect
147181
github.com/xdg-go/scram v1.2.0 // indirect
148182
github.com/xdg-go/stringprep v1.0.4 // indirect
149183
github.com/youmark/pkcs8 v0.0.0-20240726163527-a2c0da244d78 // indirect
150184
github.com/yusufpapurcu/wmi v1.2.4 // indirect
185+
github.com/zeebo/xxh3 v1.1.0 // indirect
151186
go.opentelemetry.io/auto/sdk v1.2.1 // indirect
152187
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.61.0 // indirect
153188
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.65.0 // indirect
@@ -158,12 +193,16 @@ require (
158193
go.uber.org/multierr v1.11.0 // indirect
159194
go.yaml.in/yaml/v2 v2.4.2 // indirect
160195
go.yaml.in/yaml/v3 v3.0.4 // indirect
161-
golang.org/x/crypto v0.49.0 // indirect
196+
golang.org/x/crypto v0.51.0 // indirect
162197
golang.org/x/exp v0.0.0-20260218203240-3dfff04db8fa // indirect
163-
golang.org/x/net v0.52.0 // indirect
198+
golang.org/x/mod v0.35.0 // indirect
199+
golang.org/x/net v0.53.0 // indirect
164200
golang.org/x/sync v0.20.0 // indirect
165-
golang.org/x/sys v0.42.0 // indirect
166-
golang.org/x/text v0.35.0 // indirect
201+
golang.org/x/sys v0.44.0 // indirect
202+
golang.org/x/telemetry v0.0.0-20260409153401-be6f6cb8b1fa // indirect
203+
golang.org/x/text v0.37.0 // indirect
204+
golang.org/x/tools v0.44.0 // indirect
205+
golang.org/x/xerrors v0.0.0-20240903120638-7835f813f4da // indirect
167206
google.golang.org/api v0.247.0 // indirect
168207
google.golang.org/genproto v0.0.0-20250603155806-513f23925822 // indirect
169208
google.golang.org/genproto/googleapis/api v0.0.0-20260209200024-4cfbd4190f57 // indirect

0 commit comments

Comments
 (0)