Skip to content
Permalink
Browse files

v0.10 release

  • Loading branch information...
frankmcsherry committed Jul 9, 2019
1 parent 9430c46 commit cbdfd16292a3f285d09c7c302cccc5deae803730
Showing with 26 additions and 28 deletions.
  1. +4 −2 CHANGELOG.md
  2. +5 −7 bytes/Cargo.toml
  3. +7 −6 communication/Cargo.toml
  4. +5 −8 logging/Cargo.toml
  5. +5 −5 timely/Cargo.toml
@@ -2,11 +2,13 @@

All notable changes to this project will be documented in this file.

## Unreleased
## 0.10.0

### Added

A `Worker` now has a `step_or_park(Option<Duration>)` method, which instructs the worker to take a step and gives it permission to part the worker thread for at most the supplied timeout if there is no work to perform. A value of `None` implies no timeout (unboundedly parked) whereas a value of `Some(0)` should return immediately. The communication layers are implemented to awaken workers if they receive new communications, and workers should hand out copies of their `Thread` if they want other threads to wake them for other reasons (e.g. queues from threads external to timely).
A `Worker` now has a `step_or_park(Option<Duration>)` method, which instructs the worker to take a step and gives it permission to park the worker thread for at most the supplied timeout if there is no work to perform. A value of `None` implies no timeout (unboundedly parked) whereas a value of `Some(0)` should return immediately. The communication layers are implemented to awaken workers if they receive new communications, and workers should hand out copies of their `Thread` if they want other threads to wake them for other reasons (e.g. queues from threads external to timely).

Communication `WorkerGuards` expose their underlying join handles to allow the main thread or others to unpark worker threads that may be parked (for example, after pushing new data into a queue shared with the worker).

## 0.9.0

@@ -1,15 +1,13 @@
[package]
name = "timely_bytes"
version = "0.9.0"
version = "0.10.0"
authors = ["Frank McSherry <fmcsherry@me.com>"]
edition = "2018"

description = "Disjoint mutable byte slices from a common allocation"

documentation = "https://frankmcsherry.github.com/timely-dataflow"
homepage = "https://github.com/frankmcsherry/timely-dataflow"
repository = "https://github.com/frankmcsherry/timely-dataflow.git"
documentation = "https://docs.rs/timely/"
homepage = "https://github.com/TimelyDataflow/timely-dataflow"
repository = "https://github.com/TimelyDataflow/timely-dataflow.git"
keywords = ["timely", "dataflow", "bytes"]
license = "MIT"

[dependencies]
license = "MIT"
@@ -1,14 +1,15 @@
[package]
name = "timely_communication"
version = "0.9.0"
version = "0.10.0"
authors = ["Frank McSherry <fmcsherry@me.com>"]
description = "Communication layer for timely dataflow"
edition = "2018"

# These URLs point to more information about the repository
documentation = "https://frankmcsherry.github.com/timely-dataflow"
homepage = "https://github.com/frankmcsherry/timely-dataflow"
repository = "https://github.com/frankmcsherry/timely-dataflow.git"

documentation = "https://docs.rs/timely/"
homepage = "https://github.com/TimelyDataflow/timely-dataflow"
repository = "https://github.com/TimelyDataflow/timely-dataflow.git"
keywords = ["timely", "dataflow"]
license = "MIT"

@@ -22,5 +23,5 @@ serde_derive = "1.0"
serde = "1.0"
abomonation = "0.7"
abomonation_derive = "0.4"
timely_bytes = { path = "../bytes", version = "0.9" }
timely_logging = { path = "../logging", version = "0.9" }
timely_bytes = { path = "../bytes", version = "0.10" }
timely_logging = { path = "../logging", version = "0.10" }
@@ -1,16 +1,13 @@
[package]
name = "timely_logging"
version = "0.9.0"
version = "0.10.0"
authors = ["Frank McSherry <fmcsherry@me.com>"]
edition = "2018"

description = "Common timely logging infrastructure"

documentation = "https://frankmcsherry.github.com/timely-dataflow"
homepage = "https://github.com/frankmcsherry/timely-dataflow"
repository = "https://github.com/frankmcsherry/timely-dataflow.git"
documentation = "https://docs.rs/timely/"
homepage = "https://github.com/TimelyDataflow/timely-dataflow"
repository = "https://github.com/TimelyDataflow/timely-dataflow.git"
keywords = ["timely", "dataflow", "logging"]
license = "MIT"


[dependencies]
license = "MIT"
@@ -1,9 +1,9 @@
[package]

name = "timely"
version = "0.9.0"
version = "0.10.0"
authors = ["Frank McSherry <fmcsherry@me.com>"]
readme = "README.md"
readme = "../README.md"
edition = "2018"

description = "A low-latency data-parallel dataflow system in Rust"
@@ -23,9 +23,9 @@ serde = "1.0"
serde_derive = "1.0"
abomonation = "0.7"
abomonation_derive = "0.3"
timely_bytes = { path = "../bytes", version = "0.9" }
timely_logging = { path = "../logging", version = "0.9" }
timely_communication = { path = "../communication", version = "0.9" }
timely_bytes = { path = "../bytes", version = "0.10" }
timely_logging = { path = "../logging", version = "0.10" }
timely_communication = { path = "../communication", version = "0.10" }

[dev-dependencies]
timely_sort="0.1.6"

0 comments on commit cbdfd16

Please sign in to comment.
You can’t perform that action at this time.