diff --git a/listener/listener.go b/listener/listener.go index 3427fa50..5239388b 100644 --- a/listener/listener.go +++ b/listener/listener.go @@ -94,7 +94,7 @@ func Run() { if Settings.FileToReplayPath != "" { go func() { - message := utils.ParsedRequest{time.Now().UnixNano(), m.Bytes()} + message := utils.RawRequest{time.Now().UnixNano(), m.Bytes()} fileEnc.Encode(message) }() } else { diff --git a/replay/replay_file_parser.go b/replay/replay_file_parser.go index 4cecf5fc..97197f72 100644 --- a/replay/replay_file_parser.go +++ b/replay/replay_file_parser.go @@ -10,7 +10,7 @@ import ( "github.com/buger/gor/utils" ) -func parseReplayFile() (requests []utils.ParsedRequest, err error) { +func parseReplayFile() (requests []utils.RawRequest, err error) { requests, err = readLines(Settings.FileToReplayPath) if err != nil { @@ -22,7 +22,7 @@ func parseReplayFile() (requests []utils.ParsedRequest, err error) { // readLines reads a whole file into memory // and returns a slice of request+timestamps. -func readLines(path string) (requests []utils.ParsedRequest, err error) { +func readLines(path string) (requests []utils.RawRequest, err error) { file, err := ioutil.ReadFile(path) if err != nil { @@ -33,7 +33,7 @@ func readLines(path string) (requests []utils.ParsedRequest, err error) { fileDec := gob.NewDecoder(fileBuf) for err == nil { - var reqBuf utils.ParsedRequest + var reqBuf utils.RawRequest err = fileDec.Decode(&reqBuf) if err == io.EOF { diff --git a/utils/utils.go b/utils/utils.go index c1789096..5ca5cd7d 100644 --- a/utils/utils.go +++ b/utils/utils.go @@ -4,11 +4,11 @@ import ( "fmt" ) -type ParsedRequest struct { +type RawRequest struct { Timestamp int64 Request []byte } -func (self ParsedRequest) String() string { +func (self RawRequest) String() string { return fmt.Sprintf("Request: %v, timestamp: %v", string(self.Request), self.Timestamp) }