Help us shape the future of Go! Take the 2026 Go Developer Survey

ingressobs

package
v1.53.1 Latest Latest
Warning

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

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

Documentation

Overview

Code generated by cloud-observability; DO NOT EDIT.

Index

Constants

View Source
const Version_6O9IP7G = 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