Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrBlockServiceStarted = fmt.Errorf("block service already started") ErrBlockServiceStopped = fmt.Errorf("block service already stopped") )
View Source
var ( ErrJobServiceStarted = fmt.Errorf("job service already started") ErrJobServicedStopped = fmt.Errorf("job service already stopped") CheckFirstClaimPollingInterval = time.Second * 15 )
View Source
var ( ErrRewardServiceStarted = fmt.Errorf("reward service already started") ErrRewardServiceStopped = fmt.Errorf("reward service already stopped") TryRewardPollingInterval = time.Minute * 30 // Poll to try to call reward once 30 minutes )
Functions ¶
This section is empty.
Types ¶
type BlockService ¶
type BlockService struct {
// contains filtered or unexported fields
}
func NewBlockService ¶
func NewBlockService(eventMonitor eth.EventMonitor, db *common.DB) *BlockService
func (*BlockService) IsWorking ¶
func (s *BlockService) IsWorking() bool
func (*BlockService) Start ¶
func (s *BlockService) Start(ctx context.Context) error
func (*BlockService) Stop ¶
func (s *BlockService) Stop() error
type JobService ¶
type JobService struct {
// contains filtered or unexported fields
}
func NewJobService ¶
func NewJobService(node *core.LivepeerNode) *JobService
func (*JobService) IsWorking ¶
func (s *JobService) IsWorking() bool
func (*JobService) RestartTranscoder ¶
func (s *JobService) RestartTranscoder() error
func (*JobService) Start ¶
func (s *JobService) Start(ctx context.Context) error
func (*JobService) Stop ¶
func (s *JobService) Stop() error
type RewardService ¶
type RewardService struct {
// contains filtered or unexported fields
}
func NewRewardService ¶
func NewRewardService(client eth.LivepeerEthClient) *RewardService
func (*RewardService) IsWorking ¶
func (s *RewardService) IsWorking() bool
func (*RewardService) Start ¶
func (s *RewardService) Start(ctx context.Context) error
func (*RewardService) Stop ¶
func (s *RewardService) Stop() error
type RoundsService ¶
type RoundsService struct {
// contains filtered or unexported fields
}
func NewRoundsService ¶
func NewRoundsService(eventMonitor eth.EventMonitor, client eth.LivepeerEthClient) *RoundsService
func (*RoundsService) IsWorking ¶
func (s *RoundsService) IsWorking() bool
func (*RoundsService) Start ¶
func (s *RoundsService) Start(ctx context.Context) error
func (*RoundsService) Stop ¶
func (s *RoundsService) Stop() error
type UnbondingService ¶
type UnbondingService struct {
// contains filtered or unexported fields
}
func NewUnbondingService ¶
func NewUnbondingService(client eth.LivepeerEthClient, db *common.DB) *UnbondingService
func (*UnbondingService) IsWorking ¶
func (s *UnbondingService) IsWorking() bool
func (*UnbondingService) Start ¶
func (s *UnbondingService) Start(ctx context.Context) error
func (*UnbondingService) Stop ¶
func (s *UnbondingService) Stop() error
Click to show internal directories.
Click to hide internal directories.