notifications

Author: RangelReale

client.go

@@ -382,7 +382,7 @@ func (c *client) attemptConnection(isReconnect bool, attempt int) (net.Conn, byt
 			tlsCfg = c.options.OnConnectAttempt(broker, c.options.TLSConfig)
 		}
 		if c.options.OnConnectionNotification != nil {
-			c.options.OnConnectionNotification(c, ConnectionNotificationAttempt{broker})
+			c.options.OnConnectionNotification(c, ConnectionNotificationBroker{broker})
 		}
 		connDeadline := time.Now().Add(c.options.ConnectTimeout) // Time by which connection must be established
 		dialer := c.options.Dialer
@@ -401,7 +401,7 @@ func (c *client) attemptConnection(isReconnect bool, attempt int) (net.Conn, byt
 			WARN.Println(CLI, "failed to connect to broker, trying next")
 			rc = packets.ErrNetworkError
 			if c.options.OnConnectionNotification != nil {
-				c.options.OnConnectionNotification(c, ConnectionNotificationAttemptFailed{broker, err})
+				c.options.OnConnectionNotification(c, ConnectionNotificationBrokerFailed{broker, err})
 			}
 			continue
 		}

connnotf.go

@@ -9,8 +9,8 @@ const (
 	ConnectionNotificationTypeConnecting
 	ConnectionNotificationTypeFailed
 	ConnectionNotificationTypeLost
-	ConnectionNotificationTypeAttempt
-	ConnectionNotificationTypeAttemptFailed
+	ConnectionNotificationTypeBroker
+	ConnectionNotificationTypeBrokerFailed
 )
 
 type ConnectionNotification interface {
@@ -57,23 +57,23 @@ func (n ConnectionNotificationLost) Type() ConnectionNotificationType {
 	return ConnectionNotificationTypeLost
 }
 
-// Connection Attempt
+// Broker Connection
 
-type ConnectionNotificationAttempt struct {
+type ConnectionNotificationBroker struct {
 	Broker *url.URL
 }
 
-func (n ConnectionNotificationAttempt) Type() ConnectionNotificationType {
-	return ConnectionNotificationTypeAttempt
+func (n ConnectionNotificationBroker) Type() ConnectionNotificationType {
+	return ConnectionNotificationTypeBroker
 }
 
-// Connection Attempt Failed
+// Broker Connection Failed
 
-type ConnectionNotificationAttemptFailed struct {
+type ConnectionNotificationBrokerFailed struct {
 	Broker *url.URL
 	Reason error
 }
 
-func (n ConnectionNotificationAttemptFailed) Type() ConnectionNotificationType {
-	return ConnectionNotificationTypeAttemptFailed
+func (n ConnectionNotificationBrokerFailed) Type() ConnectionNotificationType {
+	return ConnectionNotificationTypeBrokerFailed
 }