httpsource

Documentation

Index

• type HttpSource
  • func NewHttpSource(cfg *HttpSourceConf) *HttpSource
• type HttpSourceConf
  • func (s *HttpSourceConf) IsFireAndForget() bool

Types

type HttpSource

type HttpSource struct {
	source.SourceBase
	// contains filtered or unexported fields
}

func NewHttpSource

func NewHttpSource(cfg *HttpSourceConf) *HttpSource

type HttpSourceConf

type HttpSourceConf struct {
	source.SourceConfCommon `json:",inline" yaml:",inline"`

	Port int `json:"port" yaml:"port"`
	// If set the http source will not return the processor response
	// to the caller
	IgnoreProcessorResponse bool `json:"ignoreProcessorResponse" yaml:"ignoreProcessorResponse"`
}

func (*HttpSourceConf) IsFireAndForget

func (s *HttpSourceConf) IsFireAndForget() bool