func (factory *EthLogFactory) NewWorker(helper *worker.Helper) (wroker worker.Worker, err error) {
	jobInfo := new(EthLogJobInfo)
	err = json.Unmarshal(helper.Job().Data, jobInfo)
	
	if err != nil {
		return nil, err
	}
	
	proxy, err := helper.NewWorkerProxy(jobInfo.SourceJobID)
	
	if err != nil {
		return nil, err
	}
	
	logWorker := EthLogWorker{id: helper.ID(), jobInfo: jobInfo, helper: helper, sourceProxy:proxy}
	
	return &logWorker, err
}
// NewWorker implements worker.Factory.NewWorker
NewWorker implements worker.Factory.NewWorker
// NewWorker implements worker . Factory . NewWorker
func (factory *EthLogFactory) NewWorker(helper *worker.Helper) (wroker worker.Worker, err error) {
	jobInfo := new(EthLogJobInfo)
	err = json.Unmarshal(helper.Job().Data, jobInfo)
	if err != nil {
		return nil, err
	}
	proxy, err := helper.NewWorkerProxy(jobInfo.SourceJobID)
	if err != nil {
		return nil, err
	}
	logWorker := EthLogWorker{id: helper.ID(), jobInfo: jobInfo, helper: helper, sourceProxy:proxy}
	return &logWorker, err
}
func ( factory * EthLogFactory ) NewWorker ( helper * worker . Helper ) ( wroker worker . Worker , err error ) { jobInfo := new ( EthLogJobInfo ) err = json . Unmarshal ( helper . Job ( ) . Data , jobInfo ) if err != nil { return nil , err } proxy , err := helper . NewWorkerProxy ( jobInfo . SourceJobID ) if err != nil { return nil , err } logWorker := EthLogWorker { id : helper . ID ( ) , jobInfo : jobInfo , helper : helper , sourceProxy : proxy } return & logWorker , err }
NewWorker implements worker.Factory.NewWorker
NewWorker implements worker . Factory . NewWorker