extractor

Documentation

Index

• Constants
• type Extractor
  • func New(merc *mercury.Endpoint, input <-chan J.Job, output chan<- J.Job, ...) *Extractor
  • func (e *Extractor) Process(job J.Job)
  • func (e *Extractor) Run(wg *sync.WaitGroup)
• type JSON

Constants

const (
	FriendlyMessage = "Sorry, extraction failed."
	RetryTimes      = 3
	RetryPause      = 3 * time.Second
)

Types

type Extractor

type Extractor struct {
	Input  <-chan J.Job
	Output chan<- J.Job
	Error  chan<- J.Job
	// contains filtered or unexported fields
}

func New

func New(merc *mercury.Endpoint, input <-chan J.Job, output chan<- J.Job, error chan<- J.Job) *Extractor

func (*Extractor) Process

func (e *Extractor) Process(job J.Job)

func (*Extractor) Run

func (e *Extractor) Run(wg *sync.WaitGroup)

type JSON

type JSON map[string]interface{}