monitor

package
v0.5.7 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2020 License: MIT Imports: 13 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"
	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"
	SegmentTranscodeErrorPlaylist           SegmentTranscodeError = "Playlist"
)

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

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 InitCensus added in v0.5.0 

func InitCensus(nodeType, nodeID, 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 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 SegmentEmerged added in v0.5.0 

func SegmentEmerged(nonce, seqNo uint64, profilesNum int)

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, transcodeDur time.Duration, profiles string)

func SegmentUploadFailed added in v0.5.0 

func SegmentUploadFailed(nonce, seqNo uint64, code SegmentUploadError, reason string, 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)

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)

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 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.