closedchannels

Documentation

Index

• type Job
  • func NewJob(workingDir string) (*Job, error)
  • func (s *Job) Run() error
  • func (s *Job) Stop()

Types

type Job

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

Job contains a running job info.

func NewJob

func NewJob(workingDir string) (*Job, error)

NewJob crates a new SyncJob and given a directory for this job. It is assumed that a config file exists in this directory.

func (*Job) Run

func (s *Job) Run() error

Run executes the download filter operation synchronousely

func (*Job) Stop

func (s *Job) Stop()

Stop stops neutrino instance and wait for the syncFitlers to complete