httpsource

Documentation

Index

• func NewConnection(cfg config.Connection) (res itf.EventConnection, err error)
• type HTTPEventConnection
  • func (c *HTTPEventConnection) Close() (err error)
  • func (c *HTTPEventConnection) NewCache(cfg config.Cache) (res itf.EventCache, err error)
  • func (c *HTTPEventConnection) NewInput(cfg config.Input) (res itf.EventInput, err error)
  • func (c *HTTPEventConnection) NewOutput(cfg config.Output) (res itf.EventOutput, err error)
• type HTTPEventInput
  • func (s *HTTPEventInput) Close() (err error)
  • func (s *HTTPEventInput) Receive() (res <-chan itf.EventMessage, err error)
• type HTTPEventOutput
  • func (s *HTTPEventOutput) Close() (err error)
  • func (s *HTTPEventOutput) Ingest(c <-chan itf.RunnerResult) (err error)
• type HttpEventMessage
  • func (m HttpEventMessage) Ack() error
  • func (m HttpEventMessage) Data() ([]byte, error)
  • func (m HttpEventMessage) DataString() (string, error)
  • func (m HttpEventMessage) Metadata(key string) (res []string, err error)
  • func (m HttpEventMessage) Nak() error
  • func (m HttpEventMessage) ReplyTo() (string, error)
  • func (m HttpEventMessage) Time() (time.Time, error)
  • func (m HttpEventMessage) Topic() (string, error)

Functions

func NewConnection

func NewConnection(cfg config.Connection) (res itf.EventConnection, err error)

Types

type HTTPEventConnection

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

func (*HTTPEventConnection) Close

func (c *HTTPEventConnection) Close() (err error)

func (*HTTPEventConnection) NewCache

func (c *HTTPEventConnection) NewCache(cfg config.Cache) (res itf.EventCache, err error)

func (*HTTPEventConnection) NewInput

func (c *HTTPEventConnection) NewInput(cfg config.Input) (res itf.EventInput, err error)

func (*HTTPEventConnection) NewOutput

func (c *HTTPEventConnection) NewOutput(cfg config.Output) (res itf.EventOutput, err error)

type HTTPEventInput

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

func (*HTTPEventInput) Close

func (s *HTTPEventInput) Close() (err error)

func (*HTTPEventInput) Receive

func (s *HTTPEventInput) Receive() (res <-chan itf.EventMessage, err error)

type HTTPEventOutput

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

func (*HTTPEventOutput) Close

func (s *HTTPEventOutput) Close() (err error)

func (*HTTPEventOutput) Ingest

func (s *HTTPEventOutput) Ingest(c <-chan itf.RunnerResult) (err error)

type HttpEventMessage

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

func (HttpEventMessage) Ack

func (m HttpEventMessage) Ack() error

func (HttpEventMessage) Data

func (m HttpEventMessage) Data() ([]byte, error)

func (HttpEventMessage) DataString

func (m HttpEventMessage) DataString() (string, error)

func (HttpEventMessage) Metadata

func (m HttpEventMessage) Metadata(key string) (res []string, err error)

func (HttpEventMessage) Nak

func (m HttpEventMessage) Nak() error

func (HttpEventMessage) ReplyTo

func (m HttpEventMessage) ReplyTo() (string, error)

func (HttpEventMessage) Time

func (m HttpEventMessage) Time() (time.Time, error)

func (HttpEventMessage) Topic

func (m HttpEventMessage) Topic() (string, error)