http

Documentation

Index

• func CustomHeadersHandler(h http.Handler, header http.Header) http.Handler
• type HttpListenInput
  • func (hli *HttpListenInput) Init(pcf *plugins.PluginCommonConfig, conf toml.Primitive) (err error)
  • func (hli *HttpListenInput) RequestHandler(w http.ResponseWriter, req *http.Request)
  • func (hli *HttpListenInput) Run(runner plugins.InputRunner) (err error)
  • func (hli *HttpListenInput) Stop()
• type HttpListenInputConfig

Functions

func CustomHeadersHandler

func CustomHeadersHandler(h http.Handler, header http.Header) http.Handler

Types

type HttpListenInput

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

func (*HttpListenInput) Init

func (hli *HttpListenInput) Init(pcf *plugins.PluginCommonConfig, conf toml.Primitive) (err error)

func (*HttpListenInput) RequestHandler

func (hli *HttpListenInput) RequestHandler(w http.ResponseWriter, req *http.Request)

func (*HttpListenInput) Run

func (hli *HttpListenInput) Run(runner plugins.InputRunner) (err error)

func (*HttpListenInput) Stop

func (hli *HttpListenInput) Stop()

type HttpListenInputConfig

type HttpListenInputConfig struct {
	// TCP Address to listen to for incoming requests.
	// Defaults to "127.0.0.1:8325".
	Address        string
	Headers        http.Header
	RequestHeaders []string `toml:"request_headers"`
}

HTTP Listen Input config struct