# Functions
BlockUntilNoRunningGoRoutines blocks the current "thread".
CreateError creates a sync-service error from a Go error.
CreateFeedback extracts feedback parameters from an error.
CreateNotificationID creates notification ID.
GetHash returns the hash object and crypto hash algo name (used by rsa.VerifyPSS() func) of specified hash algorithm.
GetNotificationID gets the notification ID for the notification.
GetRemovedPolicyServices is the method to compare existing destination policy and new destination policy, returning removed policy services.
GoRoutineEnded decrements the go routines counter.
GoRoutineStarted increments the go routines counter.
HashStrings hashes strings.
InitObjectLocks initializes ObjectLocks.
IsErrorFeedback returns true if the feedback code corresponds to an error.
IsInvalidRequest returns true if the error passed in is the common.InvalidRequest error.
IsNotFound returns true if the error passed in is the common.NotFound error.
No description provided by the author
Load loads the configuration from the specified properties file.
NewLocks initializes object locks.
ParseSemVer parses a semantic version string and returns a SemVer.
ParseSemVerRange parses a semantic version range string and returns a SemVerRange.
RemoveServiceFromServiceList removes a service from the given service list and return it.
ResetGoRoutineCounter sets the go routines counter to 0.
ServiceListContains returns true if serviceIDList contains the given serviceID.
SetDefaultConfig sets the default configuration into the provided Config struct.
StringListContains returns true if string list contains given string.
ValidateConfig Validates the configuration.
ValidateDestinationListInput checks if destinationsList contains < or >, to avoid injecting html like tags from user.
VersionAsString returns the current version as string.
# Constants
Notification status and type.
Notification status and type.
Notification status and type.
Notification status and type.
Notification status and type.
Notification status and type.
API payload actions.
Storage providers.
The object was received completely from the other side.
Notification status and type.
The object was consumed by the other side (ESS only).
Notification status and type.
Notification status and type.
Cloud Sync Service or Edge Sync Service.
Notification status and type.
DefaultLogTraceFileSize default value for log and trace file size in KB.
Notification status and type.
API payload actions.
Notification status and type.
Notification status and type.
Notification status and type.
Indication whether the object has been delivered to the destination.
Indication whether the object has been delivered to the destination.
Types of various ACLs.
Notification status and type.
Cloud Sync Service or Edge Sync Service.
Notification status and type.
Notification status and type.
Health status values.
Protocol definitions.
Protocol definitions.
Protocol definitions.
Storage providers.
Feedback codes.
Feedback codes.
Feedback codes.
Listening types.
Listening types.
Listening types.
Listening types.
Listening types.
Magic is a magic number placed in the front of various payloads.
Storage providers.
Protocol definitions.
The object is not ready to be sent to the other side.
The object was consumed by the app.
The object was deleted by the other side.
Types of various ACLs.
The object was received by the app.
The parallelism modes by which incoming MQTT messages are processed.
The parallelism modes by which incoming MQTT messages are processed.
The parallelism modes by which incoming MQTT messages are processed.
The parallelism modes by which incoming MQTT messages are processed.
Received the object from the other side, waiting for its data.
Feedback codes.
Indication whether the object has been delivered to the destination.
Notification status and type.
The object is ready to be sent to the other side.
Notification status and type.
Notification status and type.
Notification status and type.
Notification status and type.
Health status values.
Notification status and type.
API payload actions.
Notification status and type.
Notification status and type.
API payload actions.
Notification status and type.
Resend flag options.
Resend flag options.
Resend flag options.
Feedback codes.
Hash Algorithms supported for digital signature.
Hash Algorithms supported for digital signature.
NotificationType of object sent to objectWorkQueue.
NotificationType of object sent to objectWorkQueue.
Notification status and type.
Notification status and type.
Notification status and type.
Notification status and type.
Protocol definitions.
Health status values.
# Variables
Configuration contains the read in configuration.
DBHealth describes the health status of the database of the sync-service node.
HealthStatus describes the health status of the sync-service node.
HealthUsageInfo describes the usage of the sync-service node.
HTTPCSSURL specifies the CSS URL for HTTP communication from ESS.
IsInvalidDescription checks if metadata description text contains XSS tags in this format: <abc> or </abc>.
IsValidName checks if the string only contains letters, digits, and !@#%^*-_.~.
MQTTHealth describes the health status of the MQTT connection of the sync-service node.
ObjectLocks are locks for object and notification changes.
Registered indicates if this node, an ESS, has registered itself.
ResendAcked indicates if the resend objects request had been acknowledged.
Running indicates that the Sync Service is running.
ServingAPIs when true, indicates that the Sync Service is serving the various APIs over HTTP.
SingleOrgCSS is true in case of CSS ouside WIoTP with one organization set in the configration, and false otherwise.
Version is the current version of the Sync-Service.
# Structs
ACLentry contains ACL information about each user.
ChunkInfo describes chunks for multi-inflight data transfer.
Config contains the parsed contents of the configuration file.
ConsumedObject contains consumed object's meta data and its timestamp.
DBHealthStatusInfo describes the health status of the database of the sync-service node swagger:model.
Destination describes a sync service node.
No description provided by the author
DestinationsStatus describes the delivery status of an object for a destination DestinationsStatus provides information about the delivery status of an object for a certain destination.
HealthStatusInfo describes the health status of the sync-service node swagger:model.
InternalError is a general error.
InvalidRequest is the error for invalid reguests swagger:ignore.
IOError is the error for requests failed because of the IO.
Locks is a set of object locks.
MessagingGroup maps organization to its messaging group.
MetaData is the metadata that identifies and defines the sync service object.
MQTTHealthStatusInfo describes the health status of the MQTT connection of the sync-service node swagger:model.
NotFound is the error returned if an object wasn't found.
Notification is used to store notifications in the store swagger:ignore.
NotificationInfo contains information about a message to send to the other side.
ObjectDestinationPolicy contains information about an object that has a Destination Policy.
No description provided by the author
ObjectStatus describes the delivery status of an object for a destination The status can be one of the following: Indication whether the object has been delivered to the destination delivering - indicates that the object is being delivered delivered - indicates that the object was delivered consumed - indicates that the object was consumed deleted - indicates that this destination acknowledged the deletion of the object error - indicates that a feedback error message was received swagger:model.
Organization contains organization's information swagger:model.
PathError is the error for path issues.
Policy describes a policy made up of a set of properties and constraints swagger:model.
PolicyProperty is a property in a policy swagger:model.
SecurityError is the error for requests failed because of security.
SemVer represents a semantic version.
SemVerRange represents a range over semantic version.
ServiceID contains the ID of a service to which an object may have affinity for swagger:model.
SetupError is the error for setup issues swagger:ignore.
StoreDestinationStatus is the information about destinations and their status for an object swagger:ignore.
StoredOrganization contains organization and its update timestamp.
SyncServiceVersion is the current version of the Sync-Service.
UsageInfo describes the usage of the sync-service node swagger:model.
# Type aliases
SyncServiceError is a common error type used in the sync service swagger:ignore.