33 lines
786 B
Go
33 lines
786 B
Go
package trace
|
||
|
||
import "sync"
|
||
|
||
var _ D = (*Dialog)(nil)
|
||
|
||
type D interface {
|
||
i()
|
||
AppendResponse(resp *Response)
|
||
}
|
||
|
||
// Dialog 内部调用其它方接口的会话信息；失败时会有retry操作，所以 response 会有多次。
|
||
type Dialog struct {
|
||
mux sync.Mutex
|
||
Request *Request `json:"request"` // 请求信息
|
||
Responses []*Response `json:"responses"` // 返回信息
|
||
Success bool `json:"success"` // 是否成功，true 或 false
|
||
CostSeconds float64 `json:"cost_seconds"` // 执行时长(单位秒)
|
||
}
|
||
|
||
func (d *Dialog) i() {}
|
||
|
||
// AppendResponse 按转的追加response信息
|
||
func (d *Dialog) AppendResponse(resp *Response) {
|
||
if resp == nil {
|
||
return
|
||
}
|
||
|
||
d.mux.Lock()
|
||
d.Responses = append(d.Responses, resp)
|
||
d.mux.Unlock()
|
||
}
|