Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Use connector protocol v2 #1622

Merged
merged 27 commits into from
Jul 1, 2024
Merged

Use connector protocol v2 #1622

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
27 commits
Select commit Hold shift + click to select a range
07f8215
update standalone plugin to use connector protocol v2
lovromazgon May 28, 2024
473407f
update destination acceptance tests
lovromazgon May 28, 2024
6896424
update builtin plugin adapter
lovromazgon May 28, 2024
3fa19f6
move builtin/v1 to builtin
lovromazgon May 28, 2024
23a5fea
update connector package, still missing source tests
lovromazgon May 29, 2024
5bed7c2
source tests
lovromazgon May 29, 2024
1ed5f7e
update pkg/pipeline
lovromazgon Jun 14, 2024
a3cd351
fix pkg/orchestrator
lovromazgon Jun 18, 2024
9ee5c94
conduit compiles again
lovromazgon Jun 18, 2024
deadf56
generate typed mocks
lovromazgon Jun 19, 2024
ead8878
update protocol and sdk, rename cplugin to pconnector
lovromazgon Jun 19, 2024
0e2ea93
fix linter warning
lovromazgon Jun 19, 2024
3ef82e1
Merge branch 'main' into lovro/cpluginv2
lovromazgon Jun 19, 2024
a3c83ce
test getting stream without calling run
lovromazgon Jun 19, 2024
2ffbec2
make destination plugin mock nicer
lovromazgon Jun 19, 2024
3fe54db
remove redundant mock options
lovromazgon Jun 19, 2024
60d27d7
organize imports
lovromazgon Jun 19, 2024
457de2d
clone response in builtin plugins
lovromazgon Jun 20, 2024
76969a7
Merge branch 'main' into lovro/cpluginv2
lovromazgon Jun 20, 2024
52c6ac4
add builtin generator connector
lovromazgon Jun 20, 2024
5fedd71
include builtin connectors (only postgres missing now)
lovromazgon Jun 21, 2024
b708694
add comment about cloning requests and responses
lovromazgon Jun 21, 2024
ab34609
address review comments
lovromazgon Jun 24, 2024
9347b50
update postgres connector, address review comments
lovromazgon Jun 30, 2024
5b788af
update postgres, s3 and connector sdk
lovromazgon Jun 30, 2024
ea00db8
Merge branch 'main' into lovro/cpluginv2
lovromazgon Jun 30, 2024
9bce58b
Migrate to Conduit Commons utils (#1673)
lovromazgon Jul 1, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
68 changes: 34 additions & 34 deletions go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
module github.com/conduitio/conduit

go 1.22.2
go 1.22.4

require (
buf.build/gen/go/grpc-ecosystem/grpc-gateway/protocolbuffers/go v1.34.2-20240617172850-a48fcebcf8f1.2
Expand All @@ -9,14 +9,14 @@ require (
github.com/NYTimes/gziphandler v1.1.1
github.com/bufbuild/buf v1.34.0
github.com/conduitio/conduit-commons v0.2.0
github.com/conduitio/conduit-connector-file v0.6.0
github.com/conduitio/conduit-connector-generator v0.6.0
github.com/conduitio/conduit-connector-kafka v0.8.0
github.com/conduitio/conduit-connector-log v0.3.0
github.com/conduitio/conduit-connector-postgres v0.7.5
github.com/conduitio/conduit-connector-protocol v0.6.0
github.com/conduitio/conduit-connector-s3 v0.5.1
github.com/conduitio/conduit-connector-sdk v0.9.1
github.com/conduitio/conduit-connector-file v0.6.1-0.20240621111422-221c138201d3
github.com/conduitio/conduit-connector-generator v0.6.1-0.20240621111436-e9fa3464f7b2
github.com/conduitio/conduit-connector-kafka v0.8.1-0.20240621111431-87c01cf39a06
github.com/conduitio/conduit-connector-log v0.3.1-0.20240621111440-e2f0f04a35a4
github.com/conduitio/conduit-connector-postgres v0.7.6-0.20240630172132-84b5a6e6104f
github.com/conduitio/conduit-connector-protocol v0.6.1-0.20240619121958-1df466646d01
github.com/conduitio/conduit-connector-s3 v0.5.2-0.20240630172807-e278fde1fb46
github.com/conduitio/conduit-connector-sdk v0.9.2-0.20240628152134-4cafa91a4ded
github.com/conduitio/conduit-processor-sdk v0.1.2-0.20240516124003-442e4a3f0edd
github.com/conduitio/yaml/v3 v3.3.0
github.com/dgraph-io/badger/v4 v4.2.0
Expand Down Expand Up @@ -46,7 +46,6 @@ require (
github.com/stealthrocket/wazergo v0.19.1
github.com/tetratelabs/wazero v1.7.3
github.com/twmb/go-cache v1.2.1
go.uber.org/goleak v1.3.0
go.uber.org/mock v0.4.0
golang.org/x/exp v0.0.0-20240613232115-7f521ea00fb8
golang.org/x/tools v0.22.0
Expand Down Expand Up @@ -84,28 +83,28 @@ require (
github.com/alexkohler/prealloc v1.0.0 // indirect
github.com/alingse/asasalint v0.0.11 // indirect
github.com/antlr4-go/antlr/v4 v4.13.0 // indirect
github.com/apache/arrow/go/arrow v0.0.0-20211112161151-bc219186db40 // indirect
github.com/apache/thrift v0.19.0 // indirect
github.com/apache/arrow/go/arrow v0.0.0-20200730104253-651201b0f516 // indirect
github.com/apache/thrift v0.14.2 // indirect
github.com/ashanbrown/forbidigo v1.6.0 // indirect
github.com/ashanbrown/makezero v1.1.1 // indirect
github.com/aws/aws-sdk-go-v2 v1.24.0 // indirect
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.5.4 // indirect
github.com/aws/aws-sdk-go-v2/config v1.26.1 // indirect
github.com/aws/aws-sdk-go-v2/credentials v1.16.12 // indirect
github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.14.10 // indirect
github.com/aws/aws-sdk-go-v2/internal/configsources v1.2.9 // indirect
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.5.9 // indirect
github.com/aws/aws-sdk-go-v2/internal/ini v1.7.2 // indirect
github.com/aws/aws-sdk-go-v2/internal/v4a v1.2.9 // indirect
github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.10.4 // indirect
github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.2.9 // indirect
github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.10.9 // indirect
github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.16.9 // indirect
github.com/aws/aws-sdk-go-v2/service/s3 v1.47.5 // indirect
github.com/aws/aws-sdk-go-v2/service/sso v1.18.5 // indirect
github.com/aws/aws-sdk-go-v2/service/ssooidc v1.21.5 // indirect
github.com/aws/aws-sdk-go-v2/service/sts v1.26.5 // indirect
github.com/aws/smithy-go v1.19.0 // indirect
github.com/aws/aws-sdk-go-v2 v1.30.0 // indirect
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.2 // indirect
github.com/aws/aws-sdk-go-v2/config v1.27.22 // indirect
github.com/aws/aws-sdk-go-v2/credentials v1.17.22 // indirect
github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.8 // indirect
github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.12 // indirect
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.12 // indirect
github.com/aws/aws-sdk-go-v2/internal/ini v1.8.0 // indirect
github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.12 // indirect
github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.11.2 // indirect
github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.3.14 // indirect
github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.11.14 // indirect
github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.12 // indirect
github.com/aws/aws-sdk-go-v2/service/s3 v1.57.0 // indirect
github.com/aws/aws-sdk-go-v2/service/sso v1.22.0 // indirect
github.com/aws/aws-sdk-go-v2/service/ssooidc v1.26.0 // indirect
github.com/aws/aws-sdk-go-v2/service/sts v1.30.0 // indirect
github.com/aws/smithy-go v1.20.2 // indirect
github.com/beorn7/perks v1.0.1 // indirect
github.com/bkielbasa/cyclop v1.2.1 // indirect
github.com/blizzy78/varnamelen v0.8.0 // indirect
Expand Down Expand Up @@ -246,7 +245,7 @@ require (
github.com/nishanths/exhaustive v0.12.0 // indirect
github.com/nishanths/predeclared v0.2.2 // indirect
github.com/nunnatsa/ginkgolinter v0.16.2 // indirect
github.com/nxadm/tail v1.4.8 // indirect
github.com/nxadm/tail v1.4.11 // indirect
github.com/oklog/run v1.1.0 // indirect
github.com/olekukonko/tablewriter v0.0.5 // indirect
github.com/opencontainers/go-digest v1.0.0 // indirect
Expand Down Expand Up @@ -302,15 +301,15 @@ require (
github.com/timonwong/loggercheck v0.9.4 // indirect
github.com/tomarrell/wrapcheck/v2 v2.8.3 // indirect
github.com/tommy-muehle/go-mnd/v2 v2.5.1 // indirect
github.com/twmb/franz-go v1.16.1 // indirect
github.com/twmb/franz-go/pkg/kmsg v1.7.0 // indirect
github.com/twmb/franz-go v1.17.0 // indirect
github.com/twmb/franz-go/pkg/kmsg v1.8.0 // indirect
github.com/ultraware/funlen v0.1.0 // indirect
github.com/ultraware/whitespace v0.1.1 // indirect
github.com/uudashr/gocognit v1.1.2 // indirect
github.com/vbatts/tar-split v0.11.5 // indirect
github.com/xen0n/gosmopolitan v1.2.2 // indirect
github.com/xitongsys/parquet-go v1.6.2 // indirect
github.com/xitongsys/parquet-go-source v0.0.0-20230919034749-0b16411e6349 // indirect
github.com/xitongsys/parquet-go-source v0.0.0-20211228015320-b4f792c43cd0 // indirect
github.com/yagipy/maintidx v1.0.0 // indirect
github.com/yeya24/promlinter v0.3.0 // indirect
github.com/ykadowak/zerologlint v0.1.5 // indirect
Expand All @@ -325,6 +324,7 @@ require (
go.opentelemetry.io/otel/trace v1.24.0 // indirect
go.uber.org/atomic v1.11.0 // indirect
go.uber.org/automaxprocs v1.5.3 // indirect
go.uber.org/goleak v1.3.0 // indirect
go.uber.org/multierr v1.11.0 // indirect
go.uber.org/zap v1.27.0 // indirect
golang.org/x/crypto v0.24.0 // indirect
Expand Down
Loading