common

Documentation

Index

• Constants
• Variables
• func DBJobToEthJob(j *DBJob) *lpTypes.Job
• func ParseBigInt(num string) (*big.Int, error)
• func ProfilesToTranscodeOpts(profiles []ffmpeg.VideoProfile) []byte
• func Retry(attempts int, sleep time.Duration, fn func() error) error
• func TxDataToVideoProfile(txData string) ([]ffmpeg.VideoProfile, error)
• func WaitAssert(t *testing.T, waitTime time.Duration, condition func() bool, msg string)
• func WaitUntil(waitTime time.Duration, condition func() bool)
• type DB
  • func InitDB(dbPath string) (*DB, error)
  • func TempDB(t *testing.T) (*DB, *sql.DB, error)
  • func (db *DB) ActiveBroadcasts(since *big.Int) ([]*DBJob, error)
  • func (db *DB) ActiveJobs(since *big.Int) ([]*DBJob, error)
  • func (db *DB) Close()
  • func (db *DB) InsertBroadcast(job *lpTypes.Job) error
  • func (db *DB) InsertClaim(jobID *big.Int, segRange [2]int64, root [32]byte) (*int64, error)
  • func (db *DB) InsertJob(job *DBJob) error
  • func (db *DB) InsertReceipt(jobID *big.Int, seqNo int64, bcastFile string, bcastHash []byte, ...) error
  • func (db *DB) InsertUnbondingLock(id *big.Int, delegator ethcommon.Address, amount, withdrawRound *big.Int) error
  • func (db *DB) LastSeenBlock() (*big.Int, error)
  • func (db *DB) ReceiptBCastFilesByClaim(claimID int64, jobID *big.Int) ([]string, error)
  • func (db *DB) ReceiptExists(jobID *big.Int, seqNo uint64) (bool, error)
  • func (db *DB) SetClaimStatus(jobID *big.Int, id int64, status string) error
  • func (db *DB) SetLastSeenBlock(block *big.Int) error
  • func (db *DB) SetSegmentCount(jobID *big.Int, count int64) error
  • func (db *DB) SetStopReason(id *big.Int, reason string) error
  • func (db *DB) UnbondingLockIDs() ([]*big.Int, error)
  • func (db *DB) UnbondingLocks(currentRound *big.Int) ([]*DBUnbondingLock, error)
  • func (db *DB) UnclaimedReceipts() (map[int64][]*DBReceipt, error)
  • func (db *DB) UseUnbondingLock(id *big.Int, delegator ethcommon.Address, usedBlock *big.Int) error
• type DBJob
  • func NewDBJob(id *big.Int, streamID string, segmentPrice *big.Int, ...) *DBJob
• type DBReceipt
• type DBUnbondingLock

Constants

const DEBUG = 5

const SHORT = 4

const VERBOSE = 6

Variables

var ErrDBTooNew = errors.New("DB Too New")

var (
	ErrParseBigInt = fmt.Errorf("failed to parse big integer")
)

var LivepeerDBVersion = 1

var VideoProfileIDSize = 8

var VideoProfileNameLookup = map[string]string{
	"a7ac137a": "P720p60fps16x9",
	"49d54ea9": "P720p30fps16x9",
	"79332fe7": "P720p30fps4x3",
	"5ecf4b52": "P576p30fps16x9",
	"93c717e7": "P360p30fps16x9",
	"b60382a0": "P360p30fps4x3",
	"c0a6517a": "P240p30fps16x9",
	"d435c53a": "P240p30fps4x3",
	"fca40bf9": "P144p30fps16x9",
}

Functions

func DBJobToEthJob

func DBJobToEthJob(j *DBJob) *lpTypes.Job

func ParseBigInt

func ParseBigInt(num string) (*big.Int, error)

func ProfilesToTranscodeOpts

func ProfilesToTranscodeOpts(profiles []ffmpeg.VideoProfile) []byte

func Retry

func Retry(attempts int, sleep time.Duration, fn func() error) error

func TxDataToVideoProfile

func TxDataToVideoProfile(txData string) ([]ffmpeg.VideoProfile, error)

func WaitAssert

func WaitAssert(t *testing.T, waitTime time.Duration, condition func() bool, msg string)

func WaitUntil

func WaitUntil(waitTime time.Duration, condition func() bool)

Types

type DB

type DB struct {
	// contains filtered or unexported fields
}

func InitDB

func InitDB(dbPath string) (*DB, error)

func TempDB

func TempDB(t *testing.T) (*DB, *sql.DB, error)

func (*DB) ActiveBroadcasts

func (db *DB) ActiveBroadcasts(since *big.Int) ([]*DBJob, error)

func (*DB) ActiveJobs

func (db *DB) ActiveJobs(since *big.Int) ([]*DBJob, error)

func (*DB) Close

func (db *DB) Close()

func (*DB) InsertBroadcast

func (db *DB) InsertBroadcast(job *lpTypes.Job) error

func (*DB) InsertClaim

func (db *DB) InsertClaim(jobID *big.Int, segRange [2]int64,
	root [32]byte) (*int64, error)

func (*DB) InsertJob

func (db *DB) InsertJob(job *DBJob) error

func (*DB) InsertReceipt

func (db *DB) InsertReceipt(jobID *big.Int, seqNo int64,
	bcastFile string, bcastHash []byte, bcastSig []byte, tcodeHash []byte,
	tcodeStartedAt time.Time, tcodeEndedAt time.Time) error

func (*DB) InsertUnbondingLock

func (db *DB) InsertUnbondingLock(id *big.Int, delegator ethcommon.Address, amount, withdrawRound *big.Int) error

func (*DB) LastSeenBlock

func (db *DB) LastSeenBlock() (*big.Int, error)

func (*DB) ReceiptBCastFilesByClaim

func (db *DB) ReceiptBCastFilesByClaim(claimID int64, jobID *big.Int) ([]string, error)

func (*DB) ReceiptExists

func (db *DB) ReceiptExists(jobID *big.Int, seqNo uint64) (bool, error)

func (*DB) SetClaimStatus

func (db *DB) SetClaimStatus(jobID *big.Int, id int64, status string) error

func (*DB) SetLastSeenBlock

func (db *DB) SetLastSeenBlock(block *big.Int) error

func (*DB) SetSegmentCount

func (db *DB) SetSegmentCount(jobID *big.Int, count int64) error

func (*DB) SetStopReason

func (db *DB) SetStopReason(id *big.Int, reason string) error

func (*DB) UnbondingLockIDs

func (db *DB) UnbondingLockIDs() ([]*big.Int, error)

func (*DB) UnbondingLocks

func (db *DB) UnbondingLocks(currentRound *big.Int) ([]*DBUnbondingLock, error)

func (*DB) UnclaimedReceipts

func (db *DB) UnclaimedReceipts() (map[int64][]*DBReceipt, error)

func (*DB) UseUnbondingLock

func (db *DB) UseUnbondingLock(id *big.Int, delegator ethcommon.Address, usedBlock *big.Int) error

type DBJob

type DBJob struct {
	ID int64

	Transcoder ethcommon.Address

	Segments int64
	// contains filtered or unexported fields
}

func NewDBJob

func NewDBJob(id *big.Int, streamID string,
	segmentPrice *big.Int, profiles []ffmpeg.VideoProfile,
	broadcaster ethcommon.Address, transcoder ethcommon.Address,
	startBlock *big.Int, endBlock *big.Int) *DBJob

type DBReceipt

type DBReceipt struct {
	JobID     int64
	SeqNo     int64
	BcastFile string
	BcastHash []byte
	BcastSig  []byte
	TcodeHash []byte
}

type DBUnbondingLock

type DBUnbondingLock struct {
	ID            int64
	Delegator     ethcommon.Address
	Amount        *big.Int
	WithdrawRound int64
}