Class for the Astarte devices. More...

#include <device_grpc.hpp>

Inheritance diagram for astarte::device::grpc::DeviceGrpc:

Public Member Functions
	DeviceGrpc (const std::string &server_addr, const std::string &node_uuid)
	Constructor for the Astarte device class.

	~DeviceGrpc () override
	Virtual destructor.

	DeviceGrpc (DeviceGrpc &other)=delete
	Device is non-copyable.

	DeviceGrpc (DeviceGrpc &&other)=delete
	Device is non-moveable.

auto	operator= (DeviceGrpc &other) -> DeviceGrpc &=delete
	Device is non-copyable.

auto	operator= (DeviceGrpc &&other) -> DeviceGrpc &=delete
	Device is non-moveable.

auto	add_interface_from_file (const std::filesystem::path &json_file) -> astarte_tl::expected< void, Error > override
	Adds an interface definition to the device from a JSON file.

auto	add_interface_from_str (std::string_view json) -> astarte_tl::expected< void, Error > override
	Adds an interface definition to the device from a JSON string.

auto	remove_interface (const std::string &interface_name) -> astarte_tl::expected< void, Error > override
	Removes an installed interface from the device.

auto	connect () -> astarte_tl::expected< void, Error > override
	Connects the device to the Astarte platform.

auto	is_connected () const -> bool override
	Checks connectivity status.

auto	disconnect () -> astarte_tl::expected< void, Error > override
	Disconnects the device from Astarte.

auto	send_individual (std::string_view interface_name, std::string_view path, const Data &data, const std::chrono::system_clock::time_point *timestamp) -> astarte_tl::expected< void, Error > override
	Sends an individual data point to an Astarte Interface.

auto	send_object (std::string_view interface_name, std::string_view path, const DatastreamObject &object, const std::chrono::system_clock::time_point *timestamp) -> astarte_tl::expected< void, Error > override
	Sends an aggregated object to an Astarte Interface.

auto	set_property (std::string_view interface_name, std::string_view path, const Data &data) -> astarte_tl::expected< void, Error > override
	Updates a local device property and synchronize it with Astarte.

auto	unset_property (std::string_view interface_name, std::string_view path) -> astarte_tl::expected< void, Error > override
	Unsets (deletes) a device property.

auto	poll_incoming (const std::chrono::milliseconds &timeout) -> std::optional< Message > override
	Polls for incoming messages from Astarte.

auto	get_all_properties (const std::optional< Ownership > &ownership) -> astarte_tl::expected< std::list< StoredProperty >, Error > override
	Retrieves all stored properties matching an ownership filter.

auto	get_properties (std::string_view interface_name) -> astarte_tl::expected< std::list< StoredProperty >, Error > override
	Retrieves all stored properties belonging to a specific interface.

auto	get_property (std::string_view interface_name, std::string_view path) -> astarte_tl::expected< PropertyIndividual, Error > override
	Retrieves a specific property value.

Public Member Functions inherited from astarte::device::Device
virtual	~Device ()=default
	Virtual destructor.

	Device (const Device &other)=delete
	Device is non-copyable.

	Device (Device &&other)=default
	Move constructor.

auto	operator= (const Device &other) -> Device &=delete
	Device is non-copyable.

auto	operator= (Device &&other) -> Device &=default
	Move assignment operator.

Detailed Description

Class for the Astarte devices.

This class should be instantiated once and then used to communicate with Astarte via the gRPC transport layer.

Constructor & Destructor Documentation

◆ DeviceGrpc() [1/3]

astarte::device::grpc::DeviceGrpc::DeviceGrpc	(	const std::string &	server_addr,
		const std::string &	node_uuid )

Constructor for the Astarte device class.

Parameters

[in]	server_addr	The gRPC server address of the Astarte message hub.
[in]	node_uuid	The UUID identifier for this device with the Astarte message hub.

◆ ~DeviceGrpc()

astarte::device::grpc::DeviceGrpc::~DeviceGrpc ( )

