206
operationDeadline time.Time,
207
request *matchingservice.DispatchNexusTaskRequest,
209
>
return &internalTask{
210
>
nexus: &nexusTaskInfo{
211
>
taskID: taskID,
212
>
createTime: getCreateTime(request.GetForwardInfo()),
213
>
deadline: deadline,
214
>
operationDeadline: operationDeadline,
215
>
request: request,
216
>
},
217
>
forwardInfo: request.GetForwardInfo(),
218
>
responseC: make(chan taskResponse, 1),
219
>
source: enumsspb.TASK_SOURCE_HISTORY,
220
>
}
221
>
}
222
223
func newInternalStartedTask(info *startedTaskInfo) *internalTask {