monitor

package
v0.5.16 Latest Latest
Warning

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

 Go to latest Published: Mar 29, 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 MaxSessions added in v0.5.0 

func MaxSessions(maxSessions int)

func OrchestratorSwapped added in v0.5.14 

func OrchestratorSwapped()

func PaymentCreateError added in v0.5.0 

func PaymentCreateError(recipient string, manifestID string)

PaymentCreateError records a error from payment creation

func PaymentRecvError added in v0.5.0 

func PaymentRecvError(sender string, manifestID string, 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(sender string)

TicketRedemptionError records an error from redeeming a ticket

func TicketValueRecv added in v0.5.0 

func TicketValueRecv(sender string, manifestID string, value *big.Rat)

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

func TicketValueSent added in v0.5.0 

func TicketValueSent(recipient string, manifestID string, value *big.Rat)

TicketValueSent records the ticket value sent to a recipient for a manifestID

func TicketsRecv added in v0.5.0 

func TicketsRecv(sender string, manifestID string, numTickets int)

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

func TicketsSent added in v0.5.0 

func TicketsSent(recipient string, manifestID string, numTickets int)

TicketsSent records the number of tickets sent to a recipient for a manifestID

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(sender string, value *big.Int)

ValueRedeemed records the value from redeeming winning tickets from a sender

func WinningTicketsRecv added in v0.5.0 

func WinningTicketsRecv(sender string, numTickets int)

WinningTicketsRecv records the number of winning tickets received from a sender

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.