extractor

package
v0.0.0-...-f46418c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 24, 2018 License: LGPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

This section is empty.

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{}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL