mirror of
https://github.com/buger/goreplay.git
synced 2024-04-21 12:32:02 +00:00
Mantas Matelis
11d9531829
Can filter output_http by percentage of requests, constistent with a specific header value (FNV32-a hash-based) Can filter output_http to those with header matching a specific regexp Can filter output_http to those whose URL matches a specfic regexp
47 lines
1.3 KiB
Go
47 lines
1.3 KiB
Go
package main
|
|
|
|
import (
|
|
"io"
|
|
)
|
|
|
|
type InOutPlugins struct {
|
|
Inputs []io.Reader
|
|
Outputs []io.Writer
|
|
}
|
|
|
|
var Plugins *InOutPlugins = new(InOutPlugins)
|
|
|
|
func InitPlugins() {
|
|
for _, options := range Settings.inputDummy {
|
|
Plugins.Inputs = append(Plugins.Inputs, NewDummyInput(options))
|
|
}
|
|
|
|
for _, options := range Settings.outputDummy {
|
|
Plugins.Outputs = append(Plugins.Outputs, NewDummyOutput(options))
|
|
}
|
|
|
|
for _, options := range Settings.inputRAW {
|
|
Plugins.Inputs = append(Plugins.Inputs, NewRAWInput(options))
|
|
}
|
|
|
|
for _, options := range Settings.inputTCP {
|
|
Plugins.Inputs = append(Plugins.Inputs, NewTCPInput(options))
|
|
}
|
|
|
|
for _, options := range Settings.outputTCP {
|
|
Plugins.Outputs = append(Plugins.Outputs, NewTCPOutput(options))
|
|
}
|
|
|
|
for _, options := range Settings.inputFile {
|
|
Plugins.Inputs = append(Plugins.Inputs, NewFileInput(options))
|
|
}
|
|
|
|
for _, options := range Settings.outputFile {
|
|
Plugins.Outputs = append(Plugins.Outputs, NewFileOutput(options))
|
|
}
|
|
|
|
for _, options := range Settings.outputHTTP {
|
|
Plugins.Outputs = append(Plugins.Outputs, NewHTTPOutput(options, Settings.outputHTTPHeaders, Settings.outputHTTPMethods, Settings.outputHTTPUrlRegexp, Settings.outputHTTPHeaderFilters, Settings.outputHTTPHeaderHashFilters, Settings.outputHTTPElasticSearch))
|
|
}
|
|
}
|