monitor

package
v0.8.3 Latest Latest
Warning

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

 Go to latest Published: Jan 30, 2025 License: MIT Imports: 23 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"
	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
)
View Source 
const (
	KafkaBatchInterval  = 1 * time.Second
	KafkaRequestTimeout = 60 * time.Second
	KafkaBatchSize      = 100
	KafkaChannelSize    = 100
)

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 AICurrentLiveSessions added in v0.8.2 

func AICurrentLiveSessions(currentPipelines int)

func AIFirstSegmentDelay added in v0.8.2 

func AIFirstSegmentDelay(delayMs int64, orchInfo *lpnet.OrchestratorInfo)

func AIJobProcessed added in v0.8.0 

func AIJobProcessed(ctx context.Context, pipeline string, model string, jobInfo AIJobInfo)

AIJobProcessed records orchestrator AI job processing metrics.

func AILiveVideoAttempt added in v0.8.2 

func AILiveVideoAttempt()

func AIProcessingError added in v0.8.0 

func AIProcessingError(code string, pipeline string, model string, sender string)

AIProcessingError logs errors in orchestrator AI job processing.

func AIRequestError added in v0.8.0 

func AIRequestError(code string, pipeline string, model string, orchInfo *lpnet.OrchestratorInfo)

AIRequestError logs an error in a gateway AI job request.

func AIRequestFinished added in v0.8.0 

func AIRequestFinished(ctx context.Context, pipeline string, model string, jobInfo AIJobInfo, orchInfo *lpnet.OrchestratorInfo)

AIRequestFinished records gateway AI job request metrics.

func AIResultDownloaded added in v0.8.0 

func AIResultDownloaded(ctx context.Context, pipeline string, model string, downloadDur time.Duration)

AIResultDownloaded logs the successful download of an AI job result.

func AIResultSaveError added in v0.8.0 

func AIResultSaveError(ctx context.Context, pipeline, model, code string)

AIResultSaveError logs an error in saving an AI job result to storage.

func AIResultUploaded added in v0.8.0 

func AIResultUploaded(ctx context.Context, uploadDur time.Duration, pipeline, model, uri string)

AIResultUploaded logs the successful upload of an AI job result.

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 gateway

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 InitKafkaProducer added in v0.8.1 

func InitKafkaProducer(bootstrapServers, user, password, topic, gatewayAddress string) error

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 MaxPriceForCapability added in v0.8.0 

func MaxPriceForCapability(pipeline string, modelName string, maxPrice *big.Rat)

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 SendQueueEventAsync added in v0.8.1 

func SendQueueEventAsync(eventType string, data interface{})

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 ToPipeline added in v0.8.0 

func ToPipeline(cap string) string

ToPipeline converts capability name into pipeline name

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 AIJobInfo added in v0.8.0 

type AIJobInfo struct {
	LatencyScore float64
	PricePerUnit float64
}

type GatewayEvent added in v0.8.1 

type GatewayEvent struct {
	ID        *string     `json:"id,omitempty"`
	Type      *string     `json:"type"`
	Timestamp *string     `json:"timestamp"`
	Gateway   *string     `json:"gateway,omitempty"`
	Data      interface{} `json:"data"`
}

type KafkaProducer added in v0.8.1 

type KafkaProducer struct {
	// contains filtered or unexported fields
}

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"
	AIWorker     NodeType = "aiwk"
)

type PipelineStatus added in v0.8.2 

type PipelineStatus struct {
	Pipeline             string      `json:"pipeline"`
	StartTime            float64     `json:"start_time"`
	LastParamsUpdateTime float64     `json:"last_params_update_time"`
	LastParams           interface{} `json:"last_params"`
	LastParamsHash       string      `json:"last_params_hash"`
	InputFPS             float64     `json:"input_fps"`
	OutputFPS            float64     `json:"output_fps"`
	LastInputTime        float64     `json:"last_input_time"`
	LastOutputTime       float64     `json:"last_output_time"`
	RestartCount         int         `json:"restart_count"`
	LastRestartTime      float64     `json:"last_restart_time"`
	LastRestartLogs      []string    `json:"last_restart_logs"`
	LastError            *string     `json:"last_error"`
	StreamID             *string     `json:"stream_id"`
}

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.