Versions in this module Expand all Collapse all v0 v0.21.1 Apr 1, 2019 Changes in this version + const ErrAccountNotFound + const ErrAddJob + const ErrChallengePeriodIsNotOver + const ErrChannelNotFound + const ErrChannelReceiptBalance + const ErrDecryptEndpointMsg + const ErrEndpointMsgSeal + const ErrEndpointNotFound + const ErrEthGetTransaction + const ErrEthLatestBlockNumber + const ErrEthLogChannelMismatch + const ErrEthLogNotFound + const ErrEthRetrieveBalance + const ErrEthTxInPendingState + const ErrFailedStartService + const ErrFailedStopService + const ErrFindApprovalBalanceData + const ErrFindOfferings + const ErrGeneratePasswordHash + const ErrGetEndpoint + const ErrInsufficientEthBalance + const ErrInsufficientPSCBalance + const ErrInsufficientPTCBalance + const ErrInternal + const ErrInvalidChannelStatus + const ErrInvalidEndpoint + const ErrInvalidJob + const ErrInvalidServiceStatus + const ErrMakeEndpointMsg + const ErrNoReceiptSignature + const ErrOfferNotCorrespondToTemplate + const ErrOfferNotRegistered + const ErrOfferingDeletePeriodIsNotOver + const ErrOfferingDeposit + const ErrOfferingExists + const ErrOfferingNoSupply + const ErrOfferingNotActive + const ErrOfferingNotFound + const ErrPSCAddBalance + const ErrPSCCooperativeClose + const ErrPSCCreateChannel + const ErrPSCGetChannelInfo + const ErrPSCOfferingSupply + const ErrPSCPopUpOffering + const ErrPSCRegisterOffering + const ErrPSCRemoveOffering + const ErrPSCRetrieveBalance + const ErrPSCReturnBalance + const ErrPSCSettle + const ErrPSCTopUpChannel + const ErrPSCUncooperativeClose + const ErrPTCIncreaseApproval + const ErrPTCRetrieveBalance + const ErrParseEthAddr + const ErrParseEthLog + const ErrParseJobData + const ErrParseOfferingHash + const ErrParsePrivateKey + const ErrPopUpPeriodIsNotOver + const ErrProductNotFound + const ErrPublishEndpoint + const ErrPublishOffering + const ErrRecoverClientPubKey + const ErrSOMCNoOfferings + const ErrSignClosingMsg + const ErrSmallDeposit + const ErrTemplateByHashNotFound + const ErrTemplateNotFound + const ErrTerminateChannel + const ErrTorNoSet + const ErrUncompletedJobsExists + const ErrUserNotFound + const ErrWrongLogNonIndexedArgsNumber + const ErrWrongLogTopicsNumber + const ErrWrongOfferingMsgSignature + type ClientPreChannelCreateData struct + Account string + Deposit uint64 + GasPrice uint64 + Offering string + type ClientPreChannelTopUpData struct + Channel string + GasPrice uint64 + type GasConf struct + PSC struct{ ... } + PTC struct{ ... } + type Worker struct + func NewWorker(logger log.Logger, db *reform.DB, ethBack eth.Backend, gasConc *GasConf, ...) (*Worker, error) + func (w *Worker) AccountUpdateBalances(job *data.Job) error + func (w *Worker) AfterAccountAddBalance(job *data.Job) error + func (w *Worker) AfterAccountReturnBalance(job *data.Job) error + func (w *Worker) AgentAfterChannelCreate(job *data.Job) error + func (w *Worker) AgentAfterChannelTopUp(job *data.Job) error + func (w *Worker) AgentAfterCooperativeClose(job *data.Job) error + func (w *Worker) AgentAfterOfferingDelete(job *data.Job) error + func (w *Worker) AgentAfterOfferingMsgBCPublish(job *data.Job) error + func (w *Worker) AgentAfterOfferingPopUp(job *data.Job) error + func (w *Worker) AgentAfterUncooperativeClose(job *data.Job) error + func (w *Worker) AgentAfterUncooperativeCloseRequest(job *data.Job) error + func (w *Worker) AgentPreEndpointMsgCreate(job *data.Job) error + func (w *Worker) AgentPreOfferingDelete(job *data.Job) error + func (w *Worker) AgentPreOfferingMsgBCPublish(job *data.Job) error + func (w *Worker) AgentPreOfferingPopUp(job *data.Job) error + func (w *Worker) AgentPreServiceSuspend(job *data.Job) error + func (w *Worker) AgentPreServiceTerminate(job *data.Job) error + func (w *Worker) AgentPreServiceUnsuspend(job *data.Job) error + func (w *Worker) ClientAfterChannelCreate(job *data.Job) error + func (w *Worker) ClientAfterChannelTopUp(job *data.Job) error + func (w *Worker) ClientAfterCooperativeClose(job *data.Job) error + func (w *Worker) ClientAfterOfferingDelete(job *data.Job) error + func (w *Worker) ClientAfterOfferingMsgBCPublish(job *data.Job) error + func (w *Worker) ClientAfterOfferingPopUp(job *data.Job) error + func (w *Worker) ClientAfterUncooperativeClose(job *data.Job) error + func (w *Worker) ClientAfterUncooperativeCloseRequest(job *data.Job) error + func (w *Worker) ClientCompleteServiceTransition(job *data.Job) error + func (w *Worker) ClientEndpointCreate(job *data.Job) error + func (w *Worker) ClientPreChannelCreate(job *data.Job) error + func (w *Worker) ClientPreChannelTopUp(job *data.Job) error + func (w *Worker) ClientPreServiceSuspend(job *data.Job) error + func (w *Worker) ClientPreServiceTerminate(job *data.Job) error + func (w *Worker) ClientPreServiceUnsuspend(job *data.Job) error + func (w *Worker) ClientPreUncooperativeClose(job *data.Job) error + func (w *Worker) ClientPreUncooperativeCloseRequest(job *data.Job) error + func (w *Worker) DecrementCurrentSupply(job *data.Job) error + func (w *Worker) IncrementCurrentSupply(job *data.Job) error + func (w *Worker) PreAccountAddBalance(job *data.Job) error + func (w *Worker) PreAccountAddBalanceApprove(job *data.Job) error + func (w *Worker) PreAccountReturnBalance(job *data.Job) error + func (w *Worker) SetProcessor(processor *proc.Processor) + func (w *Worker) SetQueue(queue job.Queue)