Versions in this module Expand all Collapse all v1 v1.7.2 Sep 2, 2021 Changes in this version + const AckConsumed + const AckDelete + const AckDeleted + const AckReceived + const AckRegister + const AckResend + const AddAction + const Bolt + const CSS + const CompletelyReceived + const Consumed + const ConsumedByDest + const ConsumedByDestination + const ConsumedPending + const Data + const DefaultLogTraceFileSize + const Delete + const DeleteAction + const DeletePending + const Deleted + const DeletedPending + const Delivered + const Delivering + const DestinationsACLType + const ESS + const Error + const Feedback + const Getdata + const Green + const HTTPProtocol + const HybridMQTT + const HybridWIoTP + const IOErrorCode + const InMemory + const InternalErrorCode + const InvalidObject + const ListeningBoth + const ListeningSecureUnix + const ListeningSecurely + const ListeningUnix + const ListeningUnsecurely + const MQTTProtocol + const Magic + const Mongo + const NotReadyToSend + const ObjConsumed + const ObjDeleted + const ObjReceived + const ObjectsACLType + const ParallelMQTTLarge + const ParallelMQTTMedium + const ParallelMQTTNone + const ParallelMQTTSmall + const PartiallyReceived + const PathErrorCode + const Pending + const Ping + const ReadyToSend + const Received + const ReceivedByDestination + const ReceivedPending + const ReceiverError + const Red + const Register + const RegisterAction + const RegisterAsNew + const RegisterNew + const RemoveAction + const Resend + const ResendAll + const ResendDelivered + const ResendUndelivered + const SecurityErrorCode + const Sha1 + const Sha256 + const TypeDestination + const TypeObject + const Unregister + const Update + const UpdatePending + const Updated + const WIoTP + const Yellow + var HTTPCSSURL string + var IsInvalidDescription = regexp.MustCompile(`<[/]?[a-zA-Z0-9]+>`).MatchString + var IsValidName = regexp.MustCompile(`^[a-zA-Z0-9|!|@|#|$|^|*|\-|_|.|~|\pL|\pN]+$`).MatchString + var Registered bool + var ResendAcked bool + var Running bool + var ServingAPIs bool + var SingleOrgCSS bool + func BlockUntilNoRunningGoRoutines() + func CreateFeedback(err SyncServiceError) (code int, retryInterval int32, reason string) + func CreateNotificationID(orgID string, objectType string, objectID string, destType string, ...) string + func GetNotificationID(notification Notification) string + func GoRoutineEnded() + func GoRoutineStarted() + func HashStrings(strings ...string) uint32 + func InitObjectLocks() + func IsErrorFeedback(code int) bool + func IsInvalidRequest(err error) bool + func IsNotFound(err error) bool + func IsValidHashAlgorithm(hashAlgorithm string) bool + func Load(configFileName string) error + func ResetGoRoutineCounter() + func ServiceListContains(serviceList []ServiceID, service ServiceID) bool + func SetDefaultConfig(config *Config) + func StringListContains(stringList []string, str string) bool + func ValidateConfig() error + func VersionAsString() string + type ACLentry struct + ACLRole string + ACLUserType string + Username string + type ChunkInfo struct + ResendTime int64 + type Config struct + AuthenticationHandler string + BrokerAddress string + BrokerPort uint16 + CSSOnWIoTP bool + CommunicationProtocol string + DatabaseConnectTimeout int + DestinationID string + DestinationType string + ESSCallSPIRetryInterval int32 + ESSConsumedObjectsKept int + ESSPingInterval int16 + ESSSPIMaxRetry int + HTTPCSSCACertificate string + HTTPCSSHost string + HTTPCSSPort uint16 + HTTPCSSUseSSL bool + HTTPESSClientTimeout int + HTTPPollingInterval uint16 + LeadershipTimeout int32 + ListeningAddress string + ListeningType string + LogFileName string + LogLevel string + LogRootPath string + LogTraceDestination string + LogTraceFileSizeKB int + LogTraceMaintenanceInterval int16 + MQTTAllowInvalidCertificates bool + MQTTBrokerConnectTimeout int + MQTTCACertificate string + MQTTClientID string + MQTTParallelMode string + MQTTPassword string + MQTTSSLCert string + MQTTSSLKey string + MQTTUseSSL bool + MQTTUserName string + MaxCompressedlLogTraceFilesNumber int + MaxDataChunkSize int + MaxInflightChunks int + MessagingGroupCacheExpiration int16 + MongoAddressCsv string + MongoAllowInvalidCertificates bool + MongoAuthDbName string + MongoCACertificate string + MongoDbName string + MongoPassword string + MongoSessionCacheSize int + MongoSleepTimeBetweenRetry int + MongoUseSSL bool + MongoUsername string + NodeType string + ObjectActivationInterval int16 + ObjectQueueBufferSize uint64 + ObjectsDataPath string + OrgID string + PersistenceRootPath string + RemoveESSRegistrationTime int16 + ResendInterval int16 + SecureListeningPort uint16 + ServerCertificate string + ServerKey string + ShutdownQuiesceTime int + StorageMaintenanceInterval int16 + StorageProvider string + TraceFileName string + TraceLevel string + TraceRootPath string + UnsecureListeningPort uint16 + UsingEdgeConnector bool + var Configuration Config + type ConsumedObject struct + MetaData MetaData + Timestamp time.Time + type DBHealthStatusInfo struct + DBReadFailures uint32 + DBStatus string + DBWriteFailures uint32 + DisconnectedFromDB bool + LastDisconnectFromDBDuration uint64 + TimeSinceLastReadWriteError uint64 + var DBHealth DBHealthStatusInfo + type Destination struct + CodeVersion string + Communication string + DestID string + DestOrgID string + DestType string + type DestinationRequestInQueue struct + Action string + Destination Destination + Object MetaData + Status string + type DestinationsStatus struct + DestID string + DestType string + Message string + Status string + type HealthStatusInfo struct + HealthStatus string + NodeType string + UpTime uint64 + var HealthStatus HealthStatusInfo + func (hs *HealthStatusInfo) ClientRequestReceived() + func (hs *HealthStatusInfo) DBReadFailed() + func (hs *HealthStatusInfo) DBWriteFailed() + func (hs *HealthStatusInfo) DisconnectedFromBroker() + func (hs *HealthStatusInfo) DisconnectedFromDatabase() + func (hs *HealthStatusInfo) GetLastDisconnectFromBrokerDuration() uint64 + func (hs *HealthStatusInfo) GetLastDisconnectFromDBDuration() uint64 + func (hs *HealthStatusInfo) NodeStarted() + func (hs *HealthStatusInfo) PublishFailed() + func (hs *HealthStatusInfo) ReconnectedToBroker() + func (hs *HealthStatusInfo) ReconnectedToDatabase() + func (hs *HealthStatusInfo) SubscribeFailed() + func (hs *HealthStatusInfo) UpdateHealthInfo(details bool, registeredESS uint32, storedObjects uint32) + type IOError struct + Message string + func (e *IOError) Error() string + type InternalError struct + Message string + func (e *InternalError) Error() string + type InvalidRequest struct + Message string + func (e *InvalidRequest) Error() string + type Locks struct + var ObjectLocks Locks + func NewLocks(name string) *Locks + func (locks *Locks) ConditionalLock(index uint32, lockedIndex uint32) + func (locks *Locks) ConditionalUnlock(index uint32, lockedIndex uint32) + func (locks *Locks) Lock(index uint32) + func (locks *Locks) RLock(index uint32) + func (locks *Locks) RUnlock(index uint32) + func (locks *Locks) Unlock(index uint32) + type MQTTHealthStatusInfo struct + DisconnectedFromMQTTBroker bool + LastDisconnectFromBrokerDuration uint64 + MQTTConnectionStatus string + PublishFailures uint32 + SubscribeFailures uint32 + TimeSinceLastPublishError uint64 + TimeSinceLastSubscribeError uint64 + var MQTTHealth MQTTHealthStatusInfo + type MessagingGroup struct + GroupName string + OrgID string + type MetaData struct + ActivationTime string + AutoDelete bool + ChunkSize int + DataID int64 + Deleted bool + Description string + DestID string + DestOrgID string + DestType string + DestinationDataURI string + DestinationPolicy *Policy + DestinationsList []string + ExpectedConsumers int + Expiration string + HashAlgorithm string + Inactive bool + InstanceID int64 + Link string + MetaOnly bool + NoData bool + ObjectID string + ObjectSize int64 + ObjectType string + OriginID string + OriginType string + OwnerID string + Public bool + PublicKey string + Signature string + SourceDataURI string + Version string + type NotFound struct + func (e *NotFound) Error() string + type Notification struct + DataID int64 + DestID string + DestOrgID string + DestType string + InstanceID int64 + ObjectID string + ObjectType string + ResendTime int64 + Status string + type NotificationInfo struct + DataID int64 + DestID string + DestType string + InstanceID int64 + MetaData *MetaData + NotificationTopic string + type ObjectDestinationPolicy struct + DestinationPolicy *Policy + Destinations []DestinationsStatus + ObjectID string + ObjectType string + OrgID string + type ObjectInQueue struct + Destinations []StoreDestinationStatus + NotificationAction string + NotificationType string + Object MetaData + type ObjectStatus struct + ObjectID string + ObjectType string + OrgID string + Status string + type Organization struct + Address string + OrgID string + Password string + User string + type PathError struct + Message string + func (e *PathError) Error() string + type Policy struct + Constraints []string + Properties []PolicyProperty + Services []ServiceID + Timestamp int64 + type PolicyProperty struct + Name string + Type string + Value interface{} + type SecurityError struct + Message string + func (e *SecurityError) Error() string + type SemVer struct + Fix int64 + Infinity bool + Minor int64 + Version int64 + func ParseSemVer(input string) (*SemVer, error) + func (semVer *SemVer) Compare(b *SemVer) int + func (semVer *SemVer) String() string + type SemVerRange struct + func ParseSemVerRange(input string) (*SemVerRange, error) + func (semVerRange *SemVerRange) IsInRange(semVer *SemVer) bool + type ServiceID struct + Arch string + OrgID string + ServiceName string + Version string + func GetRemovedPolicyServices(existingPolicy *Policy, newPolicy *Policy) []ServiceID + func RemoveServiceFromServiceList(serviceID string, serviceList []ServiceID) ([]ServiceID, bool) + type SetupError struct + Message string + func (e *SetupError) Error() string + type StoreDestinationStatus struct + Destination Destination + Message string + Status string + type StoredOrganization struct + Org Organization + Timestamp time.Time + type SyncServiceError error + func CreateError(err error, message string) SyncServiceError + func GetHash(hashAlgo string) (hash.Hash, crypto.Hash, SyncServiceError) + func ValidateDestinationListInput(destinationsList []string) (bool, SyncServiceError) + type SyncServiceVersion struct + Major uint32 + Minor uint32 + var Version SyncServiceVersion + type UsageInfo struct + ClientRequests uint64 + RegisteredESS uint32 + StoredObjects uint32 + var HealthUsageInfo UsageInfo