mq2http

type AMQPRPCSettings struct {
	Exchange     string
	ExchangeType string
	BindingKey   string
	ConsumerTag  string
}

type AMQPWriter struct {
	ReplyTo       string
	CorrelationID string
	Exchange      string
	ExchangeType  string
	AMQPConn      *samqp.Connection
	Headers       map[string][]string
	Status        int
}

type JSONRPCRequest struct {
	Version string          `json:"jsonrpc"`
	Method  string          `json:"method"`
	Params  ReqParamsStruct `json:"params,omitempty"`
	ID      string          `json:"id,omitempty"`
}

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

type JSONRPCResponse struct {
	Version string           `json:"jsonrpc"`
	Result  RespParamsStruct `json:"result,omitempty"`
	Error   string           `json:"error,omitempty"`
	ID      string           `json:"id,emitempty"`
}

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

type ReqParamsStruct struct {
	Body    string      `json:"body"`
	Headers http.Header `json:"headers"`
}

type RequestWriter interface {
	Headers() http.Header
	Method() string
	URL() string
	Reader() io.Reader
}

type RespParamsStruct struct {
	Status     string `json:"status"` // Have this in resp
	StatusCode int    `json:"statuscode"`
	// Proto string
	// ProtoMajor int
	// ProtoMinor int
	Header        http.Header `json:"header"` // have this in amqp.go mq2http
	Body          string      `json:"body"`
	ContentLength int64       `json:"contentlength"` // = len(body)
	//	TransferEncoding []string
	Close        bool `json:"close"`        // always false
	Uncompressed bool `json:"uncompressed"` // always true
	// 	Trailer      http.Header          `json:"trailer"`      // same as headers
	Request *http.Request `json:"reqpest"` // nil

}

type ResponseWriter interface {
	Status() string
	StatusCode() int
	Headers() http.Header
	Reader() io.ReadCloser
	ContentLength() int64
}