40
40
"TopologyConnErrors errors per operation" ,
41
41
[]string {"Operation" , "Cell" })
42
42
43
- topoStatsReadWaitTimings = stats .NewMultiTimings (
44
- "TopologyReadWaits " ,
45
- "TopologyReadWait timings" ,
43
+ topoStatsConnReadWaitTimings = stats .NewMultiTimings (
44
+ "TopologyConnReadWaits " ,
45
+ "TopologyConnReadWait timings" ,
46
46
[]string {"Operation" , "Cell" })
47
47
)
48
48
@@ -74,7 +74,7 @@ func (st *StatsConn) ListDir(ctx context.Context, dirPath string, full bool) ([]
74
74
return nil , err
75
75
}
76
76
defer st .readSem .Release (1 )
77
- topoStatsReadWaitTimings .Record (statsKey , startTime )
77
+ topoStatsConnReadWaitTimings .Record (statsKey , startTime )
78
78
defer topoStatsConnTimings .Record (statsKey , startTime )
79
79
res , err := st .conn .ListDir (ctx , dirPath , full )
80
80
if err != nil {
@@ -124,7 +124,7 @@ func (st *StatsConn) Get(ctx context.Context, filePath string) ([]byte, Version,
124
124
return nil , nil , err
125
125
}
126
126
defer st .readSem .Release (1 )
127
- topoStatsReadWaitTimings .Record (statsKey , startTime )
127
+ topoStatsConnReadWaitTimings .Record (statsKey , startTime )
128
128
defer topoStatsConnTimings .Record (statsKey , startTime )
129
129
bytes , version , err := st .conn .Get (ctx , filePath )
130
130
if err != nil {
@@ -142,7 +142,7 @@ func (st *StatsConn) List(ctx context.Context, filePathPrefix string) ([]KVInfo,
142
142
return nil , err
143
143
}
144
144
defer st .readSem .Release (1 )
145
- topoStatsReadWaitTimings .Record (statsKey , startTime )
145
+ topoStatsConnReadWaitTimings .Record (statsKey , startTime )
146
146
defer topoStatsConnTimings .Record (statsKey , startTime )
147
147
bytes , err := st .conn .List (ctx , filePathPrefix )
148
148
if err != nil {
0 commit comments