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
↓ 3 callersMethodbuild
(self)
databroker/src/permissions.rs:151
↓ 3 callersMethodcan_write_datapoint
( &self, signal_id: &SignalId, )
databroker/src/broker.rs:1878
↓ 3 callersFunctiondetermine_change_type
( change_type: Option<ChangeType>, entry_type: types::EntryType, )
databroker/src/vss.rs:513
↓ 3 callersMethoddisconnect
(self)
integration_test/provider.py:59
↓ 3 callersMethodfind_messages
(self, *, subscription_id : str = None, request_id : RequestId = N
integration_test/viss/tests/test_steps/viss_v2_steps.py:93
↓ 3 callersFunctionflatten_vss_tree
(root: RootEntry)
databroker/src/vss.rs:400
↓ 3 callersMethodget_current_data_entry
(&self, path: String)
databroker/tests/world/mod.rs:366
↓ 3 callersMethoditer_entries
(&self)
databroker/src/broker.rs:1160
↓ 3 callersMethodopen_provider_stream
Open a stream used to provide actuation and/or publishing values using a streaming interface. Used to provide actuators and to enable high frequency u
lib/kuksa_val_v2/src/lib.rs:511
↓ 3 callersMethodresolve_ids_for_paths
Resolves the databroker ids for the specified list of paths and returns them in a HashMap<String, i32> Returns (GRPC error code): NOT_FOUND if the sp
lib/kuksa_val_v2/src/lib.rs:53
↓ 3 callersFunctionserve_with_incoming_shutdown
( incoming: I, broker: broker::DataBroker, #[cfg(feature = "tls")] server_tls: ServerTLS, apis
databroker/src/grpc/server.rs:190
↓ 3 callersFunctionsplit_first_word
(s: &str)
databroker-cli/src/cli.rs:302
↓ 3 callersFunctiontest_subscribe_and_get_buffer_size
(buffer_size: Option<usize>)
databroker/src/broker.rs:4581
↓ 3 callersFunctionto_uri
(uri: impl AsRef<str>)
databroker-cli/src/cli.rs:385
↓ 3 callersMethodtry_connect
(&mut self)
lib/common/src/lib.rs:415
↓ 3 callersMethodtry_create_channel
(&mut self)
lib/common/src/lib.rs:371
↓ 3 callersFunctiontry_from_json_array
Try to extract an array matching the given DataType. Will success if the value is None or a an array of matching type Will fail if the value is a "sin
databroker/src/vss.rs:210
↓ 3 callersMethodunsubscribe
( &self, request: UnsubscribeRequest, )
databroker/src/viss/v2/server.rs:425
↓ 3 callersMethodvalidate_allowed
(&self, value: &DataValue)
databroker/src/broker.rs:357
↓ 3 callersMethodvalidate_value
(&self, value: &DataValue)
databroker/src/broker.rs:510
↓ 3 callersFunctionwrite_resp_ok
(output: &mut impl Write, operation: impl AsRef<str>)
databroker-cli/src/cli.rs:270
↓ 2 callersFunction_split_address
(address: str)
integration_test/test_databroker.py:34
↓ 2 callersMethodadd_actuate_permission
(mut self, permission: Permission)
databroker/src/permissions.rs:118
↓ 2 callersMethodadd_create_permission
(mut self, permission: Permission)
databroker/src/permissions.rs:140
↓ 2 callersFunctionadd_kuksa_bool_attribute
( database: &broker::AuthorizedAccess<'_, '_>, attribute: String, value: String, description:
databroker/src/main.rs:116
↓ 2 callersFunctionadd_kuksa_entry
( database: &broker::AuthorizedAccess<'_, '_>, attribute: String, data_type: databroker::broker::D
databroker/src/main.rs:54
↓ 2 callersMethodadd_provide_permission
(mut self, permission: Permission)
databroker/src/permissions.rs:129
↓ 2 callersMethodassert_response_has_error_code
(&self, error_codes: Vec<u32>)
databroker/tests/world/mod.rs:398
↓ 2 callersMethodassert_set_succeeded
(&self)
databroker/tests/world/mod.rs:421
↓ 2 callersMethodcan_read
(&self, path: &str)
databroker/src/permissions.rs:167
↓ 2 callersMethodcleanup
(&mut self)
databroker/src/broker.rs:850
↓ 2 callersMethodclear
(&mut self)
databroker/src/broker.rs:844
↓ 2 callersMethodequals
(&self, other: &DataValue)
databroker/src/types.rs:308
↓ 2 callersMethodget_current_values
( &mut self, paths: Self::PathType, )
lib/kuksa/src/lib.rs:152
↓ 2 callersMethodget_metadata_by_id
(&self, id: i32)
databroker/src/broker.rs:1149
↓ 2 callersMethodget_metadata_by_path
(&self, path: &str)
databroker/src/broker.rs:1154
↓ 2 callersMethodget_target_values
( &mut self, paths: Self::PathType, )
lib/kuksa/src/lib.rs:203
↓ 2 callersMethodget_values_broker
( &self, vss_signals: Vec<SignalId>, )
databroker/src/broker.rs:2196
↓ 2 callersMethodget_version
(&self)
databroker/src/broker.rs:2421
↓ 2 callersMethodgreater_than
(&self, other: &DataValue)
databroker/src/types.rs:137
↓ 2 callersFunctionhandle_actuate_command
( path: &str, value: &str, client: &mut KuksaClient, )
databroker-cli/src/kuksa_cli.rs:100
↓ 2 callersFunctionhandle_get_command
( paths: Vec<String>, client: &mut KuksaClient, )
databroker-cli/src/kuksa_cli.rs:208
↓ 2 callersFunctionhandle_publish_command
( path: &str, value: &str, client: &mut KuksaClient, )
databroker-cli/src/kuksa_cli.rs:156
↓ 2 callersMethodis_connected
(&self)
lib/common/src/lib.rs:356
↓ 2 callersMethodlist_metadata
Returns (GRPC error code): NOT_FOUND if the specified root branch does not exist. UNAUTHENTICATED if no credentials provided or credentials has expire
databroker/src/grpc/kuksa_val_v2/val.rs:705
↓ 2 callersMethodnotify
( &self, changed: Option<&HashMap<i32, HashSet<Field>>>, db: &Database, )
databroker/src/broker.rs:817
↓ 2 callersMethodopen_provider_stream
Errors: - Provider sends ProvideActuationRequest -> Databroker returns ProvideActuationResponse Returns (GRPC error code) and closes the stream call (
databroker/src/grpc/kuksa_val_v2/val.rs:845
↓ 2 callersFunctionproto_entry_from_entry_and_fields
( entry: EntryReadAccess, fields: HashSet<proto::Field>, )
databroker/src/grpc/kuksa_val_v1/val.rs:807
↓ 2 callersMethodread_all_websocket_messages
(self)
integration_test/viss/tests/test_steps/websockets_viss_client.py:64
↓ 2 callersMethodretry_until_condition_met
(self, condition_lambda, task_lambda, interval=0.1, timeout=2)
integration_test/viss/tests/test_steps/mqtt_viss_client.py:135
↓ 2 callersMethodsend_provide_signal
(self, signals_sample_intervals)
integration_test/provider.py:160
↓ 2 callersMethodset
(&mut self, entry: DataEntry, _fields: Vec<i32>)
lib/kuksa/src/lib.rs:33
↓ 2 callersMethodset
(&self, request: SetRequest)
databroker/src/viss/v2/server.rs:242
↓ 2 callersFunctionset_disconnected_prompt
(interface: &Arc<Interface<DefaultTerminal>>)
databroker-cli/src/cli.rs:135
↓ 2 callersMethodset_target_values
( &mut self, datapoints: Self::UpdateActuationType, )
lib/kuksa/src/lib.rs:265
↓ 2 callersMethodset_tls_config
(&mut self, tls_config: tonic::transport::ClientTlsConfig)
lib/common/src/lib.rs:342
↓ 2 callersFunctionshutdown_handler
()
databroker/src/main.rs:40
↓ 2 callersMethodstart_stream
(self)
integration_test/provider.py:131
↓ 2 callersMethodstreamed_update
( &self, request: tonic::Request<Streaming<proto::StreamedUpdateRequest>>, )
databroker/src/grpc/kuksa_val_v1/val.rs:340
↓ 2 callersFunctionstreaming_request
Create a `tonic::Request<Streaming<T>>` from a vec of protobuf messages, for use in tests that call streaming gRPC methods directly.
databroker/src/grpc/kuksa_val_v1/val.rs:1163
↓ 2 callersMethodsubscribe
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:319
↓ 2 callersMethodsubscribe_current_values
( &mut self, paths: Self::SubscribeType, )
lib/kuksa/src/lib.rs:229
↓ 2 callersFunctiontest_subscribe_case
Test subscribe service method */
databroker/src/grpc/kuksa_val_v2/val.rs:2245
↓ 2 callersFunctiontest_subscribe_case_by_id
Test subscribe service method by id */
databroker/src/grpc/kuksa_val_v2/val.rs:2397
↓ 2 callersFunctionto_regex_string
(glob: &str)
databroker/src/glob.rs:88
↓ 2 callersFunctiontransform_min_max
(value: &Option<broker::DataValue>)
databroker/src/grpc/kuksa_val_v2/conversions.rs:255
↓ 2 callersFunctiontry_into_data_value
( input: &str, data_type: proto::v1::DataType, )
databroker-cli/src/kuksa_cli.rs:1004
↓ 2 callersFunctionunlink_unix_domain_socket
(path: impl AsRef<Path>)
databroker/src/main.rs:223
↓ 2 callersMethodupdate
(&mut self, id: i32, update: EntryUpdate)
databroker/src/broker.rs:1195
↓ 2 callersMethoduse_name_for_first
(&mut self)
databroker/src/grpc/kuksa_val_v2/val.rs:1675
↓ 2 callersMethodvalidate_actuator_update
( &self, vss_id: &i32, data_value: &DataValue, )
databroker/src/broker.rs:1912
↓ 2 callersMethodvalidate_allowed_type
(&self, allowed: &Option<DataValue>)
databroker/src/broker.rs:317
↓ 1 callersMethod_get_queued_message
Get queued message
integration_test/provider.py:88
↓ 1 callersMethodactuate
( &self, vss_id: &i32, data_value: &DataValue, )
databroker/src/broker.rs:1795
↓ 1 callersMethodactuator_target
(&self)
databroker/src/broker.rs:1079
↓ 1 callersMethodadd_actuation_subscription
(&mut self, subscription: ActuationSubscription)
databroker/src/broker.rs:782
↓ 1 callersMethodadd_change_subscription
(&mut self, subscription: ChangeSubscription)
databroker/src/broker.rs:787
↓ 1 callersFunctionadd_entry
( entries: &mut BTreeMap<String, DataEntry>, path: String, entry: Entry, )
databroker/src/vss.rs:409
↓ 1 callersMethodadd_signal_provider_subscription
( &mut self, subscription: SignalProviderSubscription, )
databroker/src/broker.rs:793
↓ 1 callersMethodapply
(&mut self, update: EntryUpdate)
databroker/src/broker.rs:751
↓ 1 callersMethodapply_lag_after_execute
(&mut self)
databroker/src/broker.rs:746
↓ 1 callersMethodassert_status_has_code
https://github.com/grpc/grpc/blob/master/doc/statuscodes.md#status-codes-and-their-use-in-grpc
databroker/tests/world/mod.rs:385
↓ 1 callersFunctionbroadcast_drop_counter
()
databroker/src/open_telemetry.rs:96
↓ 1 callersMethodcan_create
(&self, path: &str)
databroker/src/permissions.rs:215
↓ 1 callersMethodcleanup_change_subscriptions
(&mut self)
databroker/src/broker.rs:885
↓ 1 callersMethodcleanup_signal_providers_subscriptions
(&mut self)
databroker/src/broker.rs:865
↓ 1 callersMethodclient_tls_config
(&self)
databroker/tests/world/mod.rs:156
↓ 1 callersFunctioncollect
()
integration_test/test_databroker.py:141
↓ 1 callersFunctioncombine_view_and_fields
( view: proto::View, fields: impl IntoIterator<Item = proto::Field>, )
databroker/src/grpc/kuksa_val_v1/val.rs:1062
↓ 1 callersFunctionconvert_to_data_entry_error
(path: &String, error: &broker::UpdateError)
databroker/src/grpc/kuksa_val_v1/val.rs:714
↓ 1 callersFunctionconvert_to_proto_stream
( input: impl Stream<Item = Option<broker::EntryUpdates>>, size: usize, )
databroker/src/grpc/kuksa_val_v2/val.rs:1273
↓ 1 callersFunctionconvert_to_proto_stream
( input: impl Stream<Item = Option<broker::EntryUpdates>>, )
databroker/src/grpc/kuksa_val_v1/val.rs:784
↓ 1 callersFunctionconvert_to_proto_stream_id
( input: impl Stream<Item = Option<broker::EntryUpdates>>, size: usize, )
databroker/src/grpc/kuksa_val_v2/val.rs:1302
↓ 1 callersFunctionconvert_to_viss_stream
( subscription_id: SubscriptionId, stream: impl Stream<Item = Option<broker::EntryUpdates>>, )
databroker/src/viss/v2/server.rs:450
↓ 1 callersMethodcreate_token
(&self, scope: String)
databroker/tests/world/mod.rs:437
↓ 1 callersMethoddiff
(&self, mut update: EntryUpdate)
databroker/src/broker.rs:269
↓ 1 callersMethoddisconnect
(self)
integration_test/viss/tests/test_steps/viss_v2_steps.py:57
↓ 1 callersMethodexpires_at
(mut self, expiration: SystemTime)
databroker/src/permissions.rs:102
↓ 1 callersMethodextend_provider_signals
(&mut self, vss_ids_intervals: HashMap<SignalId, TimeInterval>)
databroker/src/broker.rs:905
↓ 1 callersMethodextend_signals
( &mut self, porvider_uuid: Uuid, vss_ids_intervals: HashMap<SignalId, TimeInterval>,
databroker/src/broker.rs:803
← previousnext →101–200 of 731, ranked by callers