eventservices

Documentation

Index

• Variables
• type BlockService
  • 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
  • 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
  • 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
  • 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
  • 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

Variables

var (
	ErrBlockServiceStarted = fmt.Errorf("block service already started")
	ErrBlockServiceStopped = fmt.Errorf("block service already stopped")
)

var (
	ErrJobServiceStarted  = fmt.Errorf("job service already started")
	ErrJobServicedStopped = fmt.Errorf("job service already stopped")

	CheckFirstClaimPollingInterval = time.Second * 15
)

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
)

var (
	BlocksToWait = big.NewInt(5)

	ErrRoundsServiceStarted = fmt.Errorf("rounds service already started")
	ErrRoundsServiceStopped = fmt.Errorf("rounds service already stopped")
)

var (
	ErrUnbondingServiceStarted = fmt.Errorf("unbonding service already started")
	ErrUnbondingServiceStopped = fmt.Errorf("unbonding service already stopped")
)

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