Daniel Sanchez
|
d73f3c2040
|
Mix: Implemented cover traffic (#910)
* Implemented cover traffic
* Update as per last specs
|
2024-11-07 12:22:26 +09:00 |
|
Youngjoon Lee
|
e0959644a9
|
Add Sync bound to BoxStream in blend stream (#908)
|
2024-11-06 18:59:06 +09:00 |
|
Daniel Sanchez
|
9b29c17e2f
|
Mix: time abstract from streams (#906)
* Extract temporal async stream
* Make stuff public
* Extract persistent transmission scheduler
* Fix tests
* Push temporal scheduler one layer up
* fix compile errors
* return Poll::Pending instead of Poll::Ready(None) when queue is empty
---------
Co-authored-by: Youngjoon Lee <5462944+youngjoon-lee@users.noreply.github.com>
|
2024-11-06 14:08:52 +09:00 |
|
Youngjoon Lee
|
c84a29db31
|
Use public keys for the mock mix message encoding (#905)
* add node IDs in message
* integrate
* handle variable-lenght messages in nomos-mix-network
* add trait MixMessage
* make tests work
* clippy happy
* remove println!
* remove unnecssary dependency
* remove unnecessary trait bounds
* remove leftover
|
2024-11-06 10:49:38 +09:00 |
|
Daniel Sanchez
|
d0eafb7635
|
Abstract blend rng (#904)
|
2024-11-05 11:24:41 +01:00 |
|
Daniel Sanchez
|
23f93dcc28
|
Abstract persistent transmission rng (#903)
|
2024-11-05 09:00:31 +01:00 |
|
Daniel Sanchez
|
c237333791
|
Mix: Use streams in message blend and mix service (#896)
* Use streams in message blend and mix service
* Refactor temporal stream method naming
* Clippy happy
* Clippy test happy
* Undo coupling
* Remove bypassing from blend
* Clippy happy
* Un-entangle tiers
* Send local messages to persistent transmission
Co-authored-by: Youngjoon Lee <5462944+youngjoon-lee@users.noreply.github.com>
---------
Co-authored-by: Youngjoon Lee <5462944+youngjoon-lee@users.noreply.github.com>
|
2024-11-02 22:57:10 +01:00 |
|
Daniel Sanchez
|
2f92c183ab
|
Mix: Implement blend as stream + extension (#864)
* First attempt
* Implement blend as stream and extension
* Implement blend as stream and extension
|
2024-10-30 11:50:15 +01:00 |
|
Daniel Sanchez
|
9d52297cdf
|
Mix: temporal as stream extension (#861)
* forward msgs immediately without any processing
* Mix: Offload transmission rate and message processing from libp2p behaviour/handler
* Mix: Core skeleton used in `MixService`
* rename Processor to MessageBlend
* Mix: Implement Persistent Transmission (Tier 1) (#845)
* Mix: Add Persistent Transmission (Tier 1)
* add test
* define Coin struct with Uniform distribution for fast repeated sampling
* use ChaCha12Rng for Coin
* improve comment
* Mix: Implement Temporal Processor (Tier 2) (#846)
* Mix: Add Persistent Transmission (Tier 1)
* Mix: Implement TemporalProcessor
* use pub(crate)
* Mix: Use TemporalProcessor in MessageBlend (#847)
* Mix: Add Persistent Transmission (Tier 1)
* Mix: Implement TemporalProcessor
* Mix: Use TemporalProcessor in MessageBlend
* remove duplicate members in Cargo.toml
* Implement persistent transmission as stream trait extension
* Replicate test for stream version
* Temporal processor as stream extension
---------
Co-authored-by: Youngjoon Lee <5462944+youngjoon-lee@users.noreply.github.com>
|
2024-10-28 17:12:50 +01:00 |
|
Daniel Sanchez
|
e207743f69
|
Mix: Persistent rate as stream + Extension (#860)
* forward msgs immediately without any processing
* Mix: Offload transmission rate and message processing from libp2p behaviour/handler
* Mix: Core skeleton used in `MixService`
* rename Processor to MessageBlend
* Mix: Implement Persistent Transmission (Tier 1) (#845)
* Mix: Add Persistent Transmission (Tier 1)
* add test
* define Coin struct with Uniform distribution for fast repeated sampling
* use ChaCha12Rng for Coin
* improve comment
* Mix: Implement Temporal Processor (Tier 2) (#846)
* Mix: Add Persistent Transmission (Tier 1)
* Mix: Implement TemporalProcessor
* use pub(crate)
* Mix: Use TemporalProcessor in MessageBlend (#847)
* Mix: Add Persistent Transmission (Tier 1)
* Mix: Implement TemporalProcessor
* Mix: Use TemporalProcessor in MessageBlend
* remove duplicate members in Cargo.toml
* Implement persistent transmission as stream trait extension
* Replicate test for stream version
---------
Co-authored-by: Youngjoon Lee <5462944+youngjoon-lee@users.noreply.github.com>
|
2024-10-28 15:24:40 +01:00 |
|
Youngjoon Lee
|
7aea30132d
|
Mix: Implement PersistsentTransmission & Temporal/CryptoProcessor and use them in MixService (#844)
* forward msgs immediately without any processing
* Mix: Offload transmission rate and message processing from libp2p behaviour/handler
* Mix: Core skeleton used in `MixService`
* rename Processor to MessageBlend
* Mix: Implement Persistent Transmission (Tier 1) (#845)
* Mix: Add Persistent Transmission (Tier 1)
* add test
* define Coin struct with Uniform distribution for fast repeated sampling
* use ChaCha12Rng for Coin
* improve comment
* Mix: Implement Temporal Processor (Tier 2) (#846)
* Mix: Add Persistent Transmission (Tier 1)
* Mix: Implement TemporalProcessor
* use pub(crate)
* Mix: Use TemporalProcessor in MessageBlend (#847)
* Mix: Add Persistent Transmission (Tier 1)
* Mix: Implement TemporalProcessor
* Mix: Use TemporalProcessor in MessageBlend
* remove duplicate members in Cargo.toml
|
2024-10-28 17:32:39 +09:00 |
|