Overhaul events to use Tendermint's new pubsub package.
Makes our events non-blocking and adds Query logic.
Signed-off-by:
Silas Davis <silas@monax.io>
Showing
- client/node_client.go 1 addition, 1 deletionclient/node_client.go
- client/websocket_client.go 7 additions, 7 deletionsclient/websocket_client.go
- cmd/burrow/main.go 4 additions, 2 deletionscmd/burrow/main.go
- config/config.go 4 additions, 2 deletionsconfig/config.go
- consensus/tendermint/events.go 102 additions, 0 deletionsconsensus/tendermint/events.go
- core/kernel.go 61 additions, 37 deletionscore/kernel.go
- core/kernel_test.go 1 addition, 1 deletioncore/kernel_test.go
- event/cache.go 33 additions, 18 deletionsevent/cache.go
- event/cache_test.go 41 additions, 18 deletionsevent/cache_test.go
- event/convention.go 74 additions, 0 deletionsevent/convention.go
- event/convention_test.go 36 additions, 0 deletionsevent/convention_test.go
- event/data.go 0 additions, 136 deletionsevent/data.go
- event/data_test.go 0 additions, 64 deletionsevent/data_test.go
- event/emitter.go 48 additions, 144 deletionsevent/emitter.go
- event/emitter_test.go 35 additions, 0 deletionsevent/emitter_test.go
- event/query.go 231 additions, 0 deletionsevent/query.go
- event/query_test.go 43 additions, 0 deletionsevent/query_test.go
- execution/block_cache.go 1 addition, 3 deletionsexecution/block_cache.go
- execution/events/events.go 83 additions, 7 deletionsexecution/events/events.go
- execution/evm/events/events.go 48 additions, 2 deletionsexecution/evm/events/events.go
Loading
Please register or sign in to comment