Method DyeingWritef

tars/util/rogger/dyeing.go:73–117

(ctx context.Context, depth int, level LogLevel, ext interface{}, format string, v []interface{})

}

func (l *Logger) DyeingWritef(ctx context.Context, depth int, level LogLevel, ext interface{}, format string, v []interface{}) {
	l.Writef(depth+1, level, format, v)

	dyeingKey, ok := current.GetDyeingKey(ctx)
	if !ok {
		return
	}

	buf := bytes.NewBuffer(nil)
	if l.writer.NeedPrefix() {
		fmt.Fprintf(buf, "%s|", time.Now().Format("2006-01-02 15:04:05.000"))

		if callerFlag {
			pc, file, line, ok := runtime.Caller(depth + callerSkip)
			if !ok {
				file = "???"
				line = 0
			} else {
				file = filepath.Base(file)
			}
			fmt.Fprintf(buf, "%s:%s:%d|", file, FuncName(runtime.FuncForPC(pc)), line)
		}
		if IsColored() && l.IsConsoleWriter() {
			buf.WriteString(level.ColoredString())
		} else {
			buf.WriteString(level.String())
		}
		buf.WriteByte('|')
	}

	if format == "" {
		fmt.Fprint(buf, v...)
	} else {
		fmt.Fprintf(buf, format, v...)
	}
	if l.writer.NeedPrefix() {
		buf.WriteByte('\n')
	}

	select {
	case dyeingLogQueue <- &dyeingLogValue{Value: buf.Bytes(), DyeingKey: dyeingKey, ExtInfo: ext}:
	default:
		dyeingErrorLog.Error("dyeingLogQueue is full")
	}
}

// AddDyeingUser add dyeing key to dyeingUserMap. key is separated by ','
func AddDyeingUser(key string) error {