ItalyPaleAle
|
445f2e4940
|
Receiving events
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
|
2023-01-19 21:36:20 +00:00 |
Deepanshu Agarwal
|
b2d8e6013b
|
Add bulkSubscribe request params to SubscribeRequest (#2405)
* Add bulkSubscribe configuration params
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Replace dapr/dapr package to run cert tests
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Change bulkSubscribe param types
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Update latest dapr/dapr fork
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Update correct dapr/dapr version
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* change BulkSubscribeRequest to Config
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Update dapr/dapr version for cert
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
* Update with latest dapr fork
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
|
2023-01-10 09:30:25 -08:00 |
|
Deepanshu Agarwal
|
f74b4d648d
|
Update EntryID to EntryId
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
|
2022-09-29 15:49:45 +05:30 |
|
deepanshuagarwal
|
bcd101abad
|
Keys rename (#2135)
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
|
2022-09-28 09:52:59 -07:00 |
Shubham Sharma
|
4f406a597f
|
Add bulk subscribe support to Azure Service Bus (#2100)
* Initial implementation
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* ✅
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Add tests
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Add comment
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Refactor messages.go and add tests
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Update message tests
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Refactor servicebus.go logic
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Refactor handleAsync
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Refactor ReceiveAndBlock
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Update binding
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Review comments addressed
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Lint
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Update metadata name
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Update activeMessagesChan logic for concurrency control
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Fix tests
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Update metadata name
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Use request metadata instead of component metadata
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Review comments addressed
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Fix merge issue with metadata
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Remove unused metadata key
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Fix merge issue with metadata
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
* Lint!!!
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
|
2022-09-23 10:49:06 -07:00 |
Mukundan Sundararajan
|
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 |
Jigar
|
9078f11985
|
Added ContentType to pubsub/binding/state request-response (#1376)
Signed-off-by: jigargandhi <jigarr.gandhi@gmail.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Looong Dai <long.dai@intel.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
|
2022-01-28 10:17:04 -08:00 |
Dmitry Shmulevich
|
c7adb917f3
|
update license to Apache v2.0 (#1406)
|
2022-01-04 19:53:31 -08:00 |
Long Dai
|
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 |
Yaron Schneider
|
3ef025c604
|
change headers (#679)
|
2021-02-09 18:57:55 -08:00 |
cvictory
|
87933ad4bc
|
The subscribeRequest and PublishRequest both need Metadata. (#543)
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
|
2020-11-26 23:15:54 -08:00 |
Joni Collinge
|
704cb42383
|
add pubsub request update (#530)
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
|
2020-11-25 17:12:16 -08:00 |
|
Yaron Schneider
|
653bdced85
|
add metadata to pubsub message (#477)
Co-authored-by: Young Bu Park <youngp@microsoft.com>
|
2020-09-24 12:04:42 -07:00 |
Leon Mai
|
08d2538796
|
Corresponding changes for multi pubsub (#434)
* Corresponding changes for multi pubsub
* Fix quote
|
2020-08-14 11:05:51 -07:00 |
Aman Bhardwaj
|
04bef3ac3f
|
Adding license header and updating to MIT license. (#26)
|
2019-10-09 10:58:08 -07:00 |
|
yaron2
|
22fea6f43d
|
initial commit
|
2019-09-26 15:47:41 -07:00 |