MCPcopy Index your code

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

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

⨍ Functions 731◇ Types & classes 164↳ Endpoints 6
↓ 72 callersMethodauthorized_access
( &'a self, permissions: &'b Permissions, )
databroker/src/broker.rs:2284
↓ 66 callersMethodadd_entry
( &self, name: String, data_type: DataType, change_type: ChangeType, e
databroker/src/broker.rs:1373
↓ 36 callersMethodupdate_entries
( &self, updates: impl IntoIterator<Item = (i32, EntryUpdate)>, )
databroker/src/broker.rs:1522
↓ 33 callersFunctionexpect_status_code
(err: ClientError, code: tonic::Code)
lib/kuksa_val_v2/src/lib.rs:1414
↓ 33 callersMethodmetadata
(&self)
databroker/src/broker.rs:1087
↓ 31 callersMethodsend
(self, request_id,message,authorization=None)
integration_test/viss/tests/test_steps/viss_v2_steps.py:64
↓ 27 callersMethodget
( &mut self, path: &str, view: proto::v1::View, _fields: Vec<i32>, )
lib/kuksa/src/lib.rs:66
↓ 27 callersFunctiontry_from_json_value
Try to extract a value matching the given DataType. Will success if the value is None or a a value of matching type Will fail if the value does not ma
databroker/src/vss.rs:263
↓ 24 callersMethodfind_message
(self, *, subscription_id=None, request_id=None,
integration_test/viss/tests/test_steps/viss_v2_steps.py:78
↓ 23 callersMethodget
(&self, request: GetRequest)
databroker/src/viss/v2/server.rs:92
↓ 22 callersMethodas_ref
(&self)
databroker/src/viss/v2/types.rs:518
↓ 22 callersMethodnext
(&mut self)
databroker/src/broker.rs:1116
↓ 16 callersMethodget_channel
(&mut self)
lib/common/src/lib.rs:426
↓ 16 callersMethodget_id_by_path
(&self, name: &str)
databroker/src/broker.rs:1414
↓ 16 callersFunctionparse_whitespace_separated
(scope: &str)
databroker/src/authorization/jwt/scope.rs:33
↓ 15 callersMethodbuild
(&self)
databroker/src/grpc/kuksa_val_v2/val.rs:1714
↓ 15 callersMethodget_datapoint
(&self, id: i32)
databroker/src/broker.rs:1424
↓ 15 callersMethodnew
(self)
integration_test/viss/tests/test_steps/types.py:22
↓ 15 callersFunctionprint_error
(operation: impl AsRef<str>, msg: impl AsRef<str>)
databroker-cli/src/cli.rs:289
↓ 14 callersMethodcurrent
(self)
integration_test/viss/tests/test_steps/types.py:25
↓ 14 callersMethodget_auth_interceptor
( &mut self, )
lib/common/src/lib.rs:437
↓ 13 callersMethodauthorized_read_access
( &'a self, permissions: &'b Permissions, )
databroker/src/broker.rs:1344
↓ 13 callersMethodget_entry_by_id
(&self, id: i32)
databroker/src/broker.rs:1130
↓ 13 callersFunctiontest_get_values_combo
(config: GetValuesConfig)
databroker/src/grpc/kuksa_val_v2/val.rs:1729
↓ 12 callersFunctionget_array_from_input
(values: String)
databroker-cli/src/cli.rs:333
↓ 12 callersMethodis_match
(&self, path: &str)
databroker/src/glob.rs:56
↓ 12 callersFunctionpublish_value
( broker: &DataBroker, entry_id: i32, input_value: Option<bool>, input_timesta
databroker/src/grpc/kuksa_val_v2/val.rs:2197
↓ 12 callersMethodpublish_value
Publish a signal value. Used for low frequency signals (e.g. attributes). Returns (GRPC error code): NOT_FOUND if any of the signals are non-existant
lib/kuksa_val_v2/src/lib.rs:291
↓ 12 callersMethodrequest_first
(&mut self)
databroker/src/grpc/kuksa_val_v2/val.rs:1670
↓ 11 callersMethodfirst_exist
(&mut self)
databroker/src/grpc/kuksa_val_v2/val.rs:1680
↓ 11 callersMethodid
(&self)
databroker/src/types.rs:499
↓ 11 callersFunctionserialize
(response: impl v2::Response)
databroker/src/viss/server.rs:288
↓ 11 callersMethodsubscribe
( &self, valid_entries: HashMap<i32, HashSet<Field>>, buffer_size: Option<usize>,
databroker/src/broker.rs:1594
↓ 11 callersMethodvalidate_value_min_max
Checks if value fulfils min/max condition Returns OutOfBounds if not fulfilled
databroker/src/broker.rs:490
↓ 10 callersMethodadd_new_update_filter
Add a new filter to each signal_id in the database and returns the new update filter map containing ONLY signals_ids along with their new lowest inter
databroker/src/filter/filter_manager.rs:50
↓ 10 callersMethodas_string
(&self)
databroker/src/glob.rs:68
↓ 10 callersMethodconvert_to_v2
(self)
lib/common/src/conversion.rs:441
↓ 10 callersMethodrequest_second
(&mut self)
databroker/src/grpc/kuksa_val_v2/val.rs:1692
↓ 9 callersMethodauth_first
Request credentials and include credentials for signal 1
databroker/src/grpc/kuksa_val_v2/val.rs:1686
↓ 9 callersFunctionhelper_add_int32
Helper for adding an int32 signal and adding value
databroker/src/broker.rs:3040
↓ 9 callersMethodis_expired
(&self)
databroker/src/permissions.rs:228
↓ 9 callersMethodsecond_exist
(&mut self)
databroker/src/grpc/kuksa_val_v2/val.rs:1702
↓ 8 callersFunctiondisplay_array
(f: &mut fmt::Formatter<'_>, array: &[T])
databroker-cli/src/kuksa_cli.rs:933
↓ 8 callersMethodfor_each_entry
(&self, f: impl FnMut(EntryReadAccess))
databroker/src/broker.rs:1486
↓ 8 callersMethodis_connected
(self)
integration_test/viss/tests/test_steps/http_viss_client.py:33
↓ 8 callersFunctionprint_info
(info: impl AsRef<str>)
databroker-cli/src/cli.rs:280
↓ 8 callersFunctionprint_usage
(command: impl AsRef<str>)
databroker-cli/src/kuksa_cli.rs:63
↓ 8 callersMethodprovide_actuation
( &self, vss_ids: Vec<i32>, actuation_provider: Box<dyn ActuationProvider + Send + Syn
databroker/src/broker.rs:1675
↓ 7 callersMethodauth_second
Request credentials and include credentials for signal 2
databroker/src/grpc/kuksa_val_v2/val.rs:1708
↓ 7 callersMethodcomplete_entry_path
(&self, word: &str)
databroker-cli/src/kuksa_cli.rs:807
↓ 7 callersMethodconvert_to_v1
(self)
lib/common/src/conversion.rs:59
↓ 7 callersMethoddatapoint
(&self)
databroker/src/broker.rs:1072
↓ 7 callersMethodget_value
Get the latest value of a signal If the signal exist but does not have a valid value a DataPoint where value is None shall be returned. Returns (GRPC
lib/kuksa_val_v2/src/lib.rs:215
↓ 7 callersMethodget_value
Returns (GRPC error code): NOT_FOUND if the requested signal doesn't exist UNAUTHENTICATED if no credentials provided or credentials has expired PERMI
databroker/src/grpc/kuksa_val_v2/val.rs:202
↓ 7 callersFunctionhandle_get_metadata
( paths: Vec<&str>, client: &mut KuksaClient, )
databroker-cli/src/kuksa_cli.rs:71
↓ 7 callersMethodis_match
(&self, path: &str)
databroker/src/permissions.rs:240
↓ 7 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_v2/val.rs:1341
↓ 6 callersMethodactuate
Actuate a single actuator Returns (GRPC error code): NOT_FOUND if the actuator does not exist. PERMISSION_DENIED if access is denied for the actuator
lib/kuksa_val_v2/src/lib.rs:340
↓ 6 callersMethodbatch_actuate
Actuate simultaneously multiple actuators. If any error occurs, the entire operation will be aborted and no single actuator value will be forwarded to
lib/kuksa_val_v2/src/lib.rs:381
↓ 6 callersMethoddecode
(&self, token: impl AsRef<str>)
databroker/src/authorization/jwt/decoder.rs:125
↓ 6 callersMethodget_values
Get the latest values of a set of signals. The returned list of data points has the same order as the list of the request. If a requested signal has n
lib/kuksa_val_v2/src/lib.rs:250
↓ 6 callersFunctionhelper_add_doublearray
Helper for adding an double array signal and adding value
databroker/src/broker.rs:3447
↓ 6 callersFunctionhelper_add_int32array
Helper for adding an int32 signal and adding value
databroker/src/broker.rs:3322
↓ 6 callersMethodlist_metadata
List metadata of signals matching the request. Returns (GRPC error code): NOT_FOUND if the specified root branch does not exist. UNAUTHENTICATED if n
lib/kuksa_val_v2/src/lib.rs:539
↓ 6 callersFunctionprint_resp_err
(operation: impl AsRef<str>, err: &tonic::Status)
databroker-cli/src/cli.rs:228
↓ 6 callersFunctionprint_resp_err_fmt
(operation: impl AsRef<str>, fmt: fmt::Arguments<'_>)
databroker-cli/src/cli.rs:244
↓ 6 callersFunctionprint_resp_ok
(operation: impl AsRef<str>)
databroker-cli/src/cli.rs:263
↓ 6 callersMethodsubscribe
( &mut self, paths: Self::SubscribeType, )
lib/kuksa_val_v2/src/lib.rs:150
↓ 6 callersMethodto_tonic_status
(&self, message: String)
databroker/src/grpc/kuksa_val_v2/conversions.rs:525
↓ 6 callersFunctiontry_from_json_single_value
Try to extract a single value matching the given DataType, i.e. if an array type is given it will try to find a single value of the base type For exam
databroker/src/vss.rs:368
↓ 5 callersFunctioncheck_stream_next
( item: &Result<proto::SubscribeResponse, tonic::Status>, input_value: Option<bool>,
databroker/src/grpc/kuksa_val_v2/val.rs:2246
↓ 5 callersFunctioncheck_stream_next_by_id
( item: &Result<proto::SubscribeByIdResponse, tonic::Status>, input_value: Option<bool
databroker/src/grpc/kuksa_val_v2/val.rs:2398
↓ 5 callersMethodget
( &self, request: tonic::Request<proto::GetRequest>, )
databroker/src/grpc/kuksa_val_v1/val.rs:43
↓ 5 callersMethodget_metadata
(&self, id: i32)
databroker/src/broker.rs:1445
↓ 5 callersFunctionget_signal
( signal_id: Option<proto::SignalId>, broker: &AuthorizedAccess<'_, '_>, )
databroker/src/grpc/kuksa_val_v2/val.rs:1242
↓ 5 callersMethodset_access_token
(&mut self, token: impl AsRef<str>)
lib/common/src/lib.rs:346
↓ 5 callersMethodset_current_values
( &mut self, datapoints: Self::SensorUpdateType, )
lib/kuksa/src/lib.rs:122
↓ 5 callersMethodsubscribe
( &mut self, paths: Self::SubscribeType, )
lib/kuksa/src/lib.rs:258
↓ 5 callersMethodsubscribe_by_id
Subscribe to a set of signals using i32 id parameters Returns (GRPC error code): NOT_FOUND if any of the signals are non-existant. UNAUTHENTICATED if
lib/kuksa_val_v2/src/lib.rs:458
↓ 4 callersMethodadd_read_permission
(mut self, permission: Permission)
databroker/src/permissions.rs:107
↓ 4 callersMethodcan_write_actuator_target
( &self, vss_id: &i32, )
databroker/src/broker.rs:1841
↓ 4 callersMethodconnect
(self)
integration_test/viss/tests/test_steps/viss_v2_steps.py:50
↓ 4 callersMethodextend_with
(&mut self, other: PathMatchBuilder)
databroker/src/permissions.rs:250
↓ 4 callersMethodextend_with_glob
(&mut self, glob: String)
databroker/src/permissions.rs:277
↓ 4 callersMethodfind_subscription_id_by_request_id
(self, request_id)
integration_test/viss/tests/test_steps/viss_v2_steps.py:70
↓ 4 callersMethodget_lowest_filter_interval_per_signal
Returns a HashMap containing each signal_id present in the map, along with its corresponding lowest associated filter.
databroker/src/filter/filter_manager.rs:34
↓ 4 callersMethodget_server_info
Get server information
lib/kuksa_val_v2/src/lib.rs:563
↓ 4 callersMethodget_shutdown_trigger
(&self)
databroker/src/broker.rs:2417
↓ 4 callersFunctionhelper_add_int16
Helper for adding an int8 signal and adding value
databroker/src/broker.rs:2953
↓ 4 callersFunctionhelper_add_int64
Helper for adding an int64 signal and adding value
databroker/src/broker.rs:3148
↓ 4 callersFunctionhelper_add_int8
Helper for adding an int8 signal and adding value
databroker/src/broker.rs:2866
↓ 4 callersFunctionhelper_add_uint8
Helper for adding an uint8 signal and adding value
databroker/src/broker.rs:3235
↓ 4 callersMethodis_available
(&self)
databroker/src/grpc/kuksa_val_v2/val.rs:98
↓ 4 callersMethodpublish_value
Returns (GRPC error code): NOT_FOUND if any of the signals are non-existant. PERMISSION_DENIED - if access is denied for any of the signals. UNAUTHENT
databroker/src/grpc/kuksa_val_v2/val.rs:758
↓ 4 callersMethodremove_filter_by_subscription_uuid
Remove all intervals associated to an subscription_uuid and return the new update filter map containing ONLY signals_ids along with their new lowest i
databroker/src/filter/filter_manager.rs:99
↓ 4 callersFunctionresolve_permissions
( authorization: &Authorization, token: &Option<String>, )
databroker/src/viss/v2/server.rs:490
↓ 4 callersMethodshould_match_signals
(&self, signals: &[&str])
databroker/src/glob.rs:1141
↓ 3 callersMethodadd
( &mut self, name: String, data_type: DataType, change_type: ChangeType,
databroker/src/broker.rs:1250
↓ 3 callersFunctionadd_kuksa_string_attribute
( database: &broker::AuthorizedAccess<'_, '_>, attribute: String, value: String, description:
databroker/src/main.rs:137
↓ 3 callersMethodauthorized_write_access
( &'a mut self, permissions: &'b Permissions, )
databroker/src/broker.rs:1355
next →1–100 of 731, ranked by callers