casesensitive subscribe #21
Open
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
* Refactoring codes * close channel * Adding filter * Adding registerInterval Co-authored-by: Eddie Raapoto <[email protected]> Co-authored-by: Raapoto Eddie <[email protected]>
…ssages with this parameter
* Implement Filter
* Adding Filter implementation
Adding samples
* Implement LoadBalance Filter
* Filter
* Change Filter implementation
* Avoid segfault when call GetService("xxxx",nil)
* Fix bug with LoadBalancerFilter
Co-authored-by: Raapoto Eddie <[email protected]>
Co-authored-by: Eddie Raapoto <[email protected]>
* Implement Filter
* Adding Filter implementation
Adding samples
* Implement LoadBalance Filter
* Filter
* Change Filter implementation
* Avoid segfault when call GetService("xxxx",nil)
* Fix bug with LoadBalancerFilter
* Manage due time
* Refactoring
* Fix nil pointer seg fault after closing registry
Co-authored-by: Raapoto Eddie <[email protected]>
Co-authored-by: Eddie Raapoto <[email protected]>
* Implement Filter
* Adding Filter implementation
Adding samples
* Implement LoadBalance Filter
* Filter
* Change Filter implementation
* Avoid segfault when call GetService("xxxx",nil)
* Fix bug with LoadBalancerFilter
* Adding tests
* Adding cache
Co-authored-by: Raapoto Eddie <[email protected]>
Co-authored-by: Eddie Raapoto <[email protected]>
* Refactoring
* Refactoring
* Adding support to registry.Observe("*")
* Adding localhost observer filter
Adding Unregiser func
Co-authored-by: Raapoto Eddie <[email protected]>
* Update dependencies * Adding utility func for get free port * Timestamps.Registration and Timestamp.Duration are in milliseconds * Fix some warning Co-authored-by: Eddie Raapoto <[email protected]> Co-authored-by: Raapoto Eddie <[email protected]>
* Update dependencies * Adding utility func for get free port * Timestamps.Registration and Timestamp.Duration are in milliseconds * Fix some warning Co-authored-by: Eddie Raapoto <[email protected]> Co-authored-by: Raapoto Eddie <[email protected]>
Co-authored-by: Raapoto Eddie <[email protected]>
* Add draft fakepubsub * Implement fakemap Start to implement fakepubsub * Stable version * Adding test unit * Move pubsub -> pubsub folder Adding test unit * Fix bug on concurency * Fix bug with SetDefaultInstance * Delete unused code * Adding test unit test error * Avoid lock with channel * Fix bug on checkDueTime Co-authored-by: Eddie Raapoto <[email protected]> Co-authored-by: Eddie Raapoto <[email protected]>
* Implement redis pubsub * Implement redis pubsub * Update README.md call Stop() func Co-authored-by: Raapoto Eddie <[email protected]>
* Refactoring * improve tests * Adding test units * avoid nil pointer * Add unit tests => coverage 90.5% * Adding test for concurrent acess to map registeredService * Fix concurrent access to registeredServices * improve coverage * Unit test code coverage 94.6% * Add callback to test.pubsub * improve code coverage * Adding test unit Co-authored-by: Raapoto Eddie <[email protected]>
Co-authored-by: Raapoto Eddie <[email protected]>
* Adding consul http web service * Save changes * sending last modif * refactoring * Updating dependencies * Crete registry Port func * commit first stable version * rename consul folder to rest * implement GetObservedServiceNames * Update dependencies * Adding GetHandlerFunc Co-authored-by: Eddie Raapoto <[email protected]> Co-authored-by: Eddie Raapoto <[email protected]>
* gofmt: space added in comments * Upgrade dependencies * gofmt: adding space in compents * remove warnings * Fix concurrent access on observes map --------- Co-authored-by: Raapoto Eddie <[email protected]>
upgrade golang.org/x/net to 0.7.0
* Registry can be initialised without nats => registry.Register() func wait until nats is ready * Adding Configure interface => if Pubsub implement this interface. Registry invoke Configure at startup --------- Co-authored-by: Raapoto Eddie <[email protected]>
eddieraa
force-pushed
the
master
branch
2 times, most recently
from
d047d3e to
472423e
Compare
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
No description provided.