override

Virtual destructor.

◆ DeviceGrpc() [2/3]

astarte::device::grpc::DeviceGrpc::DeviceGrpc ( DeviceGrpc & other )

delete

Device is non-copyable.

◆ DeviceGrpc() [3/3]

astarte::device::grpc::DeviceGrpc::DeviceGrpc ( DeviceGrpc && other )

delete

Device is non-moveable.

Member Function Documentation

◆ add_interface_from_file()

auto astarte::device::grpc::DeviceGrpc::add_interface_from_file ( const std::filesystem::path & json_file ) -> astarte_tl::expected< void, Error >

overridevirtual

Adds an interface definition to the device from a JSON file.

Parses the JSON file to validate and register a new Astarte Interface.

Parameters

[in] json_file The filesystem path to the .json interface definition.

Returns: An expected containing void on success or Error on failure.

Implements astarte::device::Device.

◆ add_interface_from_str()

auto astarte::device::grpc::DeviceGrpc::add_interface_from_str ( std::string_view json ) -> astarte_tl::expected< void, Error >

overridevirtual

Adds an interface definition to the device from a JSON string.

Parameters

[in] json The interface definition as a JSON string view.

Returns: An expected containing void on success or Error on failure.

Implements astarte::device::Device.

◆ connect()

auto astarte::device::grpc::DeviceGrpc::connect ( ) -> astarte_tl::expected< void, Error >

overridevirtual

Connects the device to the Astarte platform.

This is an asynchronous operation. It initializes the transport layer and starts a background routine to maintain connectivity.

Returns: An expected containing void on success or Error on failure.

Implements astarte::device::Device.

◆ disconnect()

auto astarte::device::grpc::DeviceGrpc::disconnect ( ) -> astarte_tl::expected< void, Error >

overridevirtual

Disconnects the device from Astarte.

Returns: An expected containing void on success or Error on failure.

Implements astarte::device::Device.

◆ get_all_properties()

auto astarte::device::grpc::DeviceGrpc::get_all_properties ( const std::optional< Ownership > & ownership ) -> astarte_tl::expected< std::list< StoredProperty >, Error >

overridevirtual

Retrieves all stored properties matching an ownership filter.

Parameters

[in] ownership Optional filter, if std::nullopt, returns all properties.

Returns: An expected containing the list of properties on success or Error on failure.

Implements astarte::device::Device.

◆ get_properties()

auto astarte::device::grpc::DeviceGrpc::get_properties ( std::string_view interface_name ) -> astarte_tl::expected< std::list< StoredProperty >, Error >

overridevirtual

Retrieves all stored properties belonging to a specific interface.

Parameters

[in] interface_name The name of the interface to query.

Returns: An expected containing the list of properties on success or Error on failure.

Implements astarte::device::Device.

◆ get_property()

auto astarte::device::grpc::DeviceGrpc::get_property	(	std::string_view	interface_name,
		std::string_view	path ) -> astarte_tl::expected< PropertyIndividual, Error >

overridevirtual

Retrieves a specific property value.

Parameters

[in]	interface_name	The name of the interface.
[in]	path	The exact path of the property.

Returns: An expected containing the property on success or Error on failure.

Implements astarte::device::Device.

◆ is_connected()

auto astarte::device::grpc::DeviceGrpc::is_connected ( ) const -> bool

nodiscardoverridevirtual

Checks connectivity status.

Returns: True if the device is fully connected to Astarte, false otherwise.

Implements astarte::device::Device.

◆ operator=() [1/2]

auto astarte::device::grpc::DeviceGrpc::operator= ( DeviceGrpc && other ) -> DeviceGrpc &=delete

delete

Device is non-moveable.

◆ operator=() [2/2]

auto astarte::device::grpc::DeviceGrpc::operator= ( DeviceGrpc & other ) -> DeviceGrpc &=delete

delete

Device is non-copyable.

◆ poll_incoming()

