VER: Release 0.27.0

Author: threecgreen

CHANGELOG.md

@@ -1,16 +1,27 @@
 # Changelog
 
-## 0.27.0 - TBD
+## 0.27.0 - 2025-06-10
 
 ### Enhancements
 - Made the buffer size used by the live client when reading from the TCP socket
   configurable through the `LiveBuilder::buffer_size()` method
 - Added support for using `rustls` without pulling in OpenSSL. `reqwest` with OpenSSL is
   still the default
+- Upgraded DBN version to 0.36.0:
+  - Added support for width, fill, and padding when formatting `pretty::Ts`
+  - Added support for sign, precision, width, fill, and padding when formatting
+    `pretty::Px`
+  - Optimized pretty formatting of prices and timestamps
 
 ### Breaking changes
 - Changed type of `split_duration` to `Option<SplitDuration>` to support setting no
   split duration
+- Breaking changes from DBN:
+  - Moved core async decoding and encoding functionality to new traits to
+    match the sync interface and present a standardized interface
+    - Decoding: `AsyncDecodeRecordRef` and `AsyncDecodeRecord`
+    - Encoding: `AsyncEncodeRecord`, `AsyncEncodeRecordRef`, and
+      `AsyncEncodeRecordTextExt`
 
 ### Deprecations
 - Deprecated `LiveClient::connect` and `LiveClient::connect_with_addr` methods in favor

Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "databento"
 authors = ["Databento <[email protected]>"]
-version = "0.26.2"
+version = "0.27.0"
 edition = "2021"
 repository = "https://github.com/databento/databento-rs"
 description = "Official Databento client library"
@@ -31,7 +31,7 @@ historical = [
 live = ["dep:hex", "dep:sha2", "tokio/net"]
 
 [dependencies]
-dbn = { version = "0.35.1", features = ["async", "serde"] }
+dbn = { version = "0.36.0", features = ["async", "serde"] }
 
 async-compression = { version = "0.4", features = ["tokio", "zstd"], optional = true }
 # Async stream trait

README.md

@@ -43,7 +43,7 @@ Here is a simple program that fetches 10 minutes worth of historical trades for
 use std::error::Error;
 
 use databento::{
-    dbn::{Dataset, SType, Schema, TradeMsg},
+    dbn::{decode::DbnMetadata, Dataset, SType, Schema, TradeMsg},
     historical::timeseries::GetRangeParams,
     HistoricalClient,
 };

examples/historical.rs

@@ -2,7 +2,7 @@
 use std::error::Error;
 
 use databento::{
-    dbn::{Dataset, SType, Schema, TradeMsg},
+    dbn::{decode::DbnMetadata, Dataset, SType, Schema, TradeMsg},
     historical::timeseries::GetRangeParams,
     HistoricalClient,
 };

examples/split_symbols.rs

@@ -6,8 +6,9 @@ use anyhow::Context;
 use async_compression::tokio::write::ZstdEncoder;
 use databento::{
     dbn::{
-        decode::AsyncDbnDecoder, encode::AsyncDbnEncoder, InstrumentDefMsg, Metadata, Schema,
-        SymbolIndex,
+        decode::{AsyncDbnDecoder, DbnMetadata},
+        encode::{AsyncDbnEncoder, AsyncEncodeRecord, AsyncEncodeRecordRef},
+        InstrumentDefMsg, Metadata, Schema, SymbolIndex,
     },
     historical::timeseries::GetRangeParams,
     HistoricalClient,
@@ -55,7 +56,7 @@ async fn main() -> anyhow::Result<()> {
             encoders.insert(parent.clone(), encoder);
         };
     }
-    for (parent, encoder) in encoders {
+    for (parent, mut encoder) in encoders {
         if let Err(e) = encoder.shutdown().await {
             eprintln!("Failed to shutdown encoder for {parent}: {e:?}");
         }

src/historical/timeseries.rs

@@ -2,7 +2,11 @@
 
 use std::{num::NonZeroU64, path::PathBuf};
 
-use dbn::{encode::AsyncDbnEncoder, Compression, Encoding, SType, Schema, VersionUpgradePolicy};
+use dbn::{
+    decode::DbnMetadata,
+    encode::{AsyncDbnEncoder, AsyncEncodeRecordRef},
+    Compression, Encoding, SType, Schema, VersionUpgradePolicy,
+};
 use futures::{Stream, TryStreamExt};
 use reqwest::{header::ACCEPT, RequestBuilder};
 use tokio::{