httpstream

Documentation

Index

• Variables
• type Config
  • func (c *Config) ConfigValidate() error
• type HttpStream
  • func NewHttpStream(config *Config) (httpStream *HttpStream, err error)
  • func (s *HttpStream) LogStreamer() func(w http.ResponseWriter, req *http.Request)

Variables

var LogSourceChan = make(chan *event.ProcessorEvent)

Types

type Config

type Config struct {
	Addr string `toml:"addr"`
}

func (*Config) ConfigValidate

func (c *Config) ConfigValidate() error

type HttpStream

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

func NewHttpStream

func NewHttpStream(config *Config) (httpStream *HttpStream, err error)

initlogStream init log stream

func (*HttpStream) LogStreamer

func (s *HttpStream) LogStreamer() func(w http.ResponseWriter, req *http.Request)

LogStreamer 接收请求