common

package

Go to main page

Versions in this module

v1

v1.7.1

Sep 15, 2021

v1.7.0

Sep 2, 2021

v1.6.7

Sep 2, 2021

Changes in this version

+ const ReceiverError

+ const TypeDestination

+ const TypeObject

type Config

+ ESSCallSPIRetryInterval int32

+ ESSSPIMaxRetry int

+ HTTPESSClientTimeout int

+ ObjectQueueBufferSize uint64

+ type DestinationRequestInQueue struct

+ Action string

+ Destination Destination

+ Object MetaData

+ Status string

+ type ObjectInQueue struct

+ Destinations []StoreDestinationStatus

+ NotificationAction string

+ NotificationType string

+ Object MetaData

v1.6.5

Aug 5, 2021

Changes in this version

+ const AddAction

+ const DeleteAction

+ const RegisterAction

+ const RemoveAction

type Config

+ MongoSleepTimeBetweenRetry int

v1.6.4

Jun 3, 2021

Changes in this version

+ func IsValidHashAlgorithm(hashAlgorithm string) bool

v1.6.3

May 28, 2021

v1.6.2

May 18, 2021

Changes in this version

+ const Sha1

+ const Sha256

type MetaData

+ HashAlgorithm string

+ PublicKey string

+ Signature string

type SyncServiceError

+ func GetHash(hashAlgo string) (hash.Hash, crypto.Hash, SyncServiceError)

v1.6.1

Apr 8, 2021

v1.5.3

Mar 2, 2021

Changes in this version

+ var IsInvalidDescription = regexp.MustCompile(`<[/]?[a-zA-Z0-9]+>`).MatchString

v1.5.2

Jan 28, 2021

v1.5.1

Jan 22, 2021

v1.4.1

Sep 10, 2020

v0

v0.10.13

Jan 20, 2021

v0.10.12

Sep 10, 2020

Changes in this version

+ func StringListContains(stringList []string, str string) bool

+ type ACLentry struct

+ ACLRole string

+ ACLUserType string

+ Username string

type MetaData

+ Public bool

v0.10.11

Mar 6, 2020

Changes in this version

+ const AckConsumed

+ const AckDelete

+ const AckDeleted

+ const AckReceived

+ const AckRegister

+ const AckResend

+ const Bolt

+ const CSS

+ const CompletelyReceived

+ const Consumed

+ const ConsumedByDest

+ const ConsumedByDestination

+ const ConsumedPending

+ const Data

+ const DefaultLogTraceFileSize

+ const Delete

+ 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 Red

+ const Register

+ const RegisterAsNew

+ const RegisterNew

+ const Resend

+ const ResendAll

+ const ResendDelivered

+ const ResendUndelivered

+ const SecurityErrorCode

+ const Unregister

+ const Update

+ const UpdatePending

+ const Updated

+ const WIoTP

+ const Yellow

+ var HTTPCSSURL string

+ var IsValidName = regexp.MustCompile(`^[a-zA-Z0-9|!|@|#|$|^|*|\-|_|.|~]+$`).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 Load(configFileName string) error

+ func ResetGoRoutineCounter()

+ func ServiceListContains(serviceList []ServiceID, service ServiceID) bool

+ func SetDefaultConfig(config *Config)

+ func ValidateConfig() error

+ func VersionAsString() 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

+ ESSConsumedObjectsKept int

+ ESSPingInterval int16

+ HTTPCSSCACertificate string

+ HTTPCSSHost string

+ HTTPCSSPort uint16

+ HTTPCSSUseSSL bool

+ 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

+ MongoUseSSL bool

+ MongoUsername string

+ NodeType string

+ ObjectActivationInterval int16

+ 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 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

+ Inactive bool

+ InstanceID int64

+ Link string

+ MetaOnly bool

+ NoData bool

+ ObjectID string

+ ObjectSize int64

+ ObjectType string

+ OriginID string

+ OriginType string

+ OwnerID 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 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 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL