worker

package

Go to main page

Versions in this module

v1

v1.2.2

Mar 17, 2020

v1.2.0

Oct 11, 2019

Changes in this version

+ const ErrEthTxIsMined

+ const ErrTxNoGasIncrease

+ const ErrTxNotFound

type Worker

+ func (w *Worker) IncreaseTxGasPrice(job *data.Job) error

v1.1.0

Sep 19, 2019

v1.0.1

Jul 31, 2019

Changes in this version

+ const ErrPTCRetrieveAllowance

type Worker

+ func (w *Worker) AfterAccountAddBalanceApprove(job *data.Job) error

v1.0.0

Jul 1, 2019

Changes in this version

type Worker

+ func (w *Worker) ClientRecordClosing(job *data.Job) error

v0

v0.23.1

Jun 24, 2019

v0.23.0

Jun 12, 2019

Changes in this version

+ const ErrFetchOffering

type Worker

+ func (w *Worker) CompleteServiceTransition(job *data.Job) error

v0.22.0

May 9, 2019

Changes in this version

type Worker

+ func (w *Worker) ClientEndpointGet(job *data.Job) error

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)

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