ingressobs

package
v1.45.8 Latest Latest
Warning

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

Go to latest
Published: May 6, 2026 License: Apache-2.0 Imports: 1 Imported by: 0

Documentation

Overview

Code generated; DO NOT EDIT.

Index

Constants

View Source
const Version_HPUAOT8 = true

Variables

This section is empty.

Functions

This section is empty.

Types

type IngressReporter

type IngressReporter interface {
	RegisterFunc(func(ts time.Time, tx IngressTx) bool)
	Tx(func(tx IngressTx))
	TxAt(time.Time, func(tx IngressTx))
	WithSession(id string) SessionReporter
	WithDeferredSession() (SessionReporter, KeyResolver)
	// contains filtered or unexported methods
}

func NewNoopIngressReporter

func NewNoopIngressReporter() IngressReporter

type IngressTx

type IngressTx interface {
	Project() ProjectTx
	// contains filtered or unexported methods
}

type KeyResolver

type KeyResolver interface {
	Resolve(string)
	Reset()
}

type ProjectReporter

type ProjectReporter interface {
	RegisterFunc(func(ts time.Time, tx ProjectTx) bool)
	Tx(func(tx ProjectTx))
	TxAt(time.Time, func(tx ProjectTx))
	WithIngress(id string) IngressReporter
	WithDeferredIngress() (IngressReporter, KeyResolver)
	// contains filtered or unexported methods
}

func NewNoopProjectReporter

func NewNoopProjectReporter() ProjectReporter

type ProjectTx

type ProjectTx interface {
	// contains filtered or unexported methods
}

type Reporter

type Reporter interface {
	WithProject(id string) ProjectReporter
	WithDeferredProject() (ProjectReporter, KeyResolver)
}

func NewNoopReporter

func NewNoopReporter() Reporter

type Rollup

type Rollup string
const (
	RollupUndefined      Rollup = ""
	RollupProject        Rollup = "project"
	RollupIngress        Rollup = "ingress"
	RollupSessionIndex   Rollup = "session_index"
	RollupStartTimeIndex Rollup = "start_time_index"
	RollupEndTimeIndex   Rollup = "end_time_index"
)

type SessionInputType

type SessionInputType string
const (
	SessionInputTypeUndefined SessionInputType = ""
	SessionInputTypeRtmp      SessionInputType = "rtmp"
	SessionInputTypeWhip      SessionInputType = "whip"
	SessionInputTypeURL       SessionInputType = "url"
)

type SessionReporter

type SessionReporter interface {
	RegisterFunc(func(ts time.Time, tx SessionTx) bool)
	Tx(func(tx SessionTx))
	TxAt(time.Time, func(tx SessionTx))
	// contains filtered or unexported methods
}

func NewNoopSessionReporter

func NewNoopSessionReporter() SessionReporter

type SessionStatus

type SessionStatus string
const (
	SessionStatusUndefined  SessionStatus = ""
	SessionStatusInactive   SessionStatus = "inactive"
	SessionStatusBuffering  SessionStatus = "buffering"
	SessionStatusPublishing SessionStatus = "publishing"
	SessionStatusError      SessionStatus = "error"
	SessionStatusComplete   SessionStatus = "complete"
)

type SessionTx

type SessionTx interface {
	Ingress() IngressTx
	// contains filtered or unexported methods
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL