ActivateObjects looks for objects that are ready to be activated, marks them as active, and sends object notifications to their destinations.

NewWrapper creates a new Wrapper struct.

PrepareDeleteNotifications prepares the delete notification message.

PrepareNotificationsForDestinations prepares notification messages for the destinations if necessary.

PrepareObjectNotifications sends notifications to object’s destinations.

PrepareObjectStatusNotification sends an object status message to the other side.

PrepareUpdateNotification prepares the notification message from object's meta data.

ResendNotifications resends notications that haven't been acknowledged.

ResendObjects requests to resend all the relevant objects.

SendErrorResponse common code to send HTTP error codes.

SendNotifications calls the communication to send the notification messages.

Comm is the selected communications struct.

Store is a reference to the Storage being used.

Error is the error struct used by the communications code.

HTTP is the struct for the HTTP communications layer.

MQTT is the struct for MQTT based communications between a CSS and an ESS.

TestComm is a communicator used for unit testing.

Wrapper is the struct for a wrapper around the MQTT and HTTP communications between the CSS and ESS.

Communicator defines the interface for communications between the CSS and the CSS.