monitor

package
v0.5.20 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 13, 2021 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SegmentUploadErrorUnknown               SegmentUploadError    = "Unknown"
	SegmentUploadErrorGenCreds              SegmentUploadError    = "GenCreds"
	SegmentUploadErrorOS                    SegmentUploadError    = "ObjectStorage"
	SegmentUploadErrorSessionEnded          SegmentUploadError    = "SessionEnded"
	SegmentUploadErrorInsufficientBalance   SegmentUploadError    = "InsufficientBalance"
	SegmentUploadErrorTimeout               SegmentUploadError    = "Timeout"
	SegmentUploadErrorDuplicateSegment      SegmentUploadError    = "DuplicateSegment"
	SegmentUploadErrorOrchestratorCapped    SegmentUploadError    = "OrchestratorCapped"
	SegmentTranscodeErrorUnknown            SegmentTranscodeError = "Unknown"
	SegmentTranscodeErrorUnknownResponse    SegmentTranscodeError = "UnknownResponse"
	SegmentTranscodeErrorTranscode          SegmentTranscodeError = "Transcode"
	SegmentTranscodeErrorOrchestratorBusy   SegmentTranscodeError = "OrchestratorBusy"
	SegmentTranscodeErrorOrchestratorCapped SegmentTranscodeError = "OrchestratorCapped"
	SegmentTranscodeErrorParseResponse      SegmentTranscodeError = "ParseResponse"
	SegmentTranscodeErrorReadBody           SegmentTranscodeError = "ReadBody"
	SegmentTranscodeErrorNoOrchestrators    SegmentTranscodeError = "NoOrchestrators"
	SegmentTranscodeErrorDownload           SegmentTranscodeError = "Download"
	SegmentTranscodeErrorSaveData           SegmentTranscodeError = "SaveData"
	SegmentTranscodeErrorSessionEnded       SegmentTranscodeError = "SessionEnded"
	SegmentTranscodeErrorDuplicateSegment   SegmentTranscodeError = "DuplicateSegment"
)

Variables

View Source 
var Enabled bool

Enabled true if metrics was enabled in command line

View Source 
var Exporter *prometheus.Exporter

Exporter Prometheus exporter that handles `/metrics` endpoint

View Source 
var NodeID string

Functions

func AuthWebhookFinished added in v0.5.5 

func AuthWebhookFinished(dur time.Duration)

func CurrentSessions added in v0.5.0 

func CurrentSessions(currentSessions int)

func Deposit added in v0.5.9 

func Deposit(sender string, deposit *big.Int)

Deposit records the current deposit for the broadcaster

func HTTPClientTimedOut1 added in v0.5.11 

func HTTPClientTimedOut1()

func HTTPClientTimedOut2 added in v0.5.11 

func HTTPClientTimedOut2()

func InitCensus added in v0.5.0 

func InitCensus(nodeType NodeType, version string)

func LogDiscoveryError added in v0.5.0 

func LogDiscoveryError(code string)

LogDiscoveryError records discovery error

func MaxGasPrice added in v0.5.19 

func MaxGasPrice(maxGasPrice *big.Int)

func MaxSessions added in v0.5.0 

func MaxSessions(maxSessions int)

func MaxTranscodingPrice added in v0.5.19 

func MaxTranscodingPrice(maxPrice *big.Rat)

func MilPixelsProcessed added in v0.5.19 

func MilPixelsProcessed(milPixels float64)

func MinGasPrice added in v0.5.19 

func MinGasPrice(minGasPrice *big.Int)

func OrchestratorSwapped added in v0.5.14 

func OrchestratorSwapped()

func PaymentCreateError added in v0.5.0 

func PaymentCreateError()

PaymentCreateError records a error from payment creation

func PaymentRecvError added in v0.5.0 

func PaymentRecvError(errStr string)

PaymentRecvError records an error from receiving a payment

func RecordingPlaylistSaved added in v0.5.14 

func RecordingPlaylistSaved(dur time.Duration, err error)

func RecordingSegmentSaved added in v0.5.14 

func RecordingSegmentSaved(dur time.Duration, err error)

func Reserve added in v0.5.9 

func Reserve(sender string, reserve *big.Int)

func SegmentDownloaded added in v0.5.13 

func SegmentDownloaded(nonce, seqNo uint64, downloadDur time.Duration)

func SegmentEmerged added in v0.5.0 

func SegmentEmerged(nonce, seqNo uint64, profilesNum int, dur float64)

func SegmentFullyProcessed added in v0.5.11 

func SegmentFullyProcessed(segDur, processDur float64)

func SegmentFullyTranscoded added in v0.5.0 

func SegmentFullyTranscoded(nonce, seqNo uint64, profiles string, errCode SegmentTranscodeError)

func SegmentTranscodeFailed added in v0.5.0 

func SegmentTranscodeFailed(subType SegmentTranscodeError, nonce, seqNo uint64, err error, permanent bool)

func SegmentTranscoded added in v0.5.0 

func SegmentTranscoded(nonce, seqNo uint64, sourceDur time.Duration, transcodeDur time.Duration, profiles string)

func SegmentUploadFailed added in v0.5.0 

func SegmentUploadFailed(nonce, seqNo uint64, code SegmentUploadError, err error, permanent bool)

func SegmentUploaded added in v0.5.0 

func SegmentUploaded(nonce, seqNo uint64, uploadDur time.Duration)

func SetTranscodersNumberAndLoad added in v0.5.0 

func SetTranscodersNumberAndLoad(load, capacity, number int)

func SourceSegmentAppeared added in v0.5.0 

func SourceSegmentAppeared(nonce, seqNo uint64, manifestID, profile string, recordingEnabled bool)

func StreamCreateFailed added in v0.5.0 

func StreamCreateFailed(nonce uint64, reason string)

func StreamCreated added in v0.5.0 

func StreamCreated(hlsStrmID string, nonce uint64)

func StreamEnded added in v0.5.0 

func StreamEnded(nonce uint64)

func StreamStarted added in v0.5.0 

func StreamStarted(nonce uint64)

func SuggestedGasPrice added in v0.5.0 

func SuggestedGasPrice(gasPrice *big.Int)

SuggestedGasPrice records the last suggested gas price

func TicketRedemptionError added in v0.5.0 

func TicketRedemptionError()

TicketRedemptionError records an error from redeeming a ticket

func TicketValueRecv added in v0.5.0 

func TicketValueRecv(value *big.Rat)

TicketValueRecv records the ticket value received from a sender for a manifestID

func TicketValueSent added in v0.5.0 

func TicketValueSent(value *big.Rat)

TicketValueSent records the ticket value sent

func TicketsRecv added in v0.5.0 

func TicketsRecv(numTickets int)

TicketsRecv records the number of tickets received from a sender for a manifestID

func TicketsSent added in v0.5.0 

func TicketsSent(numTickets int)

TicketsSent records the number of tickets sent

func TranscodeTry added in v0.5.0 

func TranscodeTry(nonce, seqNo uint64)

func TranscodedSegmentAppeared added in v0.5.0 

func TranscodedSegmentAppeared(nonce, seqNo uint64, profile string, recordingEnabled bool)

func TranscodingPrice added in v0.5.0 

func TranscodingPrice(sender string, price *big.Rat)

TranscodingPrice records the last transcoding price

func ValueRedeemed added in v0.5.0 

func ValueRedeemed(value *big.Int)

ValueRedeemed records the value from redeeming winning tickets

func WinningTicketsRecv added in v0.5.0 

func WinningTicketsRecv(numTickets int)

WinningTicketsRecv records the number of winning tickets received

Types

type NodeType added in v0.5.13 

type NodeType string
const (
	Default      NodeType = "dflt"
	Orchestrator NodeType = "orch"
	Broadcaster  NodeType = "bctr"
	Transcoder   NodeType = "trcr"
	Redeemer     NodeType = "rdmr"
)

type SegmentTranscodeError added in v0.5.0 

type SegmentTranscodeError string

type SegmentUploadError added in v0.5.0 

type SegmentUploadError string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.