auto astarte::device::grpc::DeviceGrpc::poll_incoming ( const std::chrono::milliseconds & timeout ) -> std::optional< Message >

overridevirtual

Polls for incoming messages from Astarte.

This method blocks the calling thread until a message is received or the timeout expires.

Parameters

[in] timeout The maximum duration to block waiting for a message.

Returns: std::optional containing the Message if received, or std::nullopt if the timeout was reached.

Implements astarte::device::Device.

◆ remove_interface()

auto astarte::device::grpc::DeviceGrpc::remove_interface ( const std::string & interface_name ) -> astarte_tl::expected< void, Error >

overridevirtual

Removes an installed interface from the device.

Parameters

[in] interface_name The name of the interface to remove.

Returns: An expected containing void on success or Error on failure.

Implements astarte::device::Device.

◆ send_individual()

auto astarte::device::grpc::DeviceGrpc::send_individual	(	std::string_view	interface_name,
		std::string_view	path,
		const Data &	data,
		const std::chrono::system_clock::time_point *	timestamp ) -> astarte_tl::expected< void, Error >

overridevirtual

Sends an individual data point to an Astarte Interface.

Parameters

[in]	interface_name	The name of the target interface.
[in]	path	The specific mapping path within the interface (e.g., "/sensors/temp").
[in]	data	The value payload to transmit.
[in]	timestamp	Optional timestamp. Should match the interface timestamp configuration.

Returns: An expected containing void on success or Error on failure.

Implements astarte::device::Device.

◆ send_object()

auto astarte::device::grpc::DeviceGrpc::send_object	(	std::string_view	interface_name,
		std::string_view	path,
		const DatastreamObject &	object,
		const std::chrono::system_clock::time_point *	timestamp ) -> astarte_tl::expected< void, Error >

overridevirtual

Sends an aggregated object to an Astarte Interface.

Parameters

[in]	interface_name	The name of the target interface.
[in]	path	The common base path for the object aggregation.
[in]	object	The map of keys and values constituting the object.
[in]	timestamp	Optional timestamp. Should match the interface timestamp configuration.

Returns: An expected containing void on success or Error on failure.

Implements astarte::device::Device.

◆ set_property()

auto astarte::device::grpc::DeviceGrpc::set_property	(	std::string_view	interface_name,
		std::string_view	path,
		const Data &	data ) -> astarte_tl::expected< void, Error >

overridevirtual

Updates a local device property and synchronize it with Astarte.

Parameters

[in]	interface_name	The name of the interface containing the property.
[in]	path	The specific path of the property.
[in]	data	The new value for the property.

Returns: An expected containing void on success or Error on failure.

Implements astarte::device::Device.

◆ unset_property()

auto astarte::device::grpc::DeviceGrpc::unset_property	(	std::string_view	interface_name,
		std::string_view	path ) -> astarte_tl::expected< void, Error >

overridevirtual

Unsets (deletes) a device property.

Parameters

[in]	interface_name	The name of the interface containing the property.
[in]	path	The specific path of the property to unset.

Returns: An expected containing void on success or Error on failure.

Implements astarte::device::Device.

The documentation for this class was generated from the following file:

/home/runner/work/astarte-device-sdk-cpp/astarte-device-sdk-cpp/astarte-device-sdk-cpp/include/astarte_device_sdk/grpc/device_grpc.hpp

Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ DeviceGrpc() [1/3]

◆ ~DeviceGrpc()

◆ DeviceGrpc() [2/3]

◆ DeviceGrpc() [3/3]

Member Function Documentation

◆ add_interface_from_file()

◆ add_interface_from_str()

◆ connect()

◆ disconnect()

◆ get_all_properties()

◆ get_properties()

◆ get_property()

◆ is_connected()

◆ operator=() [1/2]

◆ operator=() [2/2]

◆ poll_incoming()

◆ remove_interface()

◆ send_individual()

◆ send_object()

◆ set_property()

◆ unset_property()