GitLab

add ValidatorData field to Message

Useful for passing data from the validation to the application.

Configurable outbound peer queue sizes

Topic handler bug fixes

pubsub and topic methods now return error if the pubsub context has been cancelled instead of hanging

Add Discovery

When the WithDiscovery option is passed to PubSub then PubSub will be able to search for more peers that are interested in our topics.

This includes the ability for Publishes (via Topic.Publish()) to block until the router is ready to publish. When a router is ready is currently defined by a combination of a user defined MinTopicSize function (passed into topic.Publish via the WithReadiness publish option) and the properties of the pubsub router used. The discovery tests show example usage.

Added PubSub.Join(topic) that returns a Topic object. This object can be Subscribed and Published to as well as to get a TopicEventHandler for topic events. This means that the Subscription object will no longer handle PeerEvents and that PubSub's Publish and Subscribe functions are deprecated.

Expose the peer that propagates a message to the recipient

gossip methods: renames and predicate adjustment

godocs: clarify config params of MessageCache.

minor bug fix: on join, source peers from gossip[topic] if insufficient peers in fanout[topic]

add PubSub's context to Subscription

Add the ability to handle newly subscribed peers

better context respect when waiting for new peer events. refactored backlog into eventLog. removed test that was no longer useful.

Combined Join and Leave events into a single API with a struct that specifies whether the event is a Join or a Leave.

Added a Subscription Leave event