Functions — github.com/eclipse-kuksa/kuksa-databroker

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

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

⨍ Functions 731◇ Types & classes 164↳ Endpoints 6

Methodnew

(entry: &'a Entry, permissions: &Permissions)

databroker/src/broker.rs:1096

Methodnew

()

databroker/src/grpc/kuksa_val_v2/val.rs:1649

Methodnew

(public_key: String)

databroker/src/authorization/mod.rs:32

Methodnew

Create a Decoder from a PEM-encoded public key. Supported formats: - RSA: SPKI (`BEGIN PUBLIC KEY`) or PKCS#1 (`BEGIN RSA PUBLIC KEY`) — RS256/RS384/

databroker/src/authorization/jwt/decoder.rs:78

Methodnew

()

databroker/src/viss/v2/types.rs:572

Methodnew

(broker: broker::DataBroker, authorization: Authorization)

databroker/src/viss/v2/server.rs:81

Methodnew

()

databroker/tests/world/mod.rs:106

Methodnew_test_client

(token_type: Option<TokenType>)

lib/kuksa_val_v2/src/lib.rs:606

Methodon_connect

(self, client, userdata, flags, reason_code, properties)

integration_test/viss/tests/test_steps/mqtt_viss_client.py:52

Methodon_connect

(self, client, userdata, flags, reason_code, properties)

integration_test/viss/tests/test_steps/mqtt_mock_databroker.py:37

Methodon_message

(self, client, userdata, message)

integration_test/viss/tests/test_steps/mqtt_viss_client.py:58

Methodon_message

(self, client, userdata, message)

integration_test/viss/tests/test_steps/mqtt_mock_databroker.py:43

Methodon_subscribe

(self, client, userdata, mid, reason_code_list, properties)

integration_test/viss/tests/test_steps/mqtt_viss_client.py:44

Methodon_subscribe

(self, client, userdata, mid, reason_code_list, properties)

integration_test/viss/tests/test_steps/mqtt_mock_databroker.py:31

Methodon_unsubscribe

(self, client, userdata, mid, reason_code_list, properties)

integration_test/viss/tests/test_steps/mqtt_viss_client.py:48

Methodon_unsubscribe

(self, client, userdata, mid, reason_code_list, properties)

integration_test/viss/tests/test_steps/mqtt_mock_databroker.py:34

Functionparse_vss_from_str

(data: &str)

databroker/src/vss.rs:542

Functionprint_resp_ok_fmt

(operation: impl AsRef<str>, fmt: fmt::Arguments<'_>)

databroker-cli/src/cli.rs:254

Functionprovide_actuation

( broker: &AuthorizedAccess<'_, '_>, request: &databroker_proto::kuksa::val::v2::ProvideActuationReque

databroker/src/grpc/kuksa_val_v2/val.rs:1026

Methodprovide_actuation

( &mut self, _path: Self::PathType, )

lib/kuksa_val_v2/src/lib.rs:585

Functionpublish_provider_error

(broker: &AuthorizedAccess<'_, '_>, provide_uuid: Uuid)

databroker/src/grpc/kuksa_val_v2/val.rs:1172

Functionpublish_values

( broker: &AuthorizedAccess<'_, '_>, provider_uuid: Uuid, request: &databroker_proto::kuksa::val::

databroker/src/grpc/kuksa_val_v2/val.rs:1186

Functionpytest_addoption

(parser)

integration_test/viss/conftest.py:36

Functionreceive_any_error_response

(connected_clients,request_id)

integration_test/viss/tests/test_steps/viss_v2_steps.py:403

Functionreceive_specific_error_response

(connected_clients,request_id,error_code,error_reason)

integration_test/viss/tests/test_steps/viss_v2_steps.py:410

Functionreceive_valid_get_response

(connected_clients, request_id)

integration_test/viss/tests/test_steps/viss_v2_steps.py:347

Functionreceive_ws_list_of_server_capabilities

(connected_clients,request_id)

integration_test/viss/tests/test_steps/viss_v2_steps.py:548

Functionreceive_ws_read_expected_count

(connected_clients,request_id, subscription_id, expected_count)

integration_test/viss/tests/test_steps/viss_v2_steps.py:397

Functionreceive_ws_read_multiple_datapoints

(connected_clients,request_id)

integration_test/viss/tests/test_steps/viss_v2_steps.py:380

Functionreceive_ws_set

(connected_clients,request_id)

integration_test/viss/tests/test_steps/viss_v2_steps.py:522

Functionreceive_ws_set_error_event

(connected_clients,request_id)

integration_test/viss/tests/test_steps/viss_v2_steps.py:477

Functionreceive_ws_set_readonly_error

(connected_clients,request_id)

integration_test/viss/tests/test_steps/viss_v2_steps.py:532

Functionreceive_ws_single_value_multiple_nodes

(connected_clients,request_id)

integration_test/viss/tests/test_steps/viss_v2_steps.py:388

Functionreceive_ws_single_value_single_node

(connected_clients, request_id)

integration_test/viss/tests/test_steps/viss_v2_steps.py:367

Functionreceive_ws_subscribe

(connected_clients,request_id, subscription_id)

integration_test/viss/tests/test_steps/viss_v2_steps.py:419

Functionreceive_ws_subscribe_error_event

(connected_clients,request_id)

integration_test/viss/tests/test_steps/viss_v2_steps.py:443

Functionreceive_ws_subscription

(connected_clients,subscription_id,request_id)

integration_test/viss/tests/test_steps/viss_v2_steps.py:502

Functionreceive_ws_unsubscribe

(connected_clients,request_id)

integration_test/viss/tests/test_steps/viss_v2_steps.py:491

Methodreceived_batch_actuate_stream_request

(self, request)

integration_test/provider.py:204

Methodreceived_get_provider_value_request

(self, request)

integration_test/provider.py:218

Methodreceived_provide_actuation_response

(self, request)

integration_test/provider.py:176

Methodreceived_provide_signal_response

(self, request)

integration_test/provider.py:190

Methodreceived_publish_values_response

(self, request)

integration_test/provider.py:183

Methodreceived_update_filter_request

(self, request)

integration_test/provider.py:211

Functionregister_as_provider

(w: &mut DataBrokerWorld, path: String)

databroker/tests/read_write_values.rs:269

Functionregister_provided_signals

( broker: &AuthorizedAccess<'_, '_>, request: &databroker_proto::kuksa::val::v2::ProvideSignalRequest,

databroker/src/grpc/kuksa_val_v2/val.rs:1097

Functionremove_filter

()

databroker/src/filter/filter_manager.rs:198

Functionrequest_historical_data

(connected_clients, request_id, path, timeframe)

integration_test/viss/tests/test_steps/viss_v2_steps.py:566

Functionrequest_historical_data_multiple_nodes

(connected_clients, request_id, path, timeframe)

integration_test/viss/tests/test_steps/viss_v2_steps.py:650

Functionrequest_id

()

integration_test/viss/tests/test_steps/viss_v2_steps.py:113

Functionsearch_dynamic_metadata_filter

(connected_clients, request_id, path, filter)

integration_test/viss/tests/test_steps/viss_v2_steps.py:270

Functionsearch_history_filter

(connected_clients,request_id, path, filter)

integration_test/viss/tests/test_steps/viss_v2_steps.py:257

Functionsearch_path_filter

(connected_clients,request_id, path, filter, authorization)

integration_test/viss/tests/test_steps/viss_v2_steps.py:242

Functionsearch_static_change_filter

(connected_clients,request_id, path)

integration_test/viss/tests/test_steps/viss_v2_steps.py:325

Functionsearch_static_metadata_filter

(connected_clients, request_id, path, filter)

integration_test/viss/tests/test_steps/viss_v2_steps.py:285

Functionsearch_static_range_filter

(connected_clients,request_id, path)

integration_test/viss/tests/test_steps/viss_v2_steps.py:300

Functionsecured_server

Run the server subprocess and handle its stdout.

integration_test/viss/tests/test_steps/viss_v2_steps.py:171

Methodsend

(self, request_id, message, authorization)

integration_test/viss/tests/test_steps/http_viss_client.py:42

Methodsend

(self, request_id, message, authorization=None)

integration_test/viss/tests/test_steps/websockets_viss_client.py:44

Methodsend

(self,request_id,message,authorization)

integration_test/viss/tests/test_steps/mqtt_viss_client.py:114

Functionsend_bulk_set_request

(connected_clients, request_id, datatable)

integration_test/viss/tests/test_steps/viss_v2_steps.py:684

Methodsend_provide_actuation

(self, actuator_identifiers)

integration_test/provider.py:145

Methodsend_provider_error_indication

(self, provider_error)

integration_test/provider.py:167

Methodsend_publish_values

(self, request_id, data_points)

integration_test/provider.py:152

Functionsend_read_data_point

(connected_clients, request_id, path, authorization)

integration_test/viss/tests/test_steps/viss_v2_steps.py:237

Functionsend_set

(connected_clients, request_id, path, value)

integration_test/viss/tests/test_steps/viss_v2_steps.py:342

Functionsend_subscribe

(connected_clients, request_id, path)

integration_test/viss/tests/test_steps/viss_v2_steps.py:208

Functionsend_ws_unsubscribe

(connected_clients, request_id, subscription_id)

integration_test/viss/tests/test_steps/viss_v2_steps.py:232

Methodserialize

(&self, serializer: S)

databroker/src/viss/v2/types.rs:560

Functionserver

Run the server subprocess and handle its stdout.

integration_test/viss/tests/test_steps/viss_v2_steps.py:161

Methodset

( &self, request: tonic::Request<proto::SetRequest>, )

databroker/src/grpc/kuksa_val_v1/val.rs:261

Methodset_current_values

( &mut self, datapoints: Self::SensorUpdateType, )

lib/kuksa_val_v2/src/lib.rs:98

Methodset_target_values

( &mut self, datapoints: Self::UpdateActuationType, )

lib/kuksa_val_v2/src/lib.rs:160

Methodshould_equal_glob_string_pattern

(&self, glob_string: &str)

databroker/src/glob.rs:2627

Methodshould_equal_regex_pattern

(&self, regex_pattern: &str)

databroker/src/glob.rs:1205

Methodshould_match_no_signals

(&self)

databroker/src/glob.rs:1184

Methodshould_match_signal

(&self, signal: &str)

databroker/src/glob.rs:1180

Methodshutdown

(self)

integration_test/provider.py:138

Methodsize_hint

(&self)

databroker/src/broker.rs:1123

Functionstart_databroker_server

(w: &mut DataBrokerWorld, auth: String, step: &Step)

databroker/tests/read_write_values.rs:82

Methodsubscribe

( &self, request: tonic::Request<proto::SubscribeRequest>, )

databroker/src/grpc/kuksa_val_v1/val.rs:486

Methodsubscribe_current_values

( &mut self, paths: Self::SubscribeType, )

lib/kuksa_val_v2/src/lib.rs:140

Functionsubscribe_filter_curvelog

(connected_clients, request_id, path, maxerr, bufsize)

integration_test/viss/tests/test_steps/viss_v2_steps.py:214

Methodsubscribe_target_values

( &mut self, _paths: Self::PathType, )

lib/kuksa_val_v2/src/lib.rs:120

Methodsubscribe_target_values

( &mut self, paths: Self::PathType, )

lib/kuksa/src/lib.rs:178

Functiontest_actuate

()

lib/kuksa_val_v2/src/lib.rs:899

Functiontest_actuate_a_sensor_will_return_invalid_argument

()

lib/kuksa_val_v2/src/lib.rs:945

Functiontest_actuate_can_provider_unavailable

()

databroker/src/grpc/kuksa_val_v2/val.rs:3014

Functiontest_actuate_out_of_range

()

databroker/src/grpc/kuksa_val_v2/val.rs:2929

Functiontest_actuate_signal_not_found

()

databroker/src/grpc/kuksa_val_v2/val.rs:2990

Functiontest_actuate_stream_can_provider_unavailable

()

databroker/src/grpc/kuksa_val_v2/val.rs:3666

Functiontest_actuate_stream_out_of_range

()

databroker/src/grpc/kuksa_val_v2/val.rs:3572

Functiontest_actuate_stream_signal_not_found

()

databroker/src/grpc/kuksa_val_v2/val.rs:3636

Functiontest_actuate_stream_success

()

databroker/src/grpc/kuksa_val_v2/val.rs:3712

Functiontest_actuate_success

()

databroker/src/grpc/kuksa_val_v2/val.rs:3057

Functiontest_actuate_with_invalid_signal_path_will_return_not_found

()

lib/kuksa_val_v2/src/lib.rs:962

Functiontest_actuate_with_no_actuation_provider_will_return_unavailable

()

lib/kuksa_val_v2/src/lib.rs:928

Functiontest_actuate_with_read_auth_token_will_return_permission_denied

()

lib/kuksa_val_v2/src/lib.rs:997

Functiontest_actuate_without_auth_token_will_return_unauthenticated

()

lib/kuksa_val_v2/src/lib.rs:979

Functiontest_alignment

()

databroker-cli/src/kuksa_cli.rs:1295

← previous next →401–500 of 731, ranked by callers