MCPcopy
hub / github.com/redis/go-redis / ProcessingNotification

Function ProcessingNotification

internal/maintnotifications/logs/log_messages.go:229–237  ·  view source on GitHub ↗

Notification processing functions

(connID uint64, seqID int64, notificationType string, notification interface{})

Source from the content-addressed store, hash-verified

227
228// Notification processing functions
229func 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
239func 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)

Callers 1

PreHookMethod · 0.92

Calls 1

appendJSONIfDebugFunction · 0.85

Tested by

no test coverage detected