* chore: Use latest dapr/dapr version
Signed-off-by: Javier Aliaga <javier@diagrid.io>
* chore: Bump golangci version
Signed-off-by: Javier Aliaga <javier@diagrid.io>
* chore: Bump golangci-lint version
Signed-off-by: Javier Aliaga <javier@diagrid.io>
* chore: Fix lint errors on tooling
Signed-off-by: Javier Aliaga <javier@diagrid.io>
* chore: Increase sleep to service example
Signed-off-by: Javier Aliaga <javier@diagrid.io>
---------
Signed-off-by: Javier Aliaga <javier@diagrid.io>
* Introduce interface for topic event subscriber
I introduced the TopicEventSubscriber interface to allow for
subscribers to be implemented as structs. This will allow subscribers
to be initialized with any settings or dependencies needed to process
incoming events.
I converted TopicEventHandler to implement TopicEventSubscriber. I
revised TopicRegistrar to store TopicEventSubscribers instead of
TopicEventHandlers.
Resolves#660
Signed-off-by: Michael Collins <mfcollins3@me.com>
* Update go-service documentation
I added examples of how to use the TopicEventSubscriber interface to
create a new subscriber for both HTTP and gRPC services.
Signed-off-by: Michael Collins <mfcollins3@me.com>
---------
Signed-off-by: Michael Collins <mfcollins3@me.com>
* Bidirectional Subscriptions
Adds support for bidirectional subscriptions to PubSubs. Adds two
methods for subscribing- one using a callback and one using an
imperative approach. Both giving support to different programming styles
or use cases.
Adds example with tests.
Signed-off-by: joshvanl <me@joshvanl.dev>
* Linting: Remove unused `closeCh`
Signed-off-by: joshvanl <me@joshvanl.dev>
* Fixes comment order in bidisub.go
Signed-off-by: joshvanl <me@joshvanl.dev>
* Add comment about processing message
Signed-off-by: joshvanl <me@joshvanl.dev>
* Adds dead letter topic example
Signed-off-by: joshvanl <me@joshvanl.dev>
* chore: remove go.mod
Signed-off-by: mikeee <hey@mike.ee>
* Updates go mod to v1.14.0-rc.1
Signed-off-by: joshvanl <me@joshvanl.dev>
---------
Signed-off-by: joshvanl <me@joshvanl.dev>
Signed-off-by: mikeee <hey@mike.ee>
Signed-off-by: Mike Nguyen <hey@mike.ee>
Co-authored-by: mikeee <hey@mike.ee>
* Update github.com/dapr/dapr to v1.13.0-rc.1
Signed-off-by: joshvanl <me@joshvanl.dev>
* Revert go.mod to use Go 1.20 as minimum version
Signed-off-by: joshvanl <me@joshvanl.dev>
* github actions: only perform go mod diff on same go version
Signed-off-by: joshvanl <me@joshvanl.dev>
---------
Signed-off-by: joshvanl <me@joshvanl.dev>
* Add `NewServiceWithGrpcServer` to gRPC service
Signed-off-by: pimmerks <pimmerks@users.noreply.github.com>
* Apply suggestion of not creating new variable
Signed-off-by: pimmerks <pimmerks@users.noreply.github.com>
---------
Signed-off-by: pimmerks <pimmerks@users.noreply.github.com>
* Adds context to rest of funcs, so context can always be propagated.
Signed-off-by: joshvanl <me@joshvanl.dev>
* Adds `//nolint:interfacebloat` to StateManager interface due to new
`xxxContext` methods.
Signed-off-by: joshvanl <me@joshvanl.dev>
* Use separate interface for structs with context funcs
Signed-off-by: joshvanl <me@joshvanl.dev>
* Adds more locks to actor functions
Signed-off-by: joshvanl <me@joshvanl.dev>
---------
Signed-off-by: joshvanl <me@joshvanl.dev>
* Various fixed and cleanups
1. Fixed SDK not compiling and tests failing
2. Increased minimum Go version to 1.18
3. Removed `github.com/pkg/errors` and `go.uber.org/atomic` - replaced with the standard library instead (the old packages have been added to the "depguard" linter)
4. Upgraded all dependencies
5. Upgraded golangci-lint to support Go 1.18+
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Do not wrap error if nil
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Run CI on Go 1.18 and 1.19
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Restore compatibility with Go 1.18
Looks like the newer methods were added in Go 1.19 only
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Should fix validate_examples CI
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Updated (most) deprecated Actions
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Fix helm repo
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Determine latest Dapr version in a better way
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Fix validate.sh
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
* Decode CloudEvent Data consistently between HTTP and gRPC
Signed-off-by: Phil Kedy <phil.kedy@gmail.com>
* linter issue
Signed-off-by: Phil Kedy <phil.kedy@gmail.com>
* Added parsing media type
Signed-off-by: Phil Kedy <phil.kedy@gmail.com>
* Adding extension json media type handling
Signed-off-by: Phil Kedy <phil.kedy@gmail.com>
* add TTL to actor timer/reminder requests (#225)
Signed-off-by: Phil Kedy <phil.kedy@gmail.com>
* Adding more tests
Signed-off-by: Phil Kedy <phil.kedy@gmail.com>
* Tweak
Signed-off-by: Phil Kedy <phil.kedy@gmail.com>
Co-authored-by: Dmitry Shmulevich <dmitry.shmulevich@gmail.com>
* ftr: init go-sdk action
* fix: finished design of actor-api's invoke feature
* fix: add readme
* fix: lint
* fix: add manager unit test
* fix: add actor state suport
* fix: add comments
* fix: add comment
* fix the change reqeust of pr
* fix: validate example test
* fix: linter
* add actor validation
* add actor validation
* fix: update actor validation init sleep time
* fix: add init time for validate example server
* fix: change actor to the end of test in order not to let reminder bother other test
* fix: validate test
* fix: typo of factory
* fix: add init time
* fix: ut
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Long Dai <long.dai@intel.com>
Javier Aliaga