beater

Documentation

Index

• func HandleWrapper(s *Server, fn HandleFunc) httprouter.Handle
• func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
• func Run(auth TokenAuth, events chan *common.MapStr) error
• type HandleFunc
• type HapiMessage
  • func (m *HapiMessage) UnmarshalJSON(raw []byte) error
• type HttpBeat
  • func (bt *HttpBeat) Run(b *beat.Beat) (err error)
  • func (bt *HttpBeat) Stop()
• type Server
  • func (s *Server) Events(w http.ResponseWriter, r *http.Request, p httprouter.Params) error
• type TokenAuth
  • func (a TokenAuth) Enabled() bool
  • func (a TokenAuth) Verify(req *http.Request) bool

Functions

func HandleWrapper

func HandleWrapper(s *Server, fn HandleFunc) httprouter.Handle

func New

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

Creates beater

func Run

func Run(auth TokenAuth, events chan *common.MapStr) error

Types

type HandleFunc

type HandleFunc func(http.ResponseWriter, *http.Request, httprouter.Params) error

type HapiMessage

type HapiMessage struct {
	Host   string `json:"host"`
	Schema string `json:"schema"`
	//Timestamp time.Time        `json:"timeStamp"`
	Events []*common.MapStr `json"events"`
}

func (*HapiMessage) UnmarshalJSON

func (m *HapiMessage) UnmarshalJSON(raw []byte) error

type HttpBeat

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

func (*HttpBeat) Run

func (bt *HttpBeat) Run(b *beat.Beat) (err error)

func (*HttpBeat) Stop

func (bt *HttpBeat) Stop()

type Server

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

func (*Server) Events

func (s *Server) Events(w http.ResponseWriter, r *http.Request, p httprouter.Params) error

type TokenAuth

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

func (TokenAuth) Enabled

func (a TokenAuth) Enabled() bool

func (TokenAuth) Verify

func (a TokenAuth) Verify(req *http.Request) bool