MCPcopy Create free account

hub / github.com/eclipse-kuksa/kuksa-databroker / functions

Functions731 in github.com/eclipse-kuksa/kuksa-databroker

⨍ Functions 731◇ Types & classes 164↳ Endpoints 6
↓ 1 callersFunctionfind_common_root
(paths: Vec<String>)
lib/common/src/conversion.rs:28
↓ 1 callersMethodfind_messages
(self, *, subscription_id : str = None, request_id : RequestId = N
integration_test/viss/tests/test_steps/http_viss_client.py:87
↓ 1 callersMethodfind_messages
(self, *, subscription_id : str = None, request_id : RequestId = N
integration_test/viss/tests/test_steps/websockets_viss_client.py:105
↓ 1 callersMethodfind_messages
(self, *, subscription_id : str = None, request_id : RequestId = N
integration_test/viss/tests/test_steps/mqtt_viss_client.py:171
↓ 1 callersFunctiongenerate_metadata
( db: &AuthorizedAccess<'_, '_>, path: &str, )
databroker/src/viss/v2/server.rs:509
↓ 1 callersMethodget_ca_cert
(&mut self)
databroker-cli/src/cli.rs:65
↓ 1 callersMethodget_command
(&mut self)
databroker-cli/src/cli.rs:73
↓ 1 callersMethodget_commit_sha
(&self)
databroker/src/broker.rs:2425
↓ 1 callersMethodget_current_value
(&self, path: String)
databroker/tests/world/mod.rs:372
↓ 1 callersFunctionget_data_entries_from_table
( step: &Step, )
databroker/tests/read_write_values.rs:31
↓ 1 callersMethodget_datapoint_by_path
(&self, name: &str)
databroker/src/broker.rs:1434
↓ 1 callersMethodget_entry_by_path
(&self, path: impl AsRef<str>)
databroker/src/broker.rs:1141
↓ 1 callersMethodget_protocol
(&mut self)
databroker-cli/src/cli.rs:81
↓ 1 callersMethodget_server
(&mut self)
databroker-cli/src/cli.rs:77
↓ 1 callersMethodget_signals_values_from_provider
( &mut self, signals_ids: Vec<SignalId>, )
databroker/src/grpc/kuksa_val_v2/val.rs:148
↓ 1 callersMethodget_target_value
(&self, path: String)
databroker/tests/world/mod.rs:378
↓ 1 callersMethodget_token_file
(&mut self)
databroker-cli/src/cli.rs:69
↓ 1 callersMethodget_values
Returns (GRPC error code): NOT_FOUND if any of the requested signals doesn't exist. UNAUTHENTICATED if no credentials provided or credentials has expi
databroker/src/grpc/kuksa_val_v2/val.rs:247
↓ 1 callersFunctiongiven_authorized_vsspath
(authorization,path)
integration_test/viss/tests/test_steps/viss_v2_steps.py:150
↓ 1 callersMethodgreater_than_equal
(&self, other: &DataValue)
databroker/src/types.rs:290
↓ 1 callersFunctionhandle_viss_v2
( write: W, mut read: R, client_addr: SocketAddr, broker: broker::DataBroker, authorizatio
databroker/src/viss/server.rs:115
↓ 1 callersFunctionhandle_websocket
Handle websocket (one per connection)
databroker/src/viss/server.rs:77
↓ 1 callersFunctioninit_logger
()
lib/common/src/lib.rs:317
↓ 1 callersFunctioninit_logging
()
databroker/src/lib.rs:41
↓ 1 callersFunctioninit_metrics
()
databroker/src/open_telemetry.rs:58
↓ 1 callersFunctioninit_trace
()
databroker/src/open_telemetry.rs:33
↓ 1 callersFunctioninsert_entry
(entries: &mut HashMap<String, MetadataEntry>, path: &str, entry: MetadataEntry)
databroker/src/viss/v2/server.rs:541
↓ 1 callersMethodinterval_ms
(&self)
databroker/src/types.rs:513
↓ 1 callersMethodis_connected
(self)
integration_test/viss/tests/test_steps/mqtt_viss_client.py:41
↓ 1 callersFunctionis_valid_path
(input: &str)
databroker/src/glob.rs:202
↓ 1 callersFunctionis_valid_pattern
(input: &str)
databroker/src/glob.rs:176
↓ 1 callersFunctionkuksa_main
(_cli: Cli)
databroker-cli/src/kuksa_cli.rs:246
↓ 1 callersMethodless_than
(&self, other: &DataValue)
databroker/src/types.rs:297
↓ 1 callersMethodless_than_equal
(&self, other: &DataValue)
databroker/src/types.rs:301
↓ 1 callersMethodlist_metadata
(self, root_branch="Vehicle")
integration_test/provider.py:64
↓ 1 callersFunctionmain
()
integration_test/provider.py:250
↓ 1 callersMethodmake_validator
Build a `Validation` for the token's declared algorithm, constrained to the loaded key family. Returns an error if the token header is malformed or if
databroker/src/authorization/jwt/decoder.rs:105
↓ 1 callersMethodmap_actuation_changes_by_vss_id
( &self, actuation_changes: Vec<ActuationChange>, )
databroker/src/broker.rs:1717
↓ 1 callersMethodmap_entries
(&self, f: impl FnMut(EntryReadAccess) -> T)
databroker/src/broker.rs:1496
↓ 1 callersFunctionparse_v2_error
Build a best-effort error response when a single JSON object in a multi-request message cannot be deserialized. Mirrors the error path in `parse_v2_ms
databroker/src/viss/server.rs:273
↓ 1 callersFunctionparse_vss_from_reader
(reader: R)
databroker/src/vss.rs:533
↓ 1 callersFunctionprint_logo
(version: impl fmt::Display)
databroker-cli/src/cli.rs:145
↓ 1 callersMethodpropagate_new_filter_to_provider
( &self, time_interval: Option<TimeInterval>, signal_ids: Vec<SignalId>, uuid_
databroker/src/broker.rs:1999
↓ 1 callersMethodpublish_provider_error
( &self, provider_uuid: Uuid, )
databroker/src/broker.rs:2146
↓ 1 callersFunctionread_incoming_trace_id
( request: tonic::Request<proto::SetRequest>, )
databroker/src/grpc/kuksa_val_v1/val.rs:1105
↓ 1 callersFunctionread_jwt
(token_type: TokenType)
lib/kuksa_val_v2/src/lib.rs:1423
↓ 1 callersFunctionread_metadata_file
( database: &broker::AuthorizedAccess<'_, '_>, filename: &str, )
databroker/src/main.rs:153
↓ 1 callersMethodregister_signals
( &self, vss_ids_intervals: HashMap<SignalId, TimeInterval>, signal_provider: Box<dyn
databroker/src/broker.rs:2063
↓ 1 callersFunctionsample_get_signal
(client: &mut KuksaClientV2)
lib/databroker-examples/examples/kuksa_val_v2.rs:46
↓ 1 callersFunctionsample_get_signals
(client: &mut KuksaClientV2)
lib/databroker-examples/examples/kuksa_val_v2.rs:64
↓ 1 callersFunctionsample_list_metadata
(client: &mut KuksaClientV2)
lib/databroker-examples/examples/kuksa_val_v2.rs:242
↓ 1 callersFunctionsample_provide_actuation
(client: &mut KuksaClientV2)
lib/databroker-examples/examples/kuksa_val_v2.rs:113
↓ 1 callersFunctionsample_publish_value
(client: &mut KuksaClientV2)
lib/databroker-examples/examples/kuksa_val_v2.rs:97
↓ 1 callersFunctionsample_server_info
(client: &mut KuksaClientV2)
lib/databroker-examples/examples/kuksa_val_v2.rs:260
↓ 1 callersFunctionsample_subscribe
(client: &mut KuksaClientV2)
lib/databroker-examples/examples/kuksa_val_v2.rs:160
↓ 1 callersFunctionsample_subscribe_by_id
(client: &mut KuksaClientV2)
lib/databroker-examples/examples/kuksa_val_v2.rs:194
↓ 1 callersMethodsend_auth
Request credentials to be sent. Do not need to be explcitly requested if auth_first/auth_second is used
databroker/src/grpc/kuksa_val_v2/val.rs:1665
↓ 1 callersMethodsend_none_to_receiver
(&self)
databroker/src/broker.rs:1050
↓ 1 callersFunctionserve
( addr: impl Into<std::net::SocketAddr>, broker: broker::DataBroker, // #[cfg(feature = "tls")] se
databroker/src/viss/server.rs:38
↓ 1 callersFunctionserve_tcp
( addr: impl Into<std::net::SocketAddr>, broker: broker::DataBroker, #[cfg(feature = "tls")] serve
databroker/src/grpc/server.rs:106
↓ 1 callersFunctionserve_uds
( path: impl AsRef<std::path::Path>, broker: broker::DataBroker, apis: &[Api], authorization:
databroker/src/grpc/server.rs:157
↓ 1 callersMethodserver_tls_config
(&self)
databroker/tests/world/mod.rs:149
↓ 1 callersFunctionset_connected_prompt
(interface: &Arc<Interface<DefaultTerminal>>, text: String)
databroker-cli/src/cli.rs:124
↓ 1 callersMethodset_frequency
Adjusts the frequency (iterations per second) at which the stream loop checks for new messages. :param frequency: New frequen
integration_test/provider.py:76
↓ 1 callersFunctionset_value
( w: &mut DataBrokerWorld, value_type: ValueType, path: String, data_type: DataType, value
databroker/tests/read_write_values.rs:128
↓ 1 callersFunctionshutdown
(databroker: broker::DataBroker, signal: F)
databroker/src/grpc/server.rs:95
↓ 1 callersMethodshutdown
(&self)
databroker/src/broker.rs:2408
↓ 1 callersMethodstart_databroker
( &mut self, data_entries: Vec<( String, broker::DataType,
databroker/tests/world/mod.rs:195
↓ 1 callersMethodstart_housekeeping_task
(&self)
databroker/src/broker.rs:2294
↓ 1 callersMethodstop_databroker
(&mut self)
databroker/tests/world/mod.rs:351
↓ 1 callersMethodsubscribe
( &self, request: SubscribeRequest, )
databroker/src/viss/v2/server.rs:355
↓ 1 callersMethodsubscribe_by_id
Returns (GRPC error code): NOT_FOUND if any of the signals are non-existant. UNAUTHENTICATED if no credentials provided or credentials has expired PER
databroker/src/grpc/kuksa_val_v2/val.rs:404
↓ 1 callersMethodsubscribe_to_connection_state
(&mut self)
lib/common/src/lib.rs:360
↓ 1 callersFunctionto_regex
(glob: &str)
databroker/src/glob.rs:136
↓ 1 callersMethodto_status_with_code
(&self, id: &i32)
databroker/src/grpc/kuksa_val_v2/conversions.rs:356
↓ 1 callersFunctionto_uri
(uri: impl AsRef<str>)
lib/common/src/lib.rs:286
↓ 1 callersFunctiontransform_allowed
(value: &Option<broker::DataValue>)
databroker/src/grpc/kuksa_val_v2/conversions.rs:235
↓ 1 callersMethodtrigger_reading_websocket
(self)
integration_test/viss/tests/test_steps/viss_v2_steps.py:107
↓ 1 callersMethodtry_connect_to
(&mut self, uri: tonic::transport::Uri)
lib/common/src/lib.rs:420
↓ 1 callersMethodtry_into_type
(self, data_type: &broker::DataType)
databroker/src/viss/v2/conversions.rs:354
↓ 1 callersMethodupdate_entry_lag_to_be_equal
(&mut self, path: &str)
databroker/src/broker.rs:1181
↓ 1 callersMethodupdate_filter
( &self, update_filter: HashMap<SignalId, Option<TimeInterval>>, )
databroker/src/grpc/kuksa_val_v2/val.rs:105
↓ 1 callersMethoduse_name_for_second
(&mut self)
databroker/src/grpc/kuksa_val_v2/val.rs:1697
↓ 1 callersMethodvalid_provider_publish_signals
( &self, provider_uuid: Uuid, signal_request: &HashSet<SignalId>, )
databroker/src/broker.rs:2181
↓ 1 callersMethodvalidate
(&self, update: &EntryUpdate)
databroker/src/broker.rs:295
↓ 1 callersMethodvalidate_actuator_value
(&self, data_value: &DataValue)
databroker/src/broker.rs:288
↓ 1 callersFunctionvalidate_entry_update
( broker: &AuthorizedAccess<'_, '_>, request: &EntryUpdate, id: i32, )
databroker/src/grpc/kuksa_val_v1/val.rs:681
Method__init__
Initializes the gRPC channel, stub, and internal data structures.
integration_test/provider.py:30
Method__init__
(self,pytestconfig)
integration_test/viss/tests/test_steps/http_viss_client.py:27
Method__init__
(self, pytestconfig)
integration_test/viss/tests/test_steps/websockets_viss_client.py:27
Method__init__
(self,pytestconfig)
integration_test/viss/tests/test_steps/mqtt_viss_client.py:33
Method__init__
(self)
integration_test/viss/tests/test_steps/types.py:20
Method__init__
(self,pytestconfig)
integration_test/viss/tests/test_steps/viss_v2_steps.py:31
Method__init__
(self,pytestconfig)
integration_test/viss/tests/test_steps/mqtt_mock_databroker.py:27
Method_stream_loop
Runs the bidirectional streaming call in a loop. Sends messages from the queue and processes responses.
integration_test/provider.py:101
Functiona_known_data_entry_has_value
( w: &mut DataBrokerWorld, path: String, data_type: DataType, value_type: ValueType, value
databroker/tests/read_write_values.rs:98
Methodactuate
( &self, actuation_changes: Vec<broker::ActuationChange>, )
databroker/src/grpc/kuksa_val_v2/val.rs:62
Methodactuate_stream
( &self, request: tonic::Request<tonic::Streaming<proto::ActuateRequest>>, )
databroker/src/grpc/kuksa_val_v2/val.rs:480
Functionadd_filter
()
databroker/src/filter/filter_manager.rs:166
Functionassert_provider_registration_succeeds
(w: &mut DataBrokerWorld)
databroker/tests/read_write_values.rs:435
← previousnext →201–300 of 731, ranked by callers