dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
3,297 Commits 54 Branches 155 Tags 80 MiB
Commit Graph

569 Commits

Author SHA1 Message Date
Bernd Verst 4720f6336f address changes required due to package updates 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-05-10 13:43:21 -07:00
Naah 615d4911bf
rocketmq consumer support some config item (#2811) 
Signed-off-by: Naah <nayan3480232@163.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-05-04 10:57:03 -07:00
KubeMQ 9e5e142db9
Update KubeMQ components (Fix panic and small production issues) (#2821) 
Signed-off-by: Lior Nabat <lior.nabat@kubemq.io>
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
Co-authored-by: Lior Nabat <lior.nabat@gmail.clom>
 2023-05-01 17:53:23 +00:00
Yaron Schneider a1bf2ea00a
Add Apache Pulsar e2e encryption (#2812) 
Signed-off-by: yaron2 <schneider.yaron@live.com>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
 2023-04-28 18:19:15 +00:00
Roberto Rojas 413eee94db
GCP PubSub - Certification Tests (#2689) 
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-04-24 22:23:34 +00:00
Yash Nisar 75239e051e
Add component metadata YAML for Azure Event Hubs pubsub (#2788) 
Signed-off-by: Yash Nisar <yashnisar@microsoft.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-04-24 10:04:43 -07:00
Bernd Verst a7ac906757
Fix Redis metadata parsing and reporting (#2803) 
Signed-off-by: Bernd Verst <github@bernd.dev>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Tiago Alves Macambira <tmacam@burocrata.org>
 2023-04-23 06:28:22 +00:00
Bernd Verst 1a751931f7
Add Service Bus Topics Pubsub Metadata (#2776) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-04-12 21:49:49 -07:00
Alessandro (Ale) Segala 5dad8a867c
Metadata parser: add support for built-in authentication profiles and metadata properties (#2760) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-04-12 00:04:34 +00:00
Bernd Verst 2b89d78a2d
Refactor Metadata Parsing of all PubSub Components (#2759) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-04-09 18:21:56 +00:00
spike 773b00dcb9
Create component metadata for pubsub.kafka (#2678) 
Signed-off-by: spike <hello@spike.wiki>
Co-authored-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2023-04-02 14:34:04 +00:00
Alessandro (Ale) Segala 3cd727a562
Crypto building block: core parts (#2690) 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-03-23 00:51:27 +00:00
Yaron Schneider 0e83c4adc5
Add priority queue support to rabbitmq pub/sub (#2680) 
Signed-off-by: yaron2 <schneider.yaron@live.com>
 2023-03-17 13:00:49 +00:00
Andre Bossard d87f4bb5a1
RabbitMQ: Support for external authentication with SASL (#2515) 
Signed-off-by: Andre Bossard <anbossar@microsoft.com>
Signed-off-by: Andre Bossard <abossard@users.noreply.github.com>
Co-authored-by: Andre Bossard <anbossar@microsoft.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2023-03-16 16:30:54 +00:00
ItalyPaleAle c20ab76972 Merge branch 'master' of https://github.com/dapr/components-contrib into merge-release-1.10-master 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-03-15 19:25:12 +00:00
MregXN 119fe8bd27
modify component metadata.type for pubsub.redis (#2670) 2023-03-15 08:39:31 -07:00
MregXN a31f385281
Create component metadata for pubsub.redis (#2660) 
Signed-off-by: MregXN <mregxn@gmail.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-03-14 17:12:35 -07:00
bingo1229 cfb4d7ecc9
Add partition support for pulsar (#2647) 
Signed-off-by: oops-oom <734819342@qq.com>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2023-03-14 16:37:31 +00:00
MregXN 08a101d16e
Create component metadata for pubsub.in-memory (#2664) 
Signed-off-by: MregXN <mregxn@gmail.com>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2023-03-13 11:24:33 -07:00
Bernd Verst b4cdc7a3ca
Restore Kafka CA Cert Auth without Password support, fix Jetstream pubsub issue (#2644) 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-03-07 22:47:35 -08:00
Josh van Leeuwen 569c6be070
PubSub: Wait Group and context catching (#2500) 
Signed-off-by: joshvanl <me@joshvanl.dev>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
 2023-03-03 17:44:26 +00:00
Bernd Verst 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
ItalyPaleAle 8cc74c7331 Completed the removal of the Azure SDK track 1 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-27 22:37:23 +00:00
ItalyPaleAle 2a5abb9a4f Remove deprecated components: pubsub.hazelcast, bindings.twitter 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-24 22:11:11 +00:00
Bernd Verst 4068531538
Merge branch 'master' into metadata 2023-02-22 16:46:43 -08:00
ItalyPaleAle 55b6a04805 Merge branch 'master' of https://github.com/dapr/components-contrib into newdeps 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-17 21:20:45 +00:00
ItalyPaleAle bc47aa3049 💄 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-17 00:59:25 +00:00
ItalyPaleAle f9cf54ca6f Merge branch 'master' of https://github.com/dapr/components-contrib into release-1.10 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-16 23:23:23 +00:00
Josh van Leeuwen d098e38d6a
Propagate context from caller to appropriate places in the code (#2474) 
* Propagates contexts to callers where appropriate.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Updates units tests with new func signature

Signed-off-by: joshvanl <me@joshvanl.dev>

* Fix linting errors

Signed-off-by: joshvanl <me@joshvanl.dev>

* Add atomic gate to alicloud rocketmq close channel.

Signed-off-by: joshvanl <me@joshvanl.dev>

* bindings/aws/kinesis use a separate ctx variable name

Signed-off-by: joshvanl <me@joshvanl.dev>

* binding/kafka: use atomic to prevent closing the channel twice

Signed-off-by: joshvanl <me@joshvanl.dev>

* bindings/mqtt3: use atomic bool to prevent close channel being closed multiple times

Signed-off-by: joshvanl <me@joshvanl.dev>

* bindings/mqtt3: use Background context for handle operations:w

Signed-off-by: joshvanl <me@joshvanl.dev>

* state/cocroachdb: add context to Ping()

Signed-off-by: joshvanl <me@joshvanl.dev>

* bindings/postgres: add comment explaining use of context.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Adds comment header to health/pinger.go

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/aws/snssqs: add waitgroup to wait for all go routines to finish
and block on Close(). Shuts down the subscription if there are no topic
handlers.

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/mqtt3: add atomic bool to prevent multiple channel closes. Add
wait group to block close on all goroutines to finish.

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/rabbitmq: fixes race conditions, uses atomic to prevent multiple
closes, add wait group to block close on all goroutines

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/redis: revert ctx passed when it could be cancelled. Add wait
group wait when closing.

Signed-off-by: joshvanl <me@joshvanl.dev>

* state/postges: pass context in init, and wait group on close.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Update all `Ping()` to `PingContext()` where possible.

Signed-off-by: joshvanl <me@joshvanl.dev>

* state/in-memory: add atomic bool to prevent closing channel multiple
times. Add wait group to block on close()

Signed-off-by: joshvanl <me@joshvanl.dev>

* state/mysql: don't use same ctx variable name

Signed-off-by: joshvanl <me@joshvanl.dev>

* Pass correct loop context to redis go routines

Signed-off-by: joshvanl <me@joshvanl.dev>

* Rename context when creating timeouts in state

Signed-off-by: joshvanl <me@joshvanl.dev>

* Remove state.Features() from requiring a context

Signed-off-by: joshvanl <me@joshvanl.dev>

* Revert wasm request handle Close func to be without context to
implement io.Closer interface. Add 5 second timeout. Add io.Closer
assertion in test.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Remove superfluous go lint vet directive

Signed-off-by: joshvanl <me@joshvanl.dev>

* Change Configuration Init function to take context

Signed-off-by: joshvanl <me@joshvanl.dev>

* Updates input binding interface to include a `Close() error` function. `Close`
blocks until all resources have been released and go routines have returned.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Change `Close() error` in input binding struct to `io.Closer` interface.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Update go.mod files to point to dapr/dapr PR https://github.com/dapr/dapr/pull/5831

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/redis: watch closeCh to shutdown worker instead of init context.

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/aws/snssqs + bindings/kubemq: ensure closeCh is caught so Close
correctly returns

Signed-off-by: joshvanl <me@joshvanl.dev>

* Close kubemq binding client on close. Ensure kafka consumer channel
cannot be closed more than once.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Tweaks

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Fixed cert tests

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* binding/mqtt3: add inline Background context instead of passing to
handleMessage

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/mqtt3: remove context from createSubscriberClientOptions

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/mqtt3: Remove `ResetConnection` func

Signed-off-by: joshvanl <me@joshvanl.dev>

* pubsub/kafka: Don't resubscribe if Subscribe is cancelled.

Signed-off-by: joshvanl <me@joshvanl.dev>

* binding/mqtt3: don't use context to control establishing connection

Signed-off-by: joshvanl <me@joshvanl.dev>

* bindings/mqtt3: Fix linting errors

Signed-off-by: joshvanl <me@joshvanl.dev>

---------

Signed-off-by: joshvanl <me@joshvanl.dev>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
 2023-02-16 14:18:35 -08:00
Bernd Verst b1c1304a86 Add and update component metadata definition files 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-02-13 17:09:09 -08:00
Alessandro (Ale) Segala 12acf8effe
[release-1.10] Azure Service Bus: fix goroutine "explosion" after recovering from failure and many other bugs (#2523) 
* Fixed context leak

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Finalize messages in background

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* More tweaks

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Moved a lot more code to the shared implementation package

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Fixed:
- Fixed: if number of messages received in bulk is greater than maxConcurrentHandlers, a deadlock happens
- Fixed: maxRetriableErrorsPerSec was not working

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Some refactorings

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Simplifications

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Avoid checking if topic/queue exists every time we send a message

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Ensuring locks are renewed for all 3 components

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Updated ASB SDK

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Improvements to closing

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Improvements to closing

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Changed context propagation

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Debug logs in cert tests

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Initial delay before renewing locks

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* That last change was actually unnecessary

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Tweaks

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* More tweaks

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* 💄

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

---------

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-02-13 09:23:03 -08:00
Bernd Verst 51d4a1f25c
Merge pull request #2386 from Sbolder/multiEnv_awsSqsSns 
fix bug multi environment on aws sqs/sns #2364
 2023-01-31 15:11:11 -08:00
Bernd Verst e7bcf0b785 Address linter issues 
Signed-off-by: Bernd Verst <github@bernd.dev>
 2023-01-31 13:41:24 -08:00
Yaron Schneider bc34fd20c0
Merge branch 'master' into multiEnv_awsSqsSns 2023-01-31 12:05:23 -08:00
ItalyPaleAle 7047ad533d More logging when Service Bus reconnects after publishing error 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-31 17:58:30 +00:00
ItalyPaleAle 8365df0f07 Fix flaky RabbitMQ certification tests 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-26 22:09:35 +00:00
Yaron Schneider 1dc20e6c69
Add schema support to apache pulsar (#2475) 
* add schema support to apache pulsar

Signed-off-by: yaron2 <schneider.yaron@live.com>

* linter and avro support

Signed-off-by: yaron2 <schneider.yaron@live.com>

* fix nit

Signed-off-by: yaron2 <schneider.yaron@live.com>

* fix go.mod

Signed-off-by: yaron2 <schneider.yaron@live.com>

* update cert test go.mod

Signed-off-by: yaron2 <schneider.yaron@live.com>

* update cert test metadata to latest

Signed-off-by: yaron2 <schneider.yaron@live.com>

* schema identifier refactor to handle edge case

Signed-off-by: yaron2 <schneider.yaron@live.com>

* fix shadow

Signed-off-by: yaron2 <schneider.yaron@live.com>

Signed-off-by: yaron2 <schneider.yaron@live.com>
 2023-01-26 13:10:58 -08:00
Bernd Verst 7f7362e620
Merge branch 'master' into update-deps 2023-01-26 09:28:29 -08:00
ItalyPaleAle fd5768032f 💄 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-26 01:24:47 +00:00
ItalyPaleAle cabfd3c570 Updated dependencies 
Most notable: `github.com/hashicorp/golang-lru` to `/v2`

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-26 01:10:48 +00:00
ItalyPaleAle dbf8426993 Updated mqtt binding too 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-25 23:47:30 +00:00
ItalyPaleAle 0148329c6c Added "unsubscribeOnClose" 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-25 20:22:11 +00:00
ItalyPaleAle 5a741da8b0 Some changes and fixes 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-25 19:33:20 +00:00
ItalyPaleAle 2421567997 Refactored pubsub.mqtt to better handle subscribptions and fix bugs 
- Uses a single connection for consumer and publisher
- Avoids reconnecting when the list of subscriptions changes
- Fixes re-subscribing after a connection is dropped

Fixes #2229
Fixes #2350

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-25 05:36:38 +00:00
ItalyPaleAle 232c8d813f Working on binding 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-21 19:28:00 +00:00
ItalyPaleAle 857a865e4e Moved implementation to shared package 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-21 01:14:04 +00:00
ItalyPaleAle ab7f9aa509 💄 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 23:20:58 +00:00
ItalyPaleAle a0251482c2 Create the storage container if it doesn't exist (to preserve compatibility with old SDK's behavior) 
Also fixes to tests

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 23:09:48 +00:00
ItalyPaleAle c76526c805 Fixed unit tests 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 21:34:55 +00:00
ItalyPaleAle 827c949c99 Address review comments 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 21:34:03 +00:00
ItalyPaleAle d97dac3b98 Fixes for Azure AD auth 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 20:37:59 +00:00
ItalyPaleAle c83919a49d Removed vendored conn library 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 19:34:01 +00:00
ItalyPaleAle 0649d5fae9 Updated tests 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 19:00:15 +00:00
ItalyPaleAle 462d7a95be Remove old file 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 18:10:40 +00:00
ItalyPaleAle 7153e75549 Do not.... crash twice 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 17:53:38 +00:00
ItalyPaleAle 2c98c8ef25 💄 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 17:50:05 +00:00
ItalyPaleAle fcfcbe9d87 Handle smooth upgrade from Track 1 SDKs 
(If you consider crashing Dapr on purpose "smooth" 🤣)

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 17:46:38 +00:00
ItalyPaleAle 8d679f06f9 Working on upgrading from track1 SDKs 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 16:59:27 +00:00
ItalyPaleAle 01e7d4167b Do not retry forever by default 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 04:24:35 +00:00
ItalyPaleAle 885fb5a2d4 Re-implemented BulkPublish 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 04:15:18 +00:00
ItalyPaleAle 9729c155c1 Retry failed messages + other fixes 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 00:47:24 +00:00
ItalyPaleAle c10173b29f Added entity management 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-20 00:18:22 +00:00
ItalyPaleAle 4c12f40534 WIP 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-19 22:33:50 +00:00
ItalyPaleAle 445f2e4940 Receiving events 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-19 21:36:20 +00:00
ItalyPaleAle 093669e8a8 WIP 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-19 20:12:00 +00:00
ItalyPaleAle 48dd1dabef Working on subscribing 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-19 01:27:48 +00:00
ItalyPaleAle 130afe5c1a Merge branch 'master' of https://github.com/dapr/components-contrib into eventhubs-track2 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-19 00:13:26 +00:00
ItalyPaleAle 0157bf0b72 WIP 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-19 00:12:10 +00:00
Shivam Kumar fd7dfe63ef
Fix mqtt pubsub: remove republishing when application is unhealthy (#2446) 
* Remove re-publishing in case of failures

Signed-off-by: shivam <shivamkm07@gmail.com>

* Remove maxRetriableErrorsPerSec field in metadata

Signed-off-by: shivam <shivamkm07@gmail.com>

* Remove backoffmaxretries from cert test

Signed-off-by: shivam <shivamkm07@gmail.com>

* go mod changes

Signed-off-by: shivam <shivamkm07@gmail.com>

* Testing higher value of timeout

Signed-off-by: shivam <shivamkm07@gmail.com>

* Testing even higher value of timeout

Signed-off-by: shivam <shivamkm07@gmail.com>

* Testing even higher value of timeout

Signed-off-by: shivam <shivamkm07@gmail.com>

* Resetting timeout

Signed-off-by: Shivam Kumar <shivamkm07@gmail.com>

* Removing mosquitto from pubsub conformance

Signed-off-by: Shivam Kumar <shivamkm07@gmail.com>

* Update pubsub/mqtt3/metadata.go

Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Bernd Verst <github@bernd.dev>

Signed-off-by: shivam <shivamkm07@gmail.com>
Signed-off-by: Shivam Kumar <shivamkm07@gmail.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
 2023-01-18 15:53:45 -08:00
Yaron Schneider c687bf0fd8
Merge branch 'master' into multiEnv_awsSqsSns 2023-01-16 09:15:19 -08:00
ItalyPaleAle 2afca71c2a Renamed mqtt components to mqtt3 
Fixes #2359

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-13 09:51:30 -08:00
Tomasz Pietrek 766b2df2fe
Fix heartbeat typo (#2430) 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
Co-authored-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
 2023-01-12 11:21:05 -08:00
ItalyPaleAle 9ef0bb9441 mapstructure fixes 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-10 20:41:50 +00:00
ItalyPaleAle eaa74d77d9 Metadata parsing 
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-10 18:51:50 +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
Joni Collinge 382f84f30c
Add support for Azure Service Bus sessions for topics (#2346) 
* WIP: ASB sessions

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* WIP: Support ASB sessions

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Add metadata

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* remove dead code

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* lint

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Add sessionIdleTimeoutInSec md

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Support blank session IDs

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* If require sessions and no session id, set blank

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* move session config to per subscription metadata

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* add some unit tests

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* lint

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* remove auto blank session id

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* go mod tidy

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* add basic cert test

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* update comment

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* remove dead code

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* remove dead code

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Update certification test

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Add comment

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Add cert test for roundrobin

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* go mod tidy

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Update readme

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Use struct for NewSubscription to simplify parameters

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Address feedback

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Address feedback

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Only async receive

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* isTruthy on map without check

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Use if not select for context check

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Feedback

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* lint

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

Signed-off-by: Joni Collinge <jonathancollinge@live.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
 2023-01-06 09:59:26 -08:00
Yaron Schneider ead15aee01
Merge branch 'master' into multiEnv_awsSqsSns 2023-01-05 05:54:04 -08:00
Bernd Verst 54b5f7471c
Merge branch 'master' into master 2023-01-04 15:10:10 -08:00
spike e61e170c7c
Use message's retain property to cover meta's (#2377) 
* Use message's retain property to cover meta's

Signed-off-by: spike <hello@spike.wiki>

* Add test cases for mqtt publish method

Signed-off-by: spike <hello@spike.wiki>

* Fix lint issues

Signed-off-by: spike <hello@spike.wiki>

* Fix lint issues

Signed-off-by: spike <hello@spike.wiki>

* Close channels individually

Signed-off-by: spike <hello@spike.wiki>

Signed-off-by: spike <hello@spike.wiki>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
 2023-01-04 15:05:25 -08:00
Bernd Verst d56057a649
Merge branch 'master' into master 2023-01-04 14:40:37 -08:00
Bernd Verst be093538f7
Merge branch 'master' into master 2023-01-04 14:35:59 -08:00
Tomasz Pietrek 97ad52c692 Make domain and prefix setup cleaner 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2023-01-04 10:48:32 +01:00
Tomasz Pietrek 94894c465b Add domain and apiPrefix for JetStream 
Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
 2023-01-04 09:18:35 +01:00
Bernd Verst ebe5511b32
Merge branch 'master' into multiEnv_awsSqsSns 2022-12-29 14:17:12 -08:00
TKTheTechie 5cd02e8c78 Update of amqp go library 
Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-28 23:28:25 -05:00
Bernd Verst 9845a76288 Merge remote-tracking branch 'upstream/master' into solacese/master 2022-12-28 17:39:08 -08:00
Bernd Verst e794fb9529
Merge branch 'master' into master 2022-12-28 16:42:34 -08:00
TKTheTechie 9c28641594 Fixing linting issues, conformance infrastructure 
* Fixing linting issues
* Adding infrastructure to .github/workflows
* Fixing conformance tests config to account for default anonymous config on the event broker

Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-23 08:58:41 -05:00
Davide Boldrin 27427f202b fix bug multi environment on aws sqs/sns #2364 
Signed-off-by: Davide Boldrin <davi1994@hotmail.it>

Signed-off-by: Davide Boldrin <d.boldrin@crif.com>
 2022-12-23 09:25:02 +01:00
TKTheTechie a5dfcb80fa Allowing anonymous connections 
Updating rule to allow an anonymous connection without credentials

Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-22 08:35:22 -05:00
TKTheTechie 57c2324670 Refactoring package names 
Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-22 08:35:22 -05:00
TKTheTechie 338bc03e9e Update amqp.go 
Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-22 08:35:22 -05:00
TKTheTechie d7f4933bbb Update amqp.go 
Support topic subscriptions

Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-22 08:35:21 -05:00
TKTheTechie 619c35693e Adding conformance tests 
Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-22 08:35:21 -05:00
TKTheTechie 2039a30de7 AMQP Plugin 
Initial cut of the AMQP 1.0 Plugin

Signed-off-by: TKTheTechie <thomas.kunnumpurath@solace.com>
 2022-12-22 08:35:21 -05:00
Mukundan Sundararajan cff6d7b6b1 Merge remote-tracking branch 'upstream/master' into optimize-bulkpubres-struct 2022-12-20 23:04:19 +05:30
mecoding1 6237f4eada
Fix lint issues for eventhubs_integration_test.go 
Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-12-20 18:56:10 +05:30
mecoding1 64b1a599ca
Fix lint issues across the file 
Fix lint issues across the file

Signed-off-by: mecoding1 <118708378+mecoding1@users.noreply.github.com>
 2022-12-20 12:37:41 +05:30
Bernd Verst 8b3672c91e
Merge branch 'master' into feat/rabbitmq-tls 2022-12-19 15:31:47 -08:00
Bernd Verst a7d1e9e250
Merge branch 'master' into master 2022-12-19 15:02:32 -08:00