webrouter

Documentation

Index

• type GraphiteFilter
  • func (f *GraphiteFilter) CleanUp()
  • func (f *GraphiteFilter) ConfigStruct() interface{}
  • func (f *GraphiteFilter) Init(config interface{}) error
  • func (f *GraphiteFilter) Prepare(fr pipeline.FilterRunner, h pipeline.PluginHelper) error
  • func (f *GraphiteFilter) ProcessMessage(pack *pipeline.PipelinePack) error
  • func (f *GraphiteFilter) ReportMsg(msg *message.Message) error
• type GraphiteFilterConfig
• type HTTPStatusFilter
  • func (f *HTTPStatusFilter) CleanUp()
  • func (f *HTTPStatusFilter) ConfigStruct() interface{}
  • func (f *HTTPStatusFilter) Init(config interface{}) error
  • func (f *HTTPStatusFilter) Prepare(fr pipeline.FilterRunner, h pipeline.PluginHelper) error
  • func (f *HTTPStatusFilter) ProcessMessage(pack *pipeline.PipelinePack) error
  • func (f *HTTPStatusFilter) ReportMsg(msg *message.Message) error
  • func (f *HTTPStatusFilter) TimerEvent() error
• type HTTPStatusFilterConfig
• type HTTPStatusStat
• type KafkaEncoder
  • func (enc *KafkaEncoder) Encode(pack *pipeline.PipelinePack) ([]byte, error)
  • func (enc *KafkaEncoder) Init(config interface{}) error
  • func (enc *KafkaEncoder) ReportMsg(msg *message.Message) error
• type KafkaFilter
  • func (f *KafkaFilter) CleanUp()
  • func (f *KafkaFilter) ConfigStruct() interface{}
  • func (f *KafkaFilter) Init(config interface{}) error
  • func (f *KafkaFilter) Prepare(fr pipeline.FilterRunner, h pipeline.PluginHelper) error
  • func (f *KafkaFilter) ProcessMessage(pack *pipeline.PipelinePack) error
  • func (f *KafkaFilter) ReportMsg(msg *message.Message) error
• type KafkaFilterConfig
• type KafkaLogItem
• type NginxLogItem

Types

type GraphiteFilter

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

func (*GraphiteFilter) CleanUp

func (f *GraphiteFilter) CleanUp()

func (*GraphiteFilter) ConfigStruct

func (f *GraphiteFilter) ConfigStruct() interface{}

func (*GraphiteFilter) Init

func (f *GraphiteFilter) Init(config interface{}) error

func (*GraphiteFilter) Prepare

func (f *GraphiteFilter) Prepare(fr pipeline.FilterRunner, h pipeline.PluginHelper) error

func (*GraphiteFilter) ProcessMessage

func (f *GraphiteFilter) ProcessMessage(pack *pipeline.PipelinePack) error

func (*GraphiteFilter) ReportMsg

func (f *GraphiteFilter) ReportMsg(msg *message.Message) error

type GraphiteFilterConfig

type GraphiteFilterConfig struct {
	OutputMsgType string `toml:"output_message_type"`
}

type HTTPStatusFilter

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

func (*HTTPStatusFilter) CleanUp

func (f *HTTPStatusFilter) CleanUp()

func (*HTTPStatusFilter) ConfigStruct

func (f *HTTPStatusFilter) ConfigStruct() interface{}

func (*HTTPStatusFilter) Init

func (f *HTTPStatusFilter) Init(config interface{}) error

func (*HTTPStatusFilter) Prepare

func (f *HTTPStatusFilter) Prepare(fr pipeline.FilterRunner, h pipeline.PluginHelper) error

func (*HTTPStatusFilter) ProcessMessage

func (f *HTTPStatusFilter) ProcessMessage(pack *pipeline.PipelinePack) error

func (*HTTPStatusFilter) ReportMsg

func (f *HTTPStatusFilter) ReportMsg(msg *message.Message) error

func (*HTTPStatusFilter) TimerEvent

func (f *HTTPStatusFilter) TimerEvent() error

type HTTPStatusFilterConfig

type HTTPStatusFilterConfig struct {
	OutputMsgType  string `toml:"output_message_type"`
	TickerInterval uint   `toml:"ticker_interval"`
}

type HTTPStatusStat

type HTTPStatusStat struct {
	HTTP500       int64   `json:"http_500"`
	HTTP501       int64   `json:"http_501"`
	HTTP502       int64   `json:"http_502"`
	HTTP503       int64   `json:"http_503"`
	HTTP504       int64   `json:"http_504"`
	HTTP505       int64   `json:"http_505"`
	AvgTimeCost   float64 `json:"avg_reqtime"`
	QueriesPerMin float64 `json:"qpm"`
	// contains filtered or unexported fields
}

type KafkaEncoder

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

func (*KafkaEncoder) Encode

func (enc *KafkaEncoder) Encode(pack *pipeline.PipelinePack) ([]byte, error)

func (*KafkaEncoder) Init

func (enc *KafkaEncoder) Init(config interface{}) error

func (*KafkaEncoder) ReportMsg

func (enc *KafkaEncoder) ReportMsg(msg *message.Message) error

type KafkaFilter

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

func (*KafkaFilter) CleanUp

func (f *KafkaFilter) CleanUp()

func (*KafkaFilter) ConfigStruct

func (f *KafkaFilter) ConfigStruct() interface{}

func (*KafkaFilter) Init

func (f *KafkaFilter) Init(config interface{}) error

func (*KafkaFilter) Prepare

func (f *KafkaFilter) Prepare(fr pipeline.FilterRunner, h pipeline.PluginHelper) error

func (*KafkaFilter) ProcessMessage

func (f *KafkaFilter) ProcessMessage(pack *pipeline.PipelinePack) error

func (*KafkaFilter) ReportMsg

func (f *KafkaFilter) ReportMsg(msg *message.Message) error

type KafkaFilterConfig

type KafkaFilterConfig struct {
	OutputMsgType string `toml:"output_message_type"`
}

type KafkaLogItem

type KafkaLogItem struct {
	Hostname string `json:"hostname"`
	Message  string `json:"message"`
}

type NginxLogItem

type NginxLogItem struct {
	RemoteAddr           string `json:"remote_addr"`
	RemoteUser           string `json:"remote_user"`
	TimeLocal            string `json:"time_local"`
	Host                 string `json:"host"`
	Request              string `json:"request"`
	Status               int    `json:"status"`
	BodyBytesSent        int    `json:"body_bytes_sent"`
	HTTPReferer          string `json:"http_referer"`
	HTTPUserAgent        string `json:"http_user_agent"`
	HTTPXForwardedFor    string `json:"http_x_forwarded_for"`
	UpstreamResponseTime string `json:"upstream_response_time"`
	RequestTime          string `json:"request_time"`
}