Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
52d9e1e93e | ||
|
|
19941156b4 |
@@ -1,3 +1,10 @@
|
|||||||
|
## [1.3.1](https://github.com/asepharyana/mytheclipse/compare/v1.3.0...v1.3.1) (2026-08-28)
|
||||||
|
|
||||||
|
|
||||||
|
### Bug Fixes
|
||||||
|
|
||||||
|
* **ci:** gate event crate doctest behind mem feature and apply rustfmt ([1994115](https://github.com/asepharyana/mytheclipse/commit/19941156b43ec58370d0d1369174ec84400e9bc9))
|
||||||
|
|
||||||
# [1.3.0](https://github.com/asepharyana/mytheclipse/compare/v1.2.0...v1.3.0) (2026-08-28)
|
# [1.3.0](https://github.com/asepharyana/mytheclipse/compare/v1.2.0...v1.3.0) (2026-08-28)
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Generated
+6
-6
@@ -2539,7 +2539,7 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "mytheclipse"
|
name = "mytheclipse"
|
||||||
version = "1.3.0"
|
version = "1.3.1"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"num_cpus",
|
"num_cpus",
|
||||||
"rand 0.8.8",
|
"rand 0.8.8",
|
||||||
@@ -2551,7 +2551,7 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "mytheclipse-cache"
|
name = "mytheclipse-cache"
|
||||||
version = "1.3.0"
|
version = "1.3.1"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"async-trait",
|
"async-trait",
|
||||||
"moka",
|
"moka",
|
||||||
@@ -2564,7 +2564,7 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "mytheclipse-config"
|
name = "mytheclipse-config"
|
||||||
version = "1.3.0"
|
version = "1.3.1"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"dotenvy",
|
"dotenvy",
|
||||||
"notify",
|
"notify",
|
||||||
@@ -2579,7 +2579,7 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "mytheclipse-crypto"
|
name = "mytheclipse-crypto"
|
||||||
version = "1.3.0"
|
version = "1.3.1"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"aead",
|
"aead",
|
||||||
"aes-gcm",
|
"aes-gcm",
|
||||||
@@ -2596,7 +2596,7 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "mytheclipse-event"
|
name = "mytheclipse-event"
|
||||||
version = "1.3.0"
|
version = "1.3.1"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"async-nats",
|
"async-nats",
|
||||||
"async-trait",
|
"async-trait",
|
||||||
@@ -2612,7 +2612,7 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "mytheclipse-storage"
|
name = "mytheclipse-storage"
|
||||||
version = "1.3.0"
|
version = "1.3.1"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"async-trait",
|
"async-trait",
|
||||||
"aws-config",
|
"aws-config",
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "mytheclipse-cache"
|
name = "mytheclipse-cache"
|
||||||
version = "1.3.0"
|
version = "1.3.1"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
rust-version = "1.75"
|
rust-version = "1.75"
|
||||||
license = "MIT OR Apache-2.0"
|
license = "MIT OR Apache-2.0"
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "mytheclipse-config"
|
name = "mytheclipse-config"
|
||||||
version = "1.3.0"
|
version = "1.3.1"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
rust-version = "1.75"
|
rust-version = "1.75"
|
||||||
license = "MIT OR Apache-2.0"
|
license = "MIT OR Apache-2.0"
|
||||||
|
|||||||
@@ -49,7 +49,10 @@ impl<T: Config + Clone> DynamicConfig<T> {
|
|||||||
|
|
||||||
/// Replaces the current value and notifies subscribers.
|
/// Replaces the current value and notifies subscribers.
|
||||||
pub fn set(&self, new: T) {
|
pub fn set(&self, new: T) {
|
||||||
*self.inner.write().expect("mytheclipse-config: RwLock poisoned") = new;
|
*self
|
||||||
|
.inner
|
||||||
|
.write()
|
||||||
|
.expect("mytheclipse-config: RwLock poisoned") = new;
|
||||||
let _ = self.tx.send(());
|
let _ = self.tx.send(());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "mytheclipse-crypto"
|
name = "mytheclipse-crypto"
|
||||||
version = "1.3.0"
|
version = "1.3.1"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
rust-version = "1.75"
|
rust-version = "1.75"
|
||||||
license = "MIT OR Apache-2.0"
|
license = "MIT OR Apache-2.0"
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "mytheclipse-event"
|
name = "mytheclipse-event"
|
||||||
version = "1.3.0"
|
version = "1.3.1"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
rust-version = "1.75"
|
rust-version = "1.75"
|
||||||
license = "MIT OR Apache-2.0"
|
license = "MIT OR Apache-2.0"
|
||||||
|
|||||||
@@ -15,20 +15,27 @@
|
|||||||
//!
|
//!
|
||||||
//! ## Example
|
//! ## Example
|
||||||
//!
|
//!
|
||||||
//! ```
|
//! The in-memory + typed bus (`mem` feature, on by default):
|
||||||
//! use mytheclipse_event::{EventBus, InMemoryEventBus, TypedEventBus};
|
//!
|
||||||
|
//! ```no_run
|
||||||
//! use serde::{Deserialize, Serialize};
|
//! use serde::{Deserialize, Serialize};
|
||||||
//!
|
//!
|
||||||
//! #[derive(Debug, Serialize, Deserialize, PartialEq)]
|
//! #[derive(Debug, Serialize, Deserialize, PartialEq)]
|
||||||
//! struct OrderCreated { id: u64 }
|
//! struct OrderCreated { id: u64 }
|
||||||
//!
|
//!
|
||||||
//! # #[tokio::main] async fn main() {
|
//! #[cfg(feature = "mem")]
|
||||||
//! let bus = TypedEventBus::new(InMemoryEventBus::default());
|
//! #[tokio::main]
|
||||||
//! let mut sub = bus.subscribe::<OrderCreated>("orders").await.unwrap();
|
//! async fn main() {
|
||||||
//! bus.publish("orders", &OrderCreated { id: 42 }).await.unwrap();
|
//! use mytheclipse_event::{EventBus, InMemoryEventBus, TypedEventBus};
|
||||||
//! let event = sub.recv().await.unwrap();
|
//! let bus = TypedEventBus::new(InMemoryEventBus::default());
|
||||||
//! assert_eq!(event, OrderCreated { id: 42 });
|
//! let mut sub = bus.subscribe::<OrderCreated>("orders").await.unwrap();
|
||||||
//! # }
|
//! bus.publish("orders", &OrderCreated { id: 42 }).await.unwrap();
|
||||||
|
//! let event = sub.recv().await.unwrap();
|
||||||
|
//! assert_eq!(event, OrderCreated { id: 42 });
|
||||||
|
//! }
|
||||||
|
//!
|
||||||
|
//! #[cfg(not(feature = "mem"))]
|
||||||
|
//! fn main() {}
|
||||||
//! ```
|
//! ```
|
||||||
|
|
||||||
pub mod traits;
|
pub mod traits;
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "mytheclipse-storage"
|
name = "mytheclipse-storage"
|
||||||
version = "1.3.0"
|
version = "1.3.1"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
rust-version = "1.75"
|
rust-version = "1.75"
|
||||||
license = "MIT OR Apache-2.0"
|
license = "MIT OR Apache-2.0"
|
||||||
|
|||||||
@@ -160,6 +160,9 @@ mod tests {
|
|||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
assert_eq!(data, b"hello gcs");
|
assert_eq!(data, b"hello gcs");
|
||||||
storage.delete("mytheclipse-storage-test.txt").await.unwrap();
|
storage
|
||||||
|
.delete("mytheclipse-storage-test.txt")
|
||||||
|
.await
|
||||||
|
.unwrap();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -52,7 +52,8 @@ impl S3Storage {
|
|||||||
access_key: &str,
|
access_key: &str,
|
||||||
secret_key: &str,
|
secret_key: &str,
|
||||||
) -> Self {
|
) -> Self {
|
||||||
let credentials = Credentials::new(access_key, secret_key, None, None, "mytheclipse-storage");
|
let credentials =
|
||||||
|
Credentials::new(access_key, secret_key, None, None, "mytheclipse-storage");
|
||||||
let config = aws_sdk_s3::Config::builder()
|
let config = aws_sdk_s3::Config::builder()
|
||||||
.region(Region::new(region.to_string()))
|
.region(Region::new(region.to_string()))
|
||||||
.endpoint_url(endpoint)
|
.endpoint_url(endpoint)
|
||||||
@@ -322,13 +323,19 @@ mod tests {
|
|||||||
.await;
|
.await;
|
||||||
|
|
||||||
storage
|
storage
|
||||||
.put("mytheclipse-storage-test.txt", bytes_stream(b"hello s3".to_vec()))
|
.put(
|
||||||
|
"mytheclipse-storage-test.txt",
|
||||||
|
bytes_stream(b"hello s3".to_vec()),
|
||||||
|
)
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
let data = read_to_vec(storage.get("mytheclipse-storage-test.txt").await.unwrap())
|
let data = read_to_vec(storage.get("mytheclipse-storage-test.txt").await.unwrap())
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
assert_eq!(data, b"hello s3");
|
assert_eq!(data, b"hello s3");
|
||||||
storage.delete("mytheclipse-storage-test.txt").await.unwrap();
|
storage
|
||||||
|
.delete("mytheclipse-storage-test.txt")
|
||||||
|
.await
|
||||||
|
.unwrap();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "mytheclipse"
|
name = "mytheclipse"
|
||||||
version = "1.3.0"
|
version = "1.3.1"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
rust-version = "1.75"
|
rust-version = "1.75"
|
||||||
license = "MIT OR Apache-2.0"
|
license = "MIT OR Apache-2.0"
|
||||||
|
|||||||
Reference in New Issue
Block a user