Versions in this module Expand all Collapse all v1 v1.0.1 Jul 25, 2019 v1.0.0 Jun 24, 2019 Changes in this version + var LoggingClient logger.LoggingClient + func Destruct() + func Init(useRegistry bool) bool + func Loop() + func RefreshRegistrations(update contract.NotifyUpdate) + func Retry(useRegistry bool, useProfile string, timeout int, wait *sync.WaitGroup, ...) + func ZeroMQReceiver(eventCh chan *models.Event) + type AzureMessage struct + Ack feedbackCode + Body []byte + ConnAuthMethod connAuthMethod + ConnDevGenID string + ConnDevID string + CorrelationID string + Created time.Time + Enqueued time.Time + Expire time.Time + ID string + Properties map[string]string + SequenceNumber int64 + To string + UserID string + func (am *AzureMessage) AddProperty(key, value string) error + type BIoTMessage struct + AuthToken string + Data []byte + Dataformat string + EncType string + FuncType string + MsgCode string + MsgDate int64 + MsgId string + MsgType string + ResCode string + ResMsg string + SId string + Severity string + TId string + TpId string + Version string + type CertificateInfo struct + Cert string + Key string + type ConfigurationStruct struct + AnalyticsQueue config.MessageQueueInfo + Certificates map[string]CertificateInfo + Clients map[string]config.ClientInfo + Logging config.LoggingInfo + MessageQueue config.MessageQueueInfo + Registry config.RegistryInfo + Service config.ServiceInfo + Writable WritableInfo + var Configuration *ConfigurationStruct + type WritableInfo struct + LogLevel string + MarkPushed bool