monitor

package
v0.7.4 Latest Latest
Warning

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

 Go to latest Published: Apr 2, 2024 License: MIT Imports: 17 Imported by: 1

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"
	SegmentTranscodeErrorMaxAttempts        SegmentTranscodeError = "MaxAttempts"
	SegmentTranscodeErrorNonRetryable       SegmentTranscodeError = "NonRetryable"
	SegmentTranscodeErrorCtxCancelled       SegmentTranscodeError = "CtxCancelled"
)
View Source 
const (
	//mpeg7-sign comparison fail of fast verification
	FVType1Error = 1
	//video comparison fail of fast verification
	FVType2Error = 2
)

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 ExposeClientIP bool

ExposeClientIP if true then Orchestrator exposes Broadcaster's IP address in metrics

View Source 
var NodeID string
View Source 
var PerStreamMetrics bool

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 FastVerificationDone added in v0.5.23 

func FastVerificationDone(ctx context.Context, uri string)

func FastVerificationEnabledAndUsingCurrentSessions added in v0.5.23 

func FastVerificationEnabledAndUsingCurrentSessions(enabled, using int)

func FastVerificationFailed added in v0.5.23 

func FastVerificationFailed(ctx context.Context, uri string, errtype int)

func HTTPClientTimedOut1 added in v0.5.11 

func HTTPClientTimedOut1(ctx context.Context)

func HTTPClientTimedOut2 added in v0.5.11 

func HTTPClientTimedOut2(ctx context.Context)

func InitCensus added in v0.5.0 

func InitCensus(nodeType NodeType, version string)

func LogDiscoveryError added in v0.5.0 

func LogDiscoveryError(ctx context.Context, uri, 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(ctx context.Context, milPixels float64)

func MinGasPrice added in v0.5.19 

func MinGasPrice(minGasPrice *big.Int)

func OrchestratorSwapped added in v0.5.14 

func OrchestratorSwapped(ctx context.Context)

func PaymentCreateError added in v0.5.0 

func PaymentCreateError(ctx context.Context)

PaymentCreateError records a error from payment creation

func PaymentRecvError added in v0.5.0 

func PaymentRecvError(ctx context.Context, sender 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 RewardCallError added in v0.7.2 

func RewardCallError(sender string)

RewardCallError records an error from reward calling

func SegSceneClassificationDone added in v0.5.36 

func SegSceneClassificationDone(ctx context.Context, seqNo uint64)

func SegSceneClassificationResult added in v0.5.36 

func SegSceneClassificationResult(ctx context.Context, seqNo uint64, class string, prob float64)

func SegmentDownloaded added in v0.5.13 

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

func SegmentEmerged added in v0.5.0 

func SegmentEmerged(ctx context.Context, nonce, seqNo uint64, profilesNum int, dur float64)

func SegmentFullyProcessed added in v0.5.11 

func SegmentFullyProcessed(ctx context.Context, segDur, processDur float64)

func SegmentFullyTranscoded added in v0.5.0 

func SegmentFullyTranscoded(ctx context.Context, nonce, seqNo uint64, profiles string, errCode SegmentTranscodeError, orchInfo *lpnet.OrchestratorInfo)

func SegmentTranscodeFailed added in v0.5.0 

func SegmentTranscodeFailed(ctx context.Context, subType SegmentTranscodeError, nonce, seqNo uint64, err error, permanent bool)

func SegmentTranscoded added in v0.5.0 

func SegmentTranscoded(ctx context.Context, nonce, seqNo uint64, sourceDur time.Duration, transcodeDur time.Duration, profiles string,
	trusted, verified bool)

func SegmentUploadFailed added in v0.5.0 

func SegmentUploadFailed(ctx context.Context, nonce, seqNo uint64, code SegmentUploadError, err error, permanent bool,
	uri string)

func SegmentUploaded added in v0.5.0 

func SegmentUploaded(ctx context.Context, nonce, seqNo uint64, uploadDur time.Duration, uri string)

func SetTranscodersNumberAndLoad added in v0.5.0 

func SetTranscodersNumberAndLoad(load, capacity, number int)

func SourceSegmentAppeared added in v0.5.0 

func SourceSegmentAppeared(ctx context.Context, nonce, seqNo uint64, manifestID, profile string, recordingEnabled bool)

func StreamCreated added in v0.5.0 

func StreamCreated(manifestID string, nonce uint64)

func StreamEnded added in v0.5.0 

func StreamEnded(ctx context.Context, 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(ctx context.Context, sender 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(ctx context.Context, value *big.Rat)

TicketValueSent records the ticket value sent

func TicketsRecv added in v0.5.0 

func TicketsRecv(ctx context.Context, sender 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(ctx context.Context, numTickets int)

TicketsSent records the number of tickets sent

func TranscodeTry added in v0.5.0 

func TranscodeTry(ctx context.Context, nonce, seqNo uint64)

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

func WinningTicketsRecv added in v0.5.0 

func WinningTicketsRecv(ctx context.Context, sender string, 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.