common

Oct 4, 2023

Changes in this version

+ type PerfScore struct

+ Mu sync.Mutex

+ Scores map[ethcommon.Address]float64

+ type SelectionAlgorithm interface

+ Select func(addrs []ethcommon.Address, stakes map[ethcommon.Address]int64, ...) ethcommon.Address

Feb 15, 2023

Changes in this version

+ func ParseEthAddr(strJsonKey string) (string, error)

Oct 21, 2022

Changes in this version

+ func ReadFromFile(s string) (string, error)

type NodeStatus

+ BroadcasterPrices map[string]*big.Rat

Aug 16, 2022

Changes in this version

+ var MinSegmentUploadTimeout = 2 * time.Second

Jul 18, 2022

Changes in this version

+ type OrchestratorDescriptor struct

+ LocalInfo *OrchestratorLocalInfo

+ RemoteInfo *net.OrchestratorInfo

+ type OrchestratorDescriptors []OrchestratorDescriptor

+ func FromRemoteInfos(infos []*net.OrchestratorInfo) OrchestratorDescriptors

+ func (ds OrchestratorDescriptors) GetRemoteInfos() []*net.OrchestratorInfo

May 24, 2022

Changes in this version

+ var HTTPDialTimeout = 2 * time.Second

+ var SegHttpPushTimeoutMultiplier = 4.0

+ var SegUploadTimeoutMultiplier = 0.5

+ var WebhookDiscoveryRefreshInterval = 1 * time.Minute

May 11, 2022

Changes in this version

+ var ErrChromaFormat = fmt.Errorf("unknown VideoProfile ChromaFormat")

+ func ParseAccelDevices(devices string, acceleration ffmpeg.Acceleration) ([]string, error)

Feb 11, 2022

Changes in this version

+ var ErrProfEncoder = fmt.Errorf("unknown VideoProfile encoder for protobufs")

type DB

+ func (db *DB) IsOrchActive(addr ethcommon.Address, round *big.Int) (bool, error)

Dec 21, 2021

Changes in this version

+ const Score_Trusted

+ const Score_Untrusted

+ var RandomUintUnder = func(max uint) uint

+ var SegmentUploadTimeout = 2 * time.Second

+ type DetectionWebhookRequest struct

+ ManifestID string

+ SceneClassification []SceneClassificationResult

+ SeqNo uint64

+ type NodeStatus struct

+ GOArch string

+ GOOS string

+ GolangRuntimeVersion string

+ InternalManifests map[string]string

+ LocalTranscoding bool

+ Manifests map[string]*m3u8.MasterPlaylist

+ OrchestratorPool []string

+ OrchestratorPoolInfos []OrchestratorLocalInfo

+ RegisteredTranscoders []RemoteTranscoderInfo

+ RegisteredTranscodersNumber int

+ StreamInfo map[string]StreamInfo

+ Version string

+ type OrchestratorLocalInfo struct

+ Score float32

+ URL *url.URL

+ func (u *OrchestratorLocalInfo) MarshalJSON() ([]byte, error)

type OrchestratorPool

+ GetInfo func(uri string) OrchestratorLocalInfo

+ GetInfos func() []OrchestratorLocalInfo

+ SizeWith func(ScorePred) int

+ type RemoteTranscoderInfo struct

+ Address string

+ Capacity int

+ type SceneClassificationResult struct

+ Name string

+ Probability float64

+ type ScorePred = func(float32) bool

+ func ScoreAtLeast(minScore float32) ScorePred

+ func ScoreEqualTo(neededScore float32) ScorePred

+ type StreamInfo struct

+ SourceBytes uint64

+ TranscodedBytes uint64

Oct 28, 2021

Changes in this version

type DBOrchFilter

+ UpdatedLastDay bool

May 18, 2021

Changes in this version

+ func ParseNvidiaDevices(nvidia string) ([]string, error)

Apr 13, 2021

Changes in this version

+ var MaxDuration = (5 * time.Minute)

+ var MaxSegSize = int(MaxDuration.Seconds()) * (maxInputBitrate / 8)

+ func ReadAtMost(r io.Reader, n int) ([]byte, error)

Dec 14, 2020

Changes in this version

+ func JoinURL(url, path string) string

+ func TypeByExtension(ext string) (string, error)

Oct 30, 2020

Changes in this version

+ func IgnoreRoutines() []goleak.Option

Oct 22, 2020

Changes in this version

+ var RandomBytesGenerator = func(length uint) []byte

Aug 6, 2020

Changes in this version

+ var ErrProfName = fmt.Errorf("unknown VideoProfile profile name")

+ type CapabilityComparator interface

+ CompatibleWith func(*net.Capabilities) bool

+ LegacyOnly func() bool

Jul 6, 2020

Changes in this version

+ var ErrProfProto = fmt.Errorf("unknown VideoProfile profile for protobufs")

+ func EncoderProfileNameToValue(profile string) ffmpeg.Profile

type DB

+ func (db *DB) MarkWinningTicketRedeemed(ticket *pm.SignedTicket, txHash ethcommon.Hash) error

+ func (db *DB) RemoveWinningTicket(ticket *pm.SignedTicket) error

+ func (db *DB) SelectEarliestWinningTicket(sender ethcommon.Address) (*pm.SignedTicket, error)

+ func (db *DB) WinningTicketCount(sender ethcommon.Address) (int, error)

Apr 21, 2020

Changes in this version

+ var ErrFormatExt = fmt.Errorf("unknown VideoProfile format for extension")

+ var ErrFormatMime = fmt.Errorf("unknown VideoProfile format for mime type")

+ var ErrFormatProto = fmt.Errorf("unknown VideoProfile format for protobufs")

+ func ProfileExtensionFormat(ext string) ffmpeg.Format

+ func ProfileFormatExtension(f ffmpeg.Format) (string, error)

+ func ProfileFormatMimeType(f ffmpeg.Format) (string, error)

+ type Suspender interface

+ Suspended func(orch string) int

Mar 12, 2020

Changes in this version

+ func FixedToPrice(price int64) *big.Rat

+ func RatPriceInfo(priceInfo *net.PriceInfo) (*big.Rat, error)

Feb 5, 2020

Changes in this version

+ func ToInt64(val *big.Int) int64

+ type RoundsManager interface

+ LastInitializedRound func() *big.Int

Jan 11, 2020

Changes in this version

+ func BaseTokenAmountToFixed(baseAmount *big.Int) (int64, error)

+ func DefaultProfileName(width int, height int, bitrate int) string

+ func FFmpegProfiletoNetProfile(ffmpegProfiles []ffmpeg.VideoProfile) ([]*net.VideoProfile, error)

+ func GetPass(s string) (string, error)

type DBOrch

+ Stake int64

type DBOrchFilter

+ Addresses []ethcommon.Address

Dec 3, 2019

Changes in this version

+ type Broadcaster interface

+ Address func() ethcommon.Address

+ Sign func([]byte) ([]byte, error)

type DB

+ func (db *DB) OrchCount(filter *DBOrchFilter) (int, error)

type DBOrch

+ ActivationRound int64

+ DeactivationRound int64

type DBOrchFilter

+ CurrentRound *big.Int

+ type OrchestratorPool interface

+ GetOrchestrators func(int) ([]*net.OrchestratorInfo, error)

+ GetURLs func() []*url.URL

+ Size func() int

+ type OrchestratorStore interface

+ OrchCount func(filter *DBOrchFilter) (int, error)

+ SelectOrchs func(filter *DBOrchFilter) ([]*DBOrch, error)

+ UpdateOrch func(orch *DBOrch) error

Oct 29, 2019

Changes in this version

+ const HTTPTimeout

+ const VideoProfileIDBytes

+ var ErrProfile = fmt.Errorf("failed to parse profile")

+ var RandomIDGenerator = func(length uint) string

+ var VideoProfileByteLookup = makeVideoProfileByteMap()

+ func BytesToVideoProfile(txData []byte) ([]ffmpeg.VideoProfile, error)

+ func GenErrRegex(errStrings []string) *regexp.Regexp

+ func GetConnectionAddr(ctx context.Context) string

+ func MaxUint256OrFatal(t *testing.T) *big.Int

+ func PriceToFixed(price *big.Rat) (int64, error)

+ func ProfilesNames(profiles []ffmpeg.VideoProfile) string

+ func ProfilesToHex(profiles []ffmpeg.VideoProfile) string

+ func RandName() string

type DB

+ func (db *DB) ChainID() (*big.Int, error)

+ func (db *DB) DeleteMiniHeader(hash ethcommon.Hash) error

+ func (db *DB) DeleteUnbondingLock(id *big.Int, delegator ethcommon.Address) error

+ func (db *DB) FindAllMiniHeadersSortedByNumber() ([]*blockwatch.MiniHeader, error)

+ func (db *DB) FindLatestMiniHeader() (*blockwatch.MiniHeader, error)

+ func (db *DB) InsertMiniHeader(header *blockwatch.MiniHeader) error

+ func (db *DB) LoadWinningTickets(sessionIDs []string) (tickets []*pm.Ticket, sigs [][]byte, recipientRands []*big.Int, err error)

+ func (db *DB) SelectOrchs(filter *DBOrchFilter) ([]*DBOrch, error)

+ func (db *DB) SetChainID(id *big.Int) error

+ func (db *DB) StoreWinningTicket(sessionID string, ticket *pm.Ticket, sig []byte, recipientRand *big.Int) error

+ func (db *DB) UpdateOrch(orch *DBOrch) error

+ type DBOrch struct

+ EthereumAddr string

+ PricePerPixel int64

+ ServiceURI string

+ func NewDBOrch(serviceURI string, orchAddr string) *DBOrch

+ type DBOrchFilter struct

+ MaxPrice *big.Rat

+ type StubServerStream struct

+ func (s *StubServerStream) Context() context.Context

+ func (s *StubServerStream) RecvMsg(m interface{}) error

+ func (s *StubServerStream) Send(n *net.NotifySegment) error

+ func (s *StubServerStream) SendHeader(md metadata.MD) error

+ func (s *StubServerStream) SendMsg(m interface{}) error

+ func (s *StubServerStream) SetHeader(md metadata.MD) error

+ func (s *StubServerStream) SetTrailer(md metadata.MD)

+ type VideoProfileByteMap map[[VideoProfileIDBytes]byte]string

Mar 26, 2019

Changes in this version

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

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

+ var LivepeerDBVersion = 1

+ func DBJobToEthJob(j *DBJob) *lpTypes.Job

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

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

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

+ type DB struct

+ 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 struct

+ ID int64

+ Segments int64

+ Transcoder ethcommon.Address

+ func NewDBJob(id *big.Int, streamID string, segmentPrice *big.Int, ...) *DBJob

+ type DBReceipt struct

+ BcastFile string

+ BcastHash []byte

+ BcastSig []byte

+ JobID int64

+ SeqNo int64

+ TcodeHash []byte

+ type DBUnbondingLock struct

+ Amount *big.Int

+ Delegator ethcommon.Address

+ ID int64

+ WithdrawRound int64

Dec 18, 2017

Changes in this version

+ const DEBUG

+ const SHORT

+ const VERBOSE

+ var VideoProfileIDSize = 8

+ var VideoProfileNameLookup = map[string]string

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

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

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