Skip to content

Commit d12bd94

Browse files
authored
Support execute timeout (#344)
* support execute timeout * update
1 parent 1c445dc commit d12bd94

File tree

5 files changed

+1086
-68
lines changed

5 files changed

+1086
-68
lines changed

connection.go

+4
Original file line numberDiff line numberDiff line change
@@ -187,6 +187,10 @@ func (cn *connection) executeWithParameter(sessionID int64, stmt string,
187187
return resp, nil
188188
}
189189

190+
func (cn *connection) executeWithParameterTimeout(sessionID int64, stmt string, params map[string]*nebula.Value, timeoutMs int64) (*graph.ExecutionResponse, error) {
191+
return cn.graph.ExecuteWithTimeout(sessionID, []byte(stmt), params, timeoutMs)
192+
}
193+
190194
func (cn *connection) executeJson(sessionID int64, stmt string) ([]byte, error) {
191195
return cn.ExecuteJsonWithParameter(sessionID, stmt, map[string]*nebula.Value{})
192196
}

0 commit comments

Comments
 (0)