beater

Documentation

Index

• func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
• type HttpEvent
  • func (h *HttpEvent) ToMapStr() common.MapStr
• type Httpbeat
  • func (h *Httpbeat) Cleanup(b *beat.Beat) error
  • func (h *Httpbeat) Run(b *beat.Beat) error
  • func (h *Httpbeat) Stop()
• type Poller
  • func NewPooler(httpbeat *Httpbeat, config config.HostConfig) *Poller
  • func (p *Poller) GetResponseHeader(response gorequest.Response) map[string]string
  • func (p *Poller) Run()
  • func (p *Poller) Stop()
• type Request
• type Response

Functions

func New

func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)

Types

type HttpEvent

type HttpEvent struct {
	ReadTime     time.Time
	DocumentType string
	Fields       map[string]string
	Request      Request
	Response     Response
}

func (*HttpEvent) ToMapStr

func (h *HttpEvent) ToMapStr() common.MapStr

type Httpbeat

type Httpbeat struct {
	HbConfig config.ConfigSettings
	// contains filtered or unexported fields
}

func (*Httpbeat) Cleanup

func (h *Httpbeat) Cleanup(b *beat.Beat) error

func (*Httpbeat) Run

func (h *Httpbeat) Run(b *beat.Beat) error

func (*Httpbeat) Stop

func (h *Httpbeat) Stop()

type Poller

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

func NewPooler

func NewPooler(httpbeat *Httpbeat, config config.HostConfig) *Poller

func (*Poller) GetResponseHeader

func (p *Poller) GetResponseHeader(response gorequest.Response) map[string]string

func (*Poller) Run

func (p *Poller) Run()

func (*Poller) Stop

func (p *Poller) Stop()

type Request

type Request struct {
	Url     string            `json:"url"`
	Method  string            `json:"method"`
	Headers map[string]string `json:"headers,omitempty"`
	Body    string            `json:"body,omitempty"`
}

type Response

type Response struct {
	StatusCode   int                    `json:"code"`
	StatusPhrase string                 `json:"phrase"`
	Headers      map[string]string      `json:"headers,omitempty"`
	Body         string                 `json:"body,omitempty"`
	JsonBody     map[string]interface{} `json:"jsonBody,omitempty"`
}