Skip to content
GitLab
Menu
Projects
Groups
Snippets
Loading...
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
Menu
Open sidebar
OpenDAS
dynamo
Commits
0f4c1c58
Commit
0f4c1c58
authored
Mar 14, 2025
by
Ryan McCormick
Committed by
GitHub
Mar 14, 2025
Browse files
fix: Fix cargo doc warnings for lib/runtime (#150)
parent
dac63127
Changes
4
Show whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
8 additions
and
8 deletions
+8
-8
lib/runtime/src/component/client.rs
lib/runtime/src/component/client.rs
+2
-2
lib/runtime/src/traits/events.rs
lib/runtime/src/traits/events.rs
+4
-4
lib/runtime/src/transports/zmq.rs
lib/runtime/src/transports/zmq.rs
+1
-1
lib/runtime/src/utils/pool.rs
lib/runtime/src/utils/pool.rs
+1
-1
No files found.
lib/runtime/src/component/client.rs
View file @
0f4c1c58
...
@@ -148,12 +148,12 @@ where
...
@@ -148,12 +148,12 @@ where
})
})
}
}
/// String identifying <namespace>/<component>/<endpoint>
/// String identifying
`
<namespace>/<component>/<endpoint>
`
pub
fn
path
(
&
self
)
->
String
{
pub
fn
path
(
&
self
)
->
String
{
self
.endpoint
.path
()
self
.endpoint
.path
()
}
}
/// String identifying <namespace>/component/<component>/<endpoint>
/// String identifying
`
<namespace>/component/<component>/<endpoint>
`
pub
fn
etcd_path
(
&
self
)
->
String
{
pub
fn
etcd_path
(
&
self
)
->
String
{
self
.endpoint
.etcd_path
()
self
.endpoint
.etcd_path
()
}
}
...
...
lib/runtime/src/traits/events.rs
View file @
0f4c1c58
...
@@ -24,12 +24,12 @@ use crate::Result;
...
@@ -24,12 +24,12 @@ use crate::Result;
// async fn publish(&self, event: &(impl Serialize + Send + Sync)) -> Result<()>;
// async fn publish(&self, event: &(impl Serialize + Send + Sync)) -> Result<()>;
// }
// }
/// A [EventP
lane] is a component that can publish and/or subscribe to
events.
/// A
n
[EventP
ublisher] is an object that can publish
events.
///
///
/// Each implementation of [EventP
lane
] will define the root subject.
/// Each implementation of [EventP
ublisher
] will define the root subject.
#[async_trait]
#[async_trait]
pub
trait
EventPublisher
{
pub
trait
EventPublisher
{
/// The base subject used for this implementation of the [EventP
lane
].
/// The base subject used for this implementation of the [EventP
ublisher
].
fn
subject
(
&
self
)
->
String
;
fn
subject
(
&
self
)
->
String
;
/// Publish a single event to the event plane. The `event_name` will be `.` concatenated with the
/// Publish a single event to the event plane. The `event_name` will be `.` concatenated with the
...
@@ -57,7 +57,7 @@ pub trait EventPublisher {
...
@@ -57,7 +57,7 @@ pub trait EventPublisher {
// fn publisher_bytes(&self, event_name: impl AsRef<str>) -> &PublisherBytes;
// fn publisher_bytes(&self, event_name: impl AsRef<str>) -> &PublisherBytes;
}
}
/// A
trait for subscribing to events in the event plane
.
/// A
n [EventSubscriber] is an object that can subscribe to events
.
///
///
/// This trait provides methods to subscribe to events published on specific subjects.
/// This trait provides methods to subscribe to events published on specific subjects.
#[async_trait]
#[async_trait]
...
...
lib/runtime/src/transports/zmq.rs
View file @
0f4c1c58
...
@@ -307,7 +307,7 @@ impl ServerExecutionHandle {
...
@@ -307,7 +307,7 @@ impl ServerExecutionHandle {
}
}
// Client implementation
// Client implementation
struct
Client
{
pub
struct
Client
{
dealer
:
Dealer
<
IntoIter
<
Vec
<
u8
>>
,
Vec
<
u8
>>
,
dealer
:
Dealer
<
IntoIter
<
Vec
<
u8
>>
,
Vec
<
u8
>>
,
}
}
...
...
lib/runtime/src/utils/pool.rs
View file @
0f4c1c58
...
@@ -29,7 +29,7 @@ pub trait ReturnHandle<T: Returnable>: Send + Sync + 'static {
...
@@ -29,7 +29,7 @@ pub trait ReturnHandle<T: Returnable>: Send + Sync + 'static {
fn
return_to_pool
(
&
self
,
value
:
PoolValue
<
T
>
);
fn
return_to_pool
(
&
self
,
value
:
PoolValue
<
T
>
);
}
}
/// Enum to hold either a Box<T> or
T
directly
/// Enum to hold either a
`
Box<T>
`
or
`T`
directly
pub
enum
PoolValue
<
T
:
Returnable
>
{
pub
enum
PoolValue
<
T
:
Returnable
>
{
Boxed
(
Box
<
T
>
),
Boxed
(
Box
<
T
>
),
Direct
(
T
),
Direct
(
T
),
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment