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 (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
- type DBReceipt
- type DBUnbondingLock
Constants ¶
View Source
const DEBUG = 5
View Source
const SHORT = 4
View Source
const VERBOSE = 6
Variables ¶
View Source
var LivepeerDBVersion = 1
View Source
var VideoProfileIDSize = 8
View Source
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 ProfilesToTranscodeOpts ¶ added in v0.3.3
func ProfilesToTranscodeOpts(profiles []ffmpeg.VideoProfile) []byte
func TxDataToVideoProfile ¶ added in v0.3.3
func TxDataToVideoProfile(txData string) ([]ffmpeg.VideoProfile, error)
func WaitAssert ¶
Types ¶
type DB ¶ added in v0.3.3
type DB struct {
// contains filtered or unexported fields
}
func (*DB) ActiveBroadcasts ¶ added in v0.3.3
func (*DB) InsertClaim ¶ added in v0.3.3
func (*DB) InsertReceipt ¶ added in v0.3.3
func (*DB) InsertUnbondingLock ¶ added in v0.3.3
func (*DB) ReceiptBCastFilesByClaim ¶ added in v0.3.3
func (*DB) ReceiptExists ¶ added in v0.3.3
func (*DB) SetClaimStatus ¶ added in v0.3.3
func (*DB) SetSegmentCount ¶ added in v0.3.3
func (*DB) SetStopReason ¶ added in v0.3.3
func (*DB) UnbondingLocks ¶ added in v0.3.3
func (db *DB) UnbondingLocks(currentRound *big.Int) ([]*DBUnbondingLock, error)
func (*DB) UnclaimedReceipts ¶ added in v0.3.3
type DBJob ¶ added in v0.3.3
type DBReceipt ¶ added in v0.3.3
Click to show internal directories.
Click to hide internal directories.