Versions in this module Expand all Collapse all v0 v0.3.3 Mar 26, 2019 Changes in this version + var BlocksToWait = big.NewInt(5) + var CheckFirstClaimPollingInterval = time.Second * 15 + var ErrBlockServiceStarted = fmt.Errorf("block service already started") + var ErrBlockServiceStopped = fmt.Errorf("block service already stopped") + var ErrJobServiceStarted = fmt.Errorf("job service already started") + var ErrJobServicedStopped = fmt.Errorf("job service already stopped") + var ErrRewardServiceStarted = fmt.Errorf("reward service already started") + var ErrRewardServiceStopped = fmt.Errorf("reward service already stopped") + var ErrRoundsServiceStarted = fmt.Errorf("rounds service already started") + var ErrRoundsServiceStopped = fmt.Errorf("rounds service already stopped") + var ErrUnbondingServiceStarted = fmt.Errorf("unbonding service already started") + var ErrUnbondingServiceStopped = fmt.Errorf("unbonding service already stopped") + var TryRewardPollingInterval = time.Minute * 30 + type BlockService struct + func NewBlockService(eventMonitor eth.EventMonitor, db *common.DB) *BlockService + func (s *BlockService) IsWorking() bool + func (s *BlockService) Start(ctx context.Context) error + func (s *BlockService) Stop() error + type JobService struct + func NewJobService(node *core.LivepeerNode) *JobService + func (s *JobService) IsWorking() bool + func (s *JobService) RestartTranscoder() error + func (s *JobService) Start(ctx context.Context) error + func (s *JobService) Stop() error + type RewardService struct + func NewRewardService(client eth.LivepeerEthClient) *RewardService + func (s *RewardService) IsWorking() bool + func (s *RewardService) Start(ctx context.Context) error + func (s *RewardService) Stop() error + type RoundsService struct + func NewRoundsService(eventMonitor eth.EventMonitor, client eth.LivepeerEthClient) *RoundsService + func (s *RoundsService) IsWorking() bool + func (s *RoundsService) Start(ctx context.Context) error + func (s *RoundsService) Stop() error + type UnbondingService struct + func NewUnbondingService(client eth.LivepeerEthClient, db *common.DB) *UnbondingService + func (s *UnbondingService) IsWorking() bool + func (s *UnbondingService) Start(ctx context.Context) error + func (s *UnbondingService) Stop() error