Notification processing functions
(connID uint64, seqID int64, notificationType string, notification interface{})
| 227 | |
| 228 | // Notification processing functions |
| 229 | func ProcessingNotification(connID uint64, seqID int64, notificationType string, notification interface{}) string { |
| 230 | message := fmt.Sprintf("conn[%d] seqID[%d] %s %s: %v", connID, seqID, ProcessingNotificationMessage, notificationType, notification) |
| 231 | return appendJSONIfDebug(message, map[string]interface{}{ |
| 232 | "connID": connID, |
| 233 | "seqID": seqID, |
| 234 | "notificationType": notificationType, |
| 235 | "notification": fmt.Sprintf("%v", notification), |
| 236 | }) |
| 237 | } |
| 238 | |
| 239 | func ProcessingNotificationFailed(connID uint64, notificationType string, err error, notification interface{}) string { |
| 240 | message := fmt.Sprintf("conn[%d] %s %s: %v - %v", connID, ProcessingNotificationFailedMessage, notificationType, err, notification) |
no test coverage detected