http

Documentation

Index

• type HTTPInput
  • func (this *HTTPInput) Ack(pack *engine.Packet) error
  • func (this *HTTPInput) End(r engine.InputRunner)
  • func (this *HTTPInput) Init(config *conf.Conf)
  • func (this *HTTPInput) Run(r engine.InputRunner, h engine.PluginHelper) error
  • func (*HTTPInput) SampleConfig() string

Types

type HTTPInput

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

HTTPInput is an input plugin that receives HTTP POST payload. For cluster, there should be a load balancer sitting in front of dbusd.

func (*HTTPInput) Ack

func (this *HTTPInput) Ack(pack *engine.Packet) error

func (*HTTPInput) End

func (this *HTTPInput) End(r engine.InputRunner)

func (*HTTPInput) Init

func (this *HTTPInput) Init(config *conf.Conf)

func (*HTTPInput) Run

func (this *HTTPInput) Run(r engine.InputRunner, h engine.PluginHelper) error

func (*HTTPInput) SampleConfig

func (*HTTPInput) SampleConfig() string