func AddPulsarConnTime(ctx context.Context, t int) { if n, ok := dataContainer.NoticeData.Get(GetLogId(ctx)); ok { addMiddleConnTime(&n.NoticeMetrics.Middle.Pulsar, t) } } func AddKafkaConnTime(ctx context.Context, t int) { if n, ok := dataContainer.NoticeData.Get(GetLogId(ctx)); ok { addMiddleConnTime(&n.NoticeMetrics.Middle.Kafka, t) } } func AddEsConnTime(ctx context.Context, t int) { if n, ok := dataContainer.NoticeData.Get(GetLogId(ctx)); ok { addMiddleConnTime(&n.NoticeMetrics.Middle.Elastic, t) } } func AddRpcConnTime(ctx context.Context, t int) { if n, ok := dataContainer.NoticeData.Get(GetLogId(ctx)); ok { addMiddleConnTime(&n.NoticeMetrics.Middle.Rpc, t) } } func AddRocketConnTime(ctx context.Context, t int) { if n, ok := dataContainer.NoticeData.Get(GetLogId(ctx)); ok { addMiddleConnTime(&n.NoticeMetrics.Middle.RocketMq, t) } } */.

快速获取一个带logid上下文的context.

生成文件的时候执行.

初始化的时候使用.

var noticeLog zap.Logger.

中间件耗时.