vyzo
1d5191c5bb
Merge pull request #248 from protolambda/msg-id-option
...
Configurable message id function
2019-12-16 14:20:06 +02:00
protolambda
6bd07a71fc
PR feedback: name change and account for different options order
2019-12-16 12:46:30 +01:00
protolambda
7981f9bfbd
fixes #247 : implement msg id function as pubsub option
2019-12-16 03:54:40 +01:00
Steven Allen
7269e411d7
Merge pull request #244 from libp2p/dependabot/go_modules/github.com/multiformats/go-multiaddr-0.2.0
...
Bump github.com/multiformats/go-multiaddr from 0.1.2 to 0.2.0
2019-12-11 14:57:03 +01:00
dependabot-preview[bot]
c241d1569f
Bump github.com/multiformats/go-multiaddr from 0.1.2 to 0.2.0
...
Bumps [github.com/multiformats/go-multiaddr](https://github.com/multiformats/go-multiaddr ) from 0.1.2 to 0.2.0.
- [Release notes](https://github.com/multiformats/go-multiaddr/releases )
- [Commits](https://github.com/multiformats/go-multiaddr/compare/v0.1.2...v0.2.0 )
Signed-off-by: dependabot-preview[bot] <support@dependabot.com>
2019-12-11 11:33:33 +00:00
Steven Allen
a682ceaf7d
Merge pull request #242 from libp2p/dependabot/go_modules/github.com/hashicorp/golang-lru-0.5.3
...
Bump github.com/hashicorp/golang-lru from 0.5.1 to 0.5.3
2019-12-06 17:28:50 -05:00
Steven Allen
33ef0a3eea
Merge branch 'ci/go-1.13'
2019-12-06 16:48:02 -05:00
Steven Allen
3248ced67b
ci: bump to go 1.13
2019-12-06 16:33:11 -05:00
dependabot-preview[bot]
9ce7f49ad0
Bump github.com/hashicorp/golang-lru from 0.5.1 to 0.5.3
...
Bumps [github.com/hashicorp/golang-lru](https://github.com/hashicorp/golang-lru ) from 0.5.1 to 0.5.3.
- [Release notes](https://github.com/hashicorp/golang-lru/releases )
- [Commits](https://github.com/hashicorp/golang-lru/compare/v0.5.1...v0.5.3 )
Signed-off-by: dependabot-preview[bot] <support@dependabot.com>
2019-12-06 17:41:36 +00:00
vyzo
ac2ea8beda
README: document tracing ( #239 )
2019-12-02 20:03:54 +00:00
Steven Allen
b55894f4a6
Merge pull request #236 from libp2p/chore/update-deps
...
chore(dep): update
2019-12-02 13:19:24 -05:00
Steven Allen
ed444c08f0
chore(dep): update
...
* Update go-libp2p-core and go-multiaddr.
* Regenerate protobufs with the latest gogo protobuf.
2019-12-02 13:07:46 -05:00
vyzo
01b9825fbe
Merge pull request #227 from libp2p/feat/tracing
...
tracing support
2019-11-19 02:50:36 +02:00
vyzo
7065297ac6
nits and beauty
2019-11-19 02:28:23 +02:00
vyzo
cd7f42e1d7
make tracer.Close safer
2019-11-19 00:29:23 +02:00
vyzo
40e5a49d1b
store the remote trace peer address in the peerstore
...
that way we don't have to connect every time we open the stream.
2019-11-19 00:26:06 +02:00
vyzo
7a5aaa8d1c
don't blanket wait for 1s to accumulate a batch.
...
Instead check the batch size and poll every 100ms (up to 1s) until the
minimum batch size is accumulated.
2019-11-19 00:18:10 +02:00
vyzo
24a1181b9a
move niling of trace buffer to the end
...
this avoids holding on memory while we are waiting.
2019-11-19 00:07:57 +02:00
vyzo
91527e2d10
lossy tracing for remote tracers
...
Don't accumulate memory if the tracer is being slow or unavailable, just drop the trace and log.
2019-11-18 22:01:31 +02:00
vyzo
cce30a4d6a
reset remote tracer stream on errors
2019-11-18 17:33:53 +02:00
vyzo
abe4763c01
compress entire stream in remote tracer
2019-11-18 17:13:43 +02:00
vyzo
db8e2195ea
remove CompressedTraceEventBatch from trace protobuf
2019-11-18 17:12:42 +02:00
vyzo
2fc5518a00
remote tracer: wait a second to accumulate batches
2019-11-15 20:42:04 +02:00
vyzo
57ea27eef7
remote tracer
2019-11-15 20:42:04 +02:00
vyzo
0aa629c79c
use *pb.TraceEvent as argument for Trace in the EventTracer interface
2019-11-15 20:42:04 +02:00
vyzo
f134d65848
add protobuf file tracer
2019-11-15 20:42:04 +02:00
vyzo
8ff321c529
move tracer implementation to its own file
2019-11-15 20:42:04 +02:00
vyzo
3545acf029
json tracer
2019-11-15 20:42:04 +02:00
vyzo
3f30acdcf7
track topics in message tracing
2019-11-15 20:42:04 +02:00
vyzo
ae0fcc6b4d
add traces for send/drop rpc
...
forgotten!
2019-11-15 20:42:04 +02:00
vyzo
151ec25616
implement tracing details
2019-11-15 20:42:04 +02:00
vyzo
040cabe3b0
some minor fixes in trace pb
2019-11-15 20:42:04 +02:00
vyzo
0a25f248ea
trace event protobuf
2019-11-15 20:42:04 +02:00
vyzo
fb11aa9857
initialize tracer with peer ID, trace RPC from join/leave announcements
2019-11-15 20:42:04 +02:00
vyzo
958e09a5b3
remove useless nil check when initializing subsystem tracers
2019-11-15 20:42:04 +02:00
vyzo
fd73973145
add tracing to floodsub/randomsub
2019-11-15 20:42:04 +02:00
vyzo
89c7ed46e3
trace publish
2019-11-15 20:42:04 +02:00
vyzo
67275a6382
tracing scaffolding
2019-11-15 20:42:04 +02:00
vyzo
28a87b3121
Merge pull request #231 from libp2p/feat/validator-data
...
add ValidatorData field to Message
2019-11-15 20:37:20 +02:00
vyzo
8b423348a0
add ValidatorData field to Message
...
Useful for passing data from the validation to the application.
2019-11-15 20:16:58 +02:00
vyzo
323a4110b7
Merge pull request #230 from aarshkshah1992/feat/configurable-outbound-msg-queue-size
...
Configurable outbound peer queue sizes
2019-11-15 19:55:36 +02:00
Aarsh Shah
0dd2171ac5
queue size must always be positive
2019-11-16 01:39:12 +08:00
Aarsh Shah
d380477228
Configurable outbound peer queue sizes
2019-11-16 01:14:10 +08:00
Adin Schmahmann
534fe2f382
Merge pull request #225 from libp2p/fix/224
...
Topic handler bug fixes
2019-11-04 04:13:41 -05:00
Adin Schmahmann
686c928d4e
pubsub and topic methods now return error if the pubsub context has been cancelled instead of hanging
2019-11-04 03:52:39 -05:00
Adin Schmahmann
ad97d9bf17
fixed closed Topic handles still being able to perform some actions on the topic
2019-11-02 19:28:44 -04:00
Adin Schmahmann
899f9cd62b
fixed Topic close error
2019-11-01 17:12:23 -04:00
Steven Allen
55f4ad6eb9
Merge pull request #184 from aschmahmann/feat/discovery
...
Add Discovery
2019-10-31 15:19:29 -07:00
Adin Schmahmann
f9c26c2e68
Added libp2p discovery capabilities to PubSub.
...
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.
2019-10-31 16:39:18 -04:00
Adin Schmahmann
5ef7439d71
interface: New Topic + TopicEventHandlers objects.
...
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.
2019-10-31 15:37:44 -04:00
