README
¶
replay 
Replay HTTP traffic to multiple servers easily.
Installation
go get -u gopkg.in/vinxi/replay.v0
API
See godoc reference.
Examples
Replay to multiple servers
package main
import (
"fmt"
"gopkg.in/vinxi/replay.v0"
"gopkg.in/vinxi/vinxi.v0"
"net/http"
)
func main() {
vs := vinxi.NewServer(vinxi.ServerOptions{Host: "localhost", Port: 3100})
handler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
fmt.Printf("Replay server reached: %s => %s\n", r.RemoteAddr, r.URL.String())
w.Write([]byte("replay server"))
})
srv1 := &http.Server{Addr: "localhost:3123"}
srv2 := &http.Server{Addr: "localhost:3124"}
srv1.Handler = handler
srv2.Handler = handler
go srv1.ListenAndServe()
go srv2.ListenAndServe()
replayer := replay.New("http://localhost:3123", "http://localhost:3124")
replayer.SetHandler(func(err error, res *http.Response, req *http.Request) {
if err != nil {
fmt.Printf("Replay error: %s => %s\n", req.URL.String(), err)
return
}
fmt.Printf("Replay response: %s => %d\n", req.URL.String(), res.StatusCode)
})
vs.Use(replayer)
vs.Forward("http://httpbin.org")
fmt.Printf("Server listening on port: %d\n", 3100)
err := vs.Listen()
if err != nil {
fmt.Printf("Error: %s\n", err)
}
}
License
MIT
Documentation
¶
Index ¶
- func EnsureTransporterFinalized(httpTransport *http.Transport)
- func NewReplayRequest(req *http.Request, host string, body io.Reader) (*http.Request, error)
- type Filter
- type Handler
- type Modifier
- type Replayer
- func (x *Replayer) Filter(fn ...Filter) *Replayer
- func (x *Replayer) HandleHTTP(w http.ResponseWriter, r *http.Request, h http.Handler)
- func (x *Replayer) Modify(fn ...Modifier) *Replayer
- func (x *Replayer) Replay(r *http.Request, target string, body io.Reader)
- func (x *Replayer) SetHandler(fn Handler) *Replayer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EnsureTransporterFinalized ¶
EnsureTransporterFinalized will ensure that when the HTTP client is GCed the runtime will close the idle connections (so that they won't leak) this function was adopted from Hashicorp's go-cleanhttp package.
Types ¶
type Filter ¶
Filter function is used to determine if a given http.Request should be replayed or not.
type Replayer ¶
type Replayer struct {
// Targets stores the replay URL targets.
Targets []string
// Filters stores the replay filter functions.
Filters []Filter
// Modifiers stores the replay request modifier functions.
Modifiers []Modifier
// Handler stores the optional replay response/error handler.
Handler Handler
// Client stores the http.Client to be used to replay the requests.
// Defaults to http.DefaultClient.
Client *http.Client
}
Replayer replays incoming HTTP traffic to one or multiple servers via isolated goroutine.
func (*Replayer) Filter ¶
Filter attaches a new filter function to the current replayer who determines if a given request should be replayed or not.
func (*Replayer) HandleHTTP ¶
HandleHTTP handles an incoming HTTP request received by the proxy.
func (*Replayer) Modify ¶
Modify attaches a new modifier function to the current replayer who is responsible to modify the http.Request to be replayed before the replay.
func (*Replayer) SetHandler ¶
SetHandler is used to set a replay request handler, allowing the developer to deal with the replay response or error accordingly.
Source Files
Directories