scaningest

Documentation

Overview

Package scaningest implements an API for ingesting scan jobs, to be used with a jobqueue.

Index

• type Ingester
  • func (i *Ingester) NewJob() (*Job, error)
• type Job
  • func (j *Job) AddPage(page *page.Any) error
  • func (j *Job) Ingest() (string, error)
  • func (j *Job) ReversePages()

Types

type Ingester

type Ingester struct {
	IngestCallback func(*Job) (string, error)
}

func (*Ingester) NewJob

func (i *Ingester) NewJob() (*Job, error)

type Job

type Job struct {
	Pages []*page.Any
	// contains filtered or unexported fields
}

func (*Job) AddPage

func (j *Job) AddPage(page *page.Any) error

func (*Job) Ingest

func (j *Job) Ingest() (string, error)

func (*Job) ReversePages

func (j *Job) ReversePages()