recorder

type Body struct {
	IsBinary    bool   `json:"is_binary"`
	Len         int    `json:"len"`
	ContentType string `json:"content_type"`
	Content     []byte `json:"content"`
}

type CertCache struct {
	// contains filtered or unexported fields
}

type Interceptor interface {
	// Connect 收到客户端连接, 自定义response返回, 只支持HTTP
	Connect(ctx *goproxy.Context, rw http.ResponseWriter)
	// BeforeRequest 请求发送前, 修改request
	BeforeRequest(ctx *goproxy.Context)
	// BeforeResponse 响应发送前, 修改response
	BeforeResponse(ctx *goproxy.Context, resp *http.Response, err error)
}

type Output interface {
	Write(*Transaction) error
}

type Recorder struct {
	// contains filtered or unexported fields
}

type Request struct {
	// Proto HTTP协议版本
	Proto string `json:"proto"`
	// Method 请求方法
	Method string `json:"method"`
	// Scheme 请求协议
	Scheme string `json:"scheme"`
	// Host 请求主机名
	Host string `json:"host"`
	// Path 请求path
	Path string `json:"path"`
	// QueryParam URL参数
	QueryParam string `json:"query_param"`
	// URL 完整URL
	URL string `json:"url"`
	// Header 请求Header
	Header http.Header `json:"header"`
	// Body 请求body
	Body *Body `json:"body"`
}

type Response struct {
	// Proto 响应协议
	Proto string `json:"proto"`
	// Status 状态状态
	Status string `json:"status"`
	// StatusCode 响应码
	StatusCode int `json:"status_code"`
	// Header 响应Header
	Header http.Header `json:"header"`
	// Body 响应Body
	Body *Body `json:"body"`
	// Err 错误信息
	Err string `json:"err"`
}

type Storage interface {
	Get(txId string) (*Transaction, error)
	Put(*Transaction) error
}

type Transaction struct {
	// Id 唯一id
	Id string `json:"id"`
	// Req 请求
	Req *Request `json:"request"`
	// Resp 响应
	Resp *Response `json:"response"`
	// ClientIP 客户端IP
	ClientIP string `json:"client_ip"`
	// ServerIP 服务端IP
	ServerIP string `json:"server_ip"`
	// StartTime 开始时间
	StartTime time.Time `json:"start_time"`
	// Duration 持续时间
	Duration time.Duration `json:"duration"`
}