feat: implement GCP PubSub source #1

shubhamdixit863 · 2023-11-12T09:18:39Z

No description provided.

Signed-off-by: shubham <[email protected]>

.DS_Store

.github/workflows/ci.yaml

pkg/pubsubsource/pubsub_test.go

Makefile

README.md

pkg/pubsubsource/pubsub_test.go

test/e2e-api/redis.go

test/pubsub/pubsub_e2e_test.go

Co-authored-by: Keran Yang <[email protected]>

vigith

please make sure that the exported items are commented.

main.go

pkg/pubsubsource/pubsub.go

…ource-go

Signed-off-by: shubham <[email protected]>

Signed-off-by: shubham dixit <[email protected]>

main.go

README.md

main.go

pkg/pubsubsource/pubsub.go

pkg/pubsubsource/pubsub_test.go

test/pubsub/pubsub_e2e_test.go

…ource-go

pkg/pubsubsource/pubsub_test.go

Signed-off-by: shubham <[email protected]>

README.md

pkg/pubsubsource/examples/pubsub_source.yaml

pkg/pubsubsource/pubsub.go

pkg/pubsubsource/pubsub_test.go

Co-authored-by: Keran Yang <[email protected]>

Signed-off-by: shubham <[email protected]>

Signed-off-by: shubham dixit <[email protected]>

shubhamdixit863 added 23 commits November 5, 2023 12:25

Initial Commit

521b789

Gcp ssource

49b5e98

Pub sub integration test

21c85a7

Test cases fix

ae27f80

integration tests

5db643a

Added docker test

3f25cda

Fixed Integration tests

2879b94

e2e test cases fix

41ac781

fixed ci yaml for integ tests

c805cdf

fixed linting issue

db78113

fixed linting issue

d30072a

fixed linting issue

854636d

fixed linting issue

4d8bf67

fixed ci yaml build

07203f5

fixed ci yaml build

3ce40b7

fixed ci yaml build

dcaea81

fixed ci yaml build

43e6609

Added readme.md

6481b9a

Fixed readme md

25bd7d7

restructured yaml file

27446ac

restructured yaml file

eb43082

fixed e2e tests ,structuring and removed unrequired comments

e13bda9

Signed-off-by: shubham <[email protected]>

adde code comments

98c4381

KeranYang reviewed Nov 12, 2023

View reviewed changes

shubhamdixit863 and others added 2 commits November 12, 2023 22:07

Update README.md

a121da6

Co-authored-by: Keran Yang <[email protected]>

Update README.md

f1c60b8

Co-authored-by: Keran Yang <[email protected]>

vigith reviewed Nov 12, 2023

View reviewed changes

main.go Outdated Show resolved Hide resolved

pkg/pubsubsource/pubsub.go Outdated Show resolved Hide resolved

pkg/pubsubsource/pubsub.go Show resolved Hide resolved

pkg/pubsubsource/pubsub.go Show resolved Hide resolved

shubhamdixit863 added 3 commits November 13, 2023 10:55

fixes for make file

c92ab2f

Merge branch 'main' of ssh://github.com/shubhamdixit863/gcp-pub-sub-s…

bb77b21

…ource-go

readme.md fix ,test cases concurrency issue fixes

0d9702c

Signed-off-by: shubham <[email protected]>

shubhamdixit863 added 8 commits November 14, 2023 08:36

comments for pr addressed

12e0b13

go routine leaks ,test fixes

f6c7187

fixed go routine leaks in test

d4cee1b

Added metrics api for pending

103aabd

Linting issues fix

c8ab977

Unit test cases fix

4af8777

added buffered channel to receive message asynchronously

2c56e22

modified gitignore

01ab9d6

Signed-off-by: shubham dixit <[email protected]>

KeranYang reviewed Nov 15, 2023

View reviewed changes

shubhamdixit863 added 2 commits November 16, 2023 02:51

Added test for pending

dc086ff

Merge branch 'main' of ssh://github.com/shubhamdixit863/gcp-pub-sub-s…

aa47cfb

…ource-go

KeranYang reviewed Nov 15, 2023

View reviewed changes

pkg/pubsubsource/pubsub_test.go Outdated Show resolved Hide resolved

shubhamdixit863 added 2 commits November 16, 2023 13:02

addressed comments

4ce9b78

Signed-off-by: shubham <[email protected]>

sort imports

fc6fac5

KeranYang reviewed Nov 16, 2023

View reviewed changes

shubhamdixit863 and others added 5 commits November 16, 2023 20:34

Update README.md

fedd691

Co-authored-by: Keran Yang <[email protected]>

addressed comments

7f4d541

Merge branch 'main' of github.com:shubhamdixit863/gcp-pub-sub-source-go

e12e711

addressed comments

f13e07b

Signed-off-by: shubham <[email protected]>

addressed comments

1ad719e

KeranYang previously approved these changes Nov 16, 2023

View reviewed changes

shubhamdixit863 added 3 commits November 16, 2023 21:34

addressed comments

106830c

Signed-off-by: shubham dixit <[email protected]>

Merge branch 'main' of github.com:shubhamdixit863/gcp-pub-sub-source-go

54b87ea

Modified gitignore

5335022

shubhamdixit863 dismissed KeranYang’s stale review via 5335022 November 17, 2023 07:49

Modified gitignore

0ca26d9

KeranYang changed the title ~~GCP PubSub Source For Numaflow Pipeline~~ feat: implement GCP PubSub Source Nov 17, 2023

KeranYang changed the title ~~feat: implement GCP PubSub Source~~ feat: implement GCP PubSub source Nov 17, 2023

KeranYang approved these changes Nov 17, 2023

View reviewed changes

KeranYang merged commit f67d131 into numaproj-contrib:main Nov 17, 2023

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat: implement GCP PubSub source #1

feat: implement GCP PubSub source #1

shubhamdixit863 commented Nov 12, 2023

vigith left a comment •

edited

Loading

feat: implement GCP PubSub source #1

feat: implement GCP PubSub source #1

Conversation

shubhamdixit863 commented Nov 12, 2023

vigith left a comment • edited Loading

Choose a reason for hiding this comment

vigith left a comment •

edited

Loading