Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/eclipse-kuksa/kuksa-databroker
/ functions
Functions
731 in github.com/eclipse-kuksa/kuksa-databroker
⨍
Functions
731
◇
Types & classes
164
↳
Endpoints
6
Function
assert_request_failure
(w: &mut DataBrokerWorld, expected_status_code: i32)
databroker/tests/read_write_values.rs:259
Function
assert_set_request_failure
(w: &mut DataBrokerWorld, _path: String, expected_error_code: u32)
databroker/tests/read_write_values.rs:253
Function
assert_set_succeeds
(w: &mut DataBrokerWorld)
databroker/tests/read_write_values.rs:264
Function
assert_value
( w: &mut DataBrokerWorld, value_type: ValueType, path: String, expected_value: String, ex
databroker/tests/read_write_values.rs:202
Function
assert_value_is_unspecified
(w: &mut DataBrokerWorld, value_type: ValueType, path: String)
databroker/tests/read_write_values.rs:239
Function
assert_value_not_found
(w: &mut DataBrokerWorld)
databroker/tests/read_write_values.rs:248
Function
authorization
()
integration_test/viss/tests/test_steps/viss_v2_steps.py:141
Function
authorize_client
(w: &mut DataBrokerWorld, scope: String)
databroker/tests/read_write_values.rs:110
Method
batch_actuate
( &self, actuation_changes: Vec<ActuationChange>, )
databroker/src/broker.rs:1740
Method
batch_actuate
Actuate simultaneously multiple actuators. If any error occurs, the entire operation will be aborted and no single actuator value will be forwarded to
databroker/src/grpc/kuksa_val_v2/val.rs:647
Method
builder
()
databroker/src/permissions.rs:163
Method
call
( &mut self, mut request: tonic::Request<()>, )
databroker/src/grpc/server.rs:52
Method
can_write_actuator_target
(&self, path: &str)
databroker/src/permissions.rs:192
Method
can_write_datapoint
(&self, path: &str)
databroker/src/permissions.rs:204
Function
check_databroker_connect_http_url
(pytestconfig)
integration_test/viss/conftest.py:26
Function
claim_signal
(connected_provider, path)
integration_test/provider.py:241
Function
cleanup
()
integration_test/provider.py:228
Function
cleanup
()
integration_test/viss/tests/test_steps/viss_v2_steps.py:119
Function
client
()
integration_test/test_databroker.py:40
Function
code_to_text
(code: &tonic::Code)
databroker-cli/src/cli.rs:311
Method
complete
( &self, word: &str, prompter: &Prompter<Term>, start: usize, _end: us
databroker-cli/src/kuksa_cli.rs:876
Method
connect
(self)
integration_test/viss/tests/test_steps/http_viss_client.py:36
Method
connect
(self)
integration_test/viss/tests/test_steps/websockets_viss_client.py:36
Method
connect
(self)
integration_test/viss/tests/test_steps/mqtt_viss_client.py:80
Method
connect
(self)
integration_test/viss/tests/test_steps/mqtt_mock_databroker.py:84
Function
connected_clients
(request,pytestconfig)
integration_test/viss/tests/test_steps/viss_v2_steps.py:117
Function
connected_provider
(request,pytestconfig)
integration_test/provider.py:226
Method
convert_to_actuate_requests
(values: HashMap<String, Value>)
lib/kuksa_val_v2/src/lib.rs:69
Method
default
()
databroker/src/permissions.rs:86
Method
default
()
databroker/src/broker.rs:2431
Method
default
()
databroker/src/viss/v2/types.rs:578
Function
disconnect
(connected_provider)
integration_test/provider.py:246
Method
disconnect
(self)
integration_test/viss/tests/test_steps/http_viss_client.py:39
Method
disconnect
(self)
integration_test/viss/tests/test_steps/websockets_viss_client.py:41
Method
disconnect
(self)
integration_test/viss/tests/test_steps/mqtt_viss_client.py:104
Method
disconnect
(self)
integration_test/viss/tests/test_steps/mqtt_mock_databroker.py:103
Method
drop
(&mut self)
databroker/src/viss/v2/server.rs:69
Method
execute
(&self, prompter: &mut Prompter<Term>, count: i32, _ch: char)
databroker-cli/src/cli.rs:362
Function
extend_provided_signals
( broker: &AuthorizedAccess<'_, '_>, provider_uuid: Uuid, request: &databroker_proto::kuksa::val::
databroker/src/grpc/kuksa_val_v2/val.rs:1139
Function
extend_provider_registration
(w: &mut DataBrokerWorld, path: String)
databroker/tests/read_write_values.rs:361
Method
filter_map_entries
( &self, f: impl FnMut(EntryReadAccess) -> Option<T>, )
databroker/src/broker.rs:1507
Method
find_message
(self, *, subscription_id=None, request_id=None,
integration_test/viss/tests/test_steps/http_viss_client.py:123
Method
find_message
(self, *, subscription_id=None, request_id=None,
integration_test/viss/tests/test_steps/websockets_viss_client.py:138
Method
find_message
(self, *, subscription_id=None, request_id=None,
integration_test/viss/tests/test_steps/mqtt_viss_client.py:206
Method
find_subscription_id_by_request_id
(self, request_id)
integration_test/viss/tests/test_steps/websockets_viss_client.py:90
Method
find_subscription_id_by_request_id
(self, request_id)
integration_test/viss/tests/test_steps/mqtt_viss_client.py:155
Method
fmt
(&self, f: &mut fmt::Formatter<'_>)
databroker-cli/src/kuksa_cli.rs:949
Method
fmt
(&self, f: &mut fmt::Formatter<'_>)
databroker-cli/src/cli.rs:31
Method
fmt
(&self, f: &mut std::fmt::Formatter<'_>)
lib/common/src/lib.rs:250
Method
fmt
(&self, f: &mut std::fmt::Formatter<'_>)
databroker-proto/src/lib.rs:42
Method
fmt
(&self, f: &mut fmt::Formatter)
databroker/src/vss.rs:160
Method
fmt
(&self, f: &mut fmt::Formatter)
databroker/src/types.rs:45
Method
fmt
(&self, f: &mut std::fmt::Formatter<'_>)
databroker/src/authorization/jwt/decoder.rs:32
Method
fmt
(&self, f: &mut std::fmt::Formatter<'_>)
databroker/src/viss/v2/conversions.rs:404
Method
fmt
(&self, f: &mut std::fmt::Formatter<'_>)
databroker/tests/world/mod.rs:35
Method
from
(input: Option<proto::v1::EntryType>)
databroker-cli/src/kuksa_cli.rs:975
Method
from
(from: serde_json::Error)
databroker/src/vss.rs:168
Method
from
(datapoint: &proto::Datapoint)
databroker/src/grpc/kuksa_val_v2/conversions.rs:25
Method
from
(from: &broker::EntryType)
databroker/src/grpc/kuksa_val_v1/conversions.rs:22
Method
from
(error: Error)
databroker/src/viss/v2/types.rs:424
Method
from
(abort_handle: AbortHandle)
databroker/src/viss/v2/server.rs:63
Method
from
(dp: broker::Datapoint)
databroker/src/viss/v2/conversions.rs:27
Method
from_host
(host: &'static str)
lib/kuksa_val_v2/src/lib.rs:42
Method
from_metadata
(entries: &Vec<proto::v1::DataEntry>)
databroker-cli/src/kuksa_cli.rs:782
Method
from_proto_entry_and_fields
( entry: &proto::DataEntry, fields: HashSet<proto::Field>, )
databroker/src/grpc/kuksa_val_v1/val.rs:1120
Method
from_str
(s: &str)
databroker-proto/src/lib.rs:51
Method
from_str
(s: &str)
databroker/tests/world/mod.rs:91
Method
get_current_values
( &mut self, paths: Self::PathType, )
lib/kuksa_val_v2/src/lib.rs:109
Method
get_metadata
( &mut self, paths: Self::PathType, )
lib/kuksa_val_v2/src/lib.rs:172
Method
get_metadata
( &mut self, paths: Self::PathType, )
lib/kuksa/src/lib.rs:295
Method
get_server_info
( &self, _request: tonic::Request<proto::GetServerInfoRequest>, )
databroker/src/grpc/kuksa_val_v2/val.rs:1013
Method
get_server_info
( &self, _request: tonic::Request<proto::GetServerInfoRequest>, )
databroker/src/grpc/kuksa_val_v1/val.rs:669
Method
get_target_values
( &mut self, _paths: Self::PathType, )
lib/kuksa_val_v2/src/lib.rs:130
Method
get_uri
(&self)
lib/common/src/lib.rs:337
Function
get_value
(w: &mut DataBrokerWorld, value_type: ValueType, path: String)
databroker/tests/read_write_values.rs:178
Function
given_authorized
(authorization)
integration_test/viss/tests/test_steps/viss_v2_steps.py:146
Function
glob_string_match
(glob: &str, path: &str)
databroker/src/glob.rs:141
Function
grpc_kuksa_provider_via_grpc
(connected_provider)
integration_test/provider.py:234
Function
handle_upgrade
Handle upgrade request
databroker/src/viss/server.rs:66
Function
http_client
(connected_clients)
integration_test/viss/tests/test_steps/viss_v2_steps.py:125
Method
httpclient
(self)
integration_test/viss/tests/test_steps/viss_v2_steps.py:41
Method
is_connected
(self)
integration_test/viss/tests/test_steps/websockets_viss_client.py:33
Function
main
()
databroker-cli/src/main.rs:21
Function
main
()
lib/databroker-examples/examples/kuksa_val_v2.rs:28
Function
main
()
lib/databroker-examples/examples/slow_subscriber.rs:21
Function
main
()
databroker-proto/build.rs:16
Function
main
Extract build info (at build time)
databroker/build.rs:22
Function
main
()
databroker/src/main.rs:232
Function
main
()
databroker/tests/read_write_values.rs:442
Function
mqtt_client
(connected_clients)
integration_test/viss/tests/test_steps/viss_v2_steps.py:133
Method
mqttclient
(self)
integration_test/viss/tests/test_steps/viss_v2_steps.py:47
Method
new
()
databroker-cli/src/kuksa_cli.rs:767
Method
new
(uri: Uri)
lib/kuksa_val_v2/src/lib.rs:36
Method
new
( sender: tokio::sync::mpsc::Sender<protoV2::OpenProviderStreamRequest>, receiver_stream: toni
lib/common/src/types.rs:67
Method
new
(uri: Uri)
lib/common/src/lib.rs:324
Method
new
(uri: Uri)
lib/kuksa/src/lib.rs:27
Method
new
(message: T)
databroker-proto/src/lib.rs:34
Method
new
()
databroker/src/permissions.rs:92
Method
new
(glob_pattern: &str)
databroker/src/glob.rs:34
Method
new
(id: i32)
databroker/src/types.rs:496
← previous
next →
301–400 of 731, ranked by callers