Skip to content

Commit 2baa834

Browse files
ecal configuration API introduced (samples how to use it will follow) (#56)
1 parent e66e2d8 commit 2baa834

File tree

34 files changed

+145
-86
lines changed

34 files changed

+145
-86
lines changed

README.md

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ use rustecal_types_string::StringMessage;
3838

3939
fn main() {
4040
// Initialize eCAL
41-
Ecal::initialize(Some("hello publisher"), EcalComponents::DEFAULT).unwrap();
41+
Ecal::initialize(Some("hello publisher"), EcalComponents::DEFAULT, None).unwrap();
4242

4343
// create a string publisher on "hello"
4444
let publisher = TypedPublisher::<StringMessage>::new("hello").unwrap();
@@ -67,7 +67,7 @@ use rustecal_types_string::StringMessage;
6767

6868
fn main() {
6969
// Initialize eCAL
70-
Ecal::initialize(Some("hello subscriber"), EcalComponents::DEFAULT).unwrap();
70+
Ecal::initialize(Some("hello subscriber"), EcalComponents::DEFAULT, None).unwrap();
7171

7272
// create a string subscriber on “hello”
7373
let mut subscriber = TypedSubscriber::<StringMessage>::new("hello").unwrap();
@@ -99,7 +99,7 @@ use rustecal::service::types::MethodInfo;
9999

100100
fn main() {
101101
// Initialize eCAL
102-
Ecal::initialize(Some("mirror server"), EcalComponents::DEFAULT).unwrap();
102+
Ecal::initialize(Some("mirror server"), EcalComponents::DEFAULT, None).unwrap();
103103

104104
// create a service server for "mirror"
105105
let mut server = ServiceServer::new("mirror").unwrap();
@@ -138,7 +138,7 @@ use rustecal::service::types::ServiceRequest;
138138

139139
fn main() {
140140
// Initialize eCAL
141-
Ecal::initialize(Some("mirror client"), EcalComponents::DEFAULT).unwrap();
141+
Ecal::initialize(Some("mirror client"), EcalComponents::DEFAULT, None).unwrap();
142142

143143
// create a service client for "mirror"
144144
let client = ServiceClient::new("mirror").unwrap();

docs/src/api/ecal.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ The `Ecal` struct manages initialization and finalization of the eCAL system.
88
use rustecal::{Ecal, EcalComponents};
99

1010
fn main() -> Result<(), Box<dyn std::error::Error>> {
11-
Ecal::initialize(Some("my ecal app"), EcalComponents::DEFAULT)?;
11+
Ecal::initialize(Some("my ecal app"), EcalComponents::DEFAULT, None)?;
1212

1313
// use publishers, subscribers, clients, server
1414

docs/src/examples/binary.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ use rustecal::{Ecal, EcalComponents, TypedPublisher};
88
use rustecal_types_bytes::BytesMessage;
99

1010
fn main() -> Result<(), Box<dyn std::error::Error>> {
11-
Ecal::initialize(Some("blob publisher"), EcalComponents::DEFAULT)?;
11+
Ecal::initialize(Some("blob publisher"), EcalComponents::DEFAULT, None)?;
1212

1313
let publisher = TypedPublisher::<BytesMessage>::new("blob")?;
1414

@@ -35,7 +35,7 @@ use rustecal::{Ecal, EcalComponents, TypedSubscriber};
3535
use rustecal_types_bytes::BytesMessage;
3636

3737
fn main() -> Result<(), Box<dyn std::error::Error>> {
38-
Ecal::initialize(Some("blob subscriber"), EcalComponents::DEFAULT)?;
38+
Ecal::initialize(Some("blob subscriber"), EcalComponents::DEFAULT, None)?;
3939

4040
let mut subscriber = TypedSubscriber::<BytesMessage>::new("blob")?;
4141
subscriber.set_callback(|message| {

docs/src/examples/json.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ struct MyData {
1414
}
1515

1616
fn main() -> Result<(), Box<dyn std::error::Error>> {
17-
Ecal::initialize(Some("json publisher"), EcalComponents::DEFAULT)?;
17+
Ecal::initialize(Some("json publisher"), EcalComponents::DEFAULT, None)?;
1818

1919
let publisher = TypedPublisher::<JsonMessage<MyData>>::new("hello_json")?;
2020

@@ -45,7 +45,7 @@ struct MyData {
4545
}
4646

4747
fn main() -> Result<(), Box<dyn std::error::Error>> {
48-
Ecal::initialize(Some("json subscriber"), EcalComponents::DEFAULT)?;
48+
Ecal::initialize(Some("json subscriber"), EcalComponents::DEFAULT, None)?;
4949

5050
let mut subscriber = TypedSubscriber::<JsonMessage<MyData>>::new("hello_json")?;
5151
subscriber.set_callback(|message| {

docs/src/examples/logging.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ use std::{thread, time::Duration};
99

1010
fn main() -> Result<(), Box<dyn std::error::Error>> {
1111
// Initialize only the logging subsystem
12-
Ecal::initialize(Some("logging_receive_sample"), EcalComponents::LOGGING)?;
12+
Ecal::initialize(Some("logging_receive_sample"), EcalComponents::LOGGING, None)?;
1313

1414
while Ecal::ok() {
1515
let entries = Log::get_logging()?;

docs/src/examples/monitoring.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ use std::{thread, time::Duration};
99

1010
fn main() -> Result<(), Box<dyn std::error::Error>> {
1111
// Initialize only the monitoring subsystem
12-
Ecal::initialize(Some("monitoring_receive_sample"), EcalComponents::MONITORING)?;
12+
Ecal::initialize(Some("monitoring_receive_sample"), EcalComponents::MONITORING, None)?;
1313

1414
while Ecal::ok() {
1515
let snap = Monitoring::get_snapshot()?;

docs/src/examples/protobuf.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ use people::Person;
1515
impl IsProtobufType for Person {}
1616

1717
fn main() -> Result<(), Box<dyn std::error::Error>> {
18-
Ecal::initialize(Some("protobuf publisher"), EcalComponents::DEFAULT)?;
18+
Ecal::initialize(Some("protobuf publisher"), EcalComponents::DEFAULT, None)?;
1919

2020
let publisher = TypedPublisher::<ProtobufMessage<Person>>::new("person")?;
2121

@@ -47,7 +47,7 @@ use people::Person;
4747
impl IsProtobufType for Person {}
4848

4949
fn main() -> Result<(), Box<dyn std::error::Error>> {
50-
Ecal::initialize(Some("protobuf subscriber"), EcalComponents::DEFAULT)?;
50+
Ecal::initialize(Some("protobuf subscriber"), EcalComponents::DEFAULT, None)?;
5151

5252
let mut subscriber = TypedSubscriber::<ProtobufMessage<Person>>::new("person")?;
5353
subscriber.set_callback(|message| {

docs/src/examples/service_client.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ This example demonstrates how to call a **Mirror Service** using `rustecal`.
88
use rustecal::{Ecal, EcalComponents, ServiceClient, ServiceRequest};
99

1010
fn main() -> Result<(), Box<dyn std::error::Error>> {
11-
Ecal::initialize(Some("mirror_client"), EcalComponents::DEFAULT)?;
11+
Ecal::initialize(Some("mirror_client"), EcalComponents::DEFAULT, None)?;
1212

1313
let client = ServiceClient::new("mirror_service")?;
1414

docs/src/examples/service_server.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ use rustecal::{Ecal, EcalComponents, ServiceServer};
1111
use rustecal::service::types::MethodInfo;
1212

1313
fn main() -> Result<(), Box<dyn std::error::Error>> {
14-
Ecal::initialize(Some("mirror_server"), EcalComponents::DEFAULT)?;
14+
Ecal::initialize(Some("mirror_server"), EcalComponents::DEFAULT, None)?;
1515

1616
let mut server = ServiceServer::new("mirror_service")?;
1717

docs/src/examples/string.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ use rustecal::{Ecal, EcalComponents, TypedPublisher};
88
use rustecal_types_string::StringMessage;
99

1010
fn main() -> Result<(), Box<dyn std::error::Error>> {
11-
Ecal::initialize(Some("string publisher"), EcalComponents::DEFAULT)?;
11+
Ecal::initialize(Some("string publisher"), EcalComponents::DEFAULT, None)?;
1212

1313
let publisher = TypedPublisher::<StringMessage>::new("hello")?;
1414

@@ -31,7 +31,7 @@ use rustecal::{Ecal, EcalComponents, TypedSubscriber};
3131
use rustecal_types_string::StringMessage;
3232

3333
fn main() -> Result<(), Box<dyn std::error::Error>> {
34-
Ecal::initialize(Some("string subscriber"), EcalComponents::DEFAULT)?;
34+
Ecal::initialize(Some("string subscriber"), EcalComponents::DEFAULT, None)?;
3535

3636
let mut subscriber = TypedSubscriber::<StringMessage>::new("hello")?;
3737
subscriber.set_callback(|message| {

0 commit comments

Comments
 (0)