Method OpenStream

middleware/grpc_stats.go:150–158

(connID string)

}

func (st *StreamTracker) OpenStream(connID string) {
	st.mu.RLock()
	conn, ok := st.connMap[connID]
	st.mu.RUnlock()
	if !ok {
		conn = st.createOrGetConnEntry(connID)
	}
	conn.Inc()
}

func (st *StreamTracker) CloseStream(connID string) {
	st.mu.RLock()