5d6ee65d26
Retain cloudevent trace fields ( #3080 )
...
Signed-off-by: yaron2 <schneider.yaron@live.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-08-14 13:40:14 -07:00
1708951cec
Add Cloud Event Protobuf to PubSub Content Types
...
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-03-02 14:37:18 -08:00
fbde4c706b
Merge branch 'master' into feature/pubsub-batching
2022-09-27 08:15:37 +05:30
ad5397ea25
Add time to CloudEvent automatically if not present ( #2123 )
...
Closes https://github.com/dapr/dapr/issues/5137
Signed-off-by: Yash Nisar <yashnisar@microsoft.com>
Signed-off-by: Yash Nisar <yashnisar@microsoft.com>
2022-09-26 14:44:57 -07:00
3f9c42c4b8
Kafka bulk publish ( #2059 )
...
* Contrib updates for Batch Subscribe
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* commit
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Commit pubsub
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Update structs
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Update Default Batch struct name
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Update Default Batch
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Update return type for BatchPublish
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Add docs
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Rename batch to bulk
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* snssqs renam batch to bulk
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Renaming Bulker to BulkMessager
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Renaming names as discussed
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Minor updates
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Remove ContentType from BulkPublishRequest
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Update error type
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Changes to bulk subscribe and error type
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Segregating Bulk Publisher and Bulk Subscriber and removing them as mandatory
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Event Type name correction
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Docs update as per comments
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* bulk publish implementation for kafka
Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
* Add ctx to BulkPublish.
Signed-off-by: Artur Souza <artursouza.ms@outlook.com>
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
Signed-off-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2022-09-15 13:17:17 -07:00
e87cd5e4cb
Go 1.19 support and linter fixes ( #1975 )
...
* Go 1.19 support and linter fixes
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
* Update workflows for Go1.19 and new linter version
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
* Remove unnecessary space in nolint directive
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
* disable additional linters which aren't used because of Go generics
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
* enable gosec linter again
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
* Update bindings/zeebe/command/publish_message_test.go
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
* Update bindings/output_binding.go
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
* Use prepared statement for mysql table creation
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
* Ping is not ping
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
* c'mon linter
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
* Fix MySQL gosec issue
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
* revert mysql to be fixed later
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-08-18 00:45:23 -07:00
5673b28b13
Add context in bindings interface
...
Signed-off-by: pigletfly <wangbing.adam@gmail.com>
2022-04-25 14:16:15 +08:00
bc0615652f
fix/typo: Change traceid to traceparent ( #1604 )
...
Signed-off-by: 1046102779 <seachen@tencent.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
2022-03-21 10:21:39 -07:00
e0b63062d5
Fix serialization issue with 64 bit data type ( #1597 )
...
* Unmarshal precise
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* nit: remove empty line
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* make modtidy-all
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Fix test
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Add new test for large numbers
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
Co-authored-by: Looong Dai <long.dai@intel.com>
2022-03-21 10:15:08 -07:00
c7adb917f3
update license to Apache v2.0 ( #1406 )
2022-01-04 19:53:31 -08:00
63d6329ae5
Support tracestate can be propagated in PubSub ( #1264 )
...
* support tracestate can be propagated in PubSub
* add trace state
Co-authored-by: Long Dai <long.dai@intel.com>
Co-authored-by: Ian Luo <ian.luo@gmail.com>
Co-authored-by: Simon Leet <31784195+CodeMonkeyLeet@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
2021-11-24 12:30:35 -08:00
988fed05ab
ci: standard linter config ( #1102 )
...
* ci: standard linter config
Signed-off-by: Long <long.dai@intel.com>
* Update utils.go
* fix pulsar issue
Signed-off-by: Long <long.dai@intel.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-09-21 15:21:59 -07:00
7d2bc9bbdf
fix: Dapr runtime panic when handle Pub/Sub (dapr#3281) ( #967 )
...
* fix: Dapr runtime panic when handle Pub/Sub (dapr#3281)
* use uuid to generate Id when Id is missing
* skip default value for id and content-type
Co-authored-by: Phil Kedy <phil.kedy@gmail.com>
Co-authored-by: beiwei.ly <beiwei.ly@alibaba-inc.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-07-08 10:54:36 -07:00
3cc0472a41
Add function to generate CloudEvent for raw subscribed events. ( #864 )
...
* Add function to generate CloudEvent for raw subscribed events.
* address code comments.
2021-05-10 10:39:26 -07:00
3ef025c604
change headers ( #679 )
2021-02-09 18:57:55 -08:00
859f0ae881
Handles binary data in cloud event. ( #674 )
2021-02-09 09:45:38 -08:00
bc0988af42
fix missing subject ( #640 )
2021-01-28 08:37:36 -08:00
27344d4e4c
Added binary data type detection ( #631 )
...
* Added binary data type detection
Added base64 encoding for binary data types
* Update utils.go
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-01-25 23:08:47 -08:00
01147e559d
Refactor and fix contenttype logic for pubsub. ( #602 )
...
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-01-14 14:28:52 -08:00
80e5f2ca52
fix data serialization in cloudevent ( #571 )
...
* fix data serialization in cloudevent
* fixes
2021-01-04 17:23:07 -08:00
a99b605db8
extend custom cloud event ( #570 )
2021-01-04 12:12:39 -08:00
b7584f670b
Add new cloudevents creation method ( #568 )
...
* add new cloudevents creation method
* linter
2020-12-30 19:10:47 -08:00
a7ff1b0aad
Replace content cloud event check, add settraceid ( #567 )
...
* replace content cloud event check, add settraceid
* change cloudeventenvelope to map
* change settraceid method
2020-12-30 17:06:32 -08:00
3e7f473b0c
Add method to check if payload is a cloudevent ( #566 )
...
* add method to check if payload is a cloudevent
* linter
* remove old test
2020-12-30 12:26:22 -08:00
e6dadfab6c
TTL in PubSub. ( #565 )
...
* TTL in PubSub.
* Handle message TTL only if component cannot handle it.
* Removig dead code for overflow check in pubsub expiration.
2020-12-29 14:28:52 -08:00
2f4be95b84
Respect content-type for PubSub data. ( #541 )
2020-11-25 17:20:20 -08:00
f647d9eedb
Upgrade golang lint to 1.31 ( #490 )
...
Upgrade golang lint to 1.31.0
https://github.com/dapr/components-contrib/issues/439
2020-10-12 12:54:15 -07:00
08d2538796
Corresponding changes for multi pubsub ( #434 )
...
* Corresponding changes for multi pubsub
* Fix quote
2020-08-14 11:05:51 -07:00
5892feca63
update Cloud Events to 1.0 ( #419 )
2020-07-23 17:13:26 -07:00
cf3ee2a46a
Add topic to cloud events envelope ( #396 )
...
Co-authored-by: ibrahim.dursun <ibrahim.dursun@gmail.com>
2020-07-22 08:48:32 -07:00
05e71ffdc2
data serialized object ( #391 )
...
Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-07-13 13:31:32 -07:00
dbc1a76dcf
lint fix
2020-07-13 09:24:51 -07:00
1589031af6
fiixes json array envelope parsing
2020-07-13 09:20:54 -07:00
68c5a5537c
changes cloudevent identification
2020-07-08 15:28:54 -07:00
f1f69bf3c8
fixes speeling mistakes in ccmments
2020-07-08 11:23:23 -07:00
43092998ab
uses provided CE as is, adds CE test
2020-07-08 06:50:10 -07:00
194ff4f914
fixes double envelop
2020-07-07 16:47:47 -07:00
4602757a45
extend envelop to include a subject field ( #249 )
...
* extend envelop to include a subject field
* fix envelop test
* update mod
* try fix mod again
2020-03-04 22:59:26 -08:00
4e436865fa
added cloud events content type ( #32 )
2019-10-14 12:52:39 -07:00
04bef3ac3f
Adding license header and updating to MIT license. ( #26 )
2019-10-09 10:58:08 -07:00
2b8dbd2b44
dapr name change ( #21 )
2019-10-02 13:21:22 -07:00
22fea6f43d
initial commit
2019-09-26 15:47:41 -07:00
Yaron Schneider
Bernd Verst
Mukundan Sundararajan
Yash Nisar
Bernd Verst
pigletfly
yellow chicks
Shubham Sharma
Dmitry Shmulevich
huazhongming
Long Dai
Ian Luo
Artur Souza
Yaron Schneider
Jigar
halspang
Leon Mai
Ally Parker
Mark Chmarny
Mark Chmarny
Aman Bhardwaj