egressobs

type EgressReporter interface {
	RegisterFunc(func(ts time.Time, tx EgressTx) bool)
	Tx(func(tx EgressTx))
	TxAt(time.Time, func(tx EgressTx))
	WithSession(id string) SessionReporter
	WithDeferredSession() (SessionReporter, KeyResolver)
	EgressTx
}

type EgressRequestType string

type EgressResults struct {
	FileResults    []*livekit.FileInfo
	StreamResults  []*livekit.StreamInfo
	SegmentResults []*livekit.SegmentsInfo
	ImageResults   []*livekit.ImagesInfo
}

type EgressStatus string

type EgressTx interface {
	ReportRequestType(v EgressRequestType)
	ReportRoomName(v string)
	ReportRequest(v string)
	ReportAudioOnly(v bool)
	ReportStartTime(v time.Time)
	ReportEndTime(v time.Time)
	ReportUpdateTime(v time.Time)
	ReportStatus(v EgressStatus)
	ReportDetails(v string)
	ReportError(v string)
	ReportErrorCode(v int32)
	ReportResult(v string)
	ReportManifestLocation(v string)
}

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

type ProjectReporter interface {
	RegisterFunc(func(ts time.Time, tx ProjectTx) bool)
	Tx(func(tx ProjectTx))
	TxAt(time.Time, func(tx ProjectTx))
	WithEgress(id string) EgressReporter
	WithDeferredEgress() (EgressReporter, KeyResolver)
	ProjectTx
}

type ProjectTx interface{}

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

type Rollup string

type SessionReporter interface {
	RegisterFunc(func(ts time.Time, tx SessionTx) bool)
	Tx(func(tx SessionTx))
	TxAt(time.Time, func(tx SessionTx))
	SessionTx
}

type SessionSourceType string

type SessionStatus string

type SessionTx interface {
	ReportStartTime(v time.Time)
	ReportEndTime(v time.Time)
	ReportUpdateTime(v time.Time)
	ReportDuration(v uint64)
	ReportRetryCount(v uint32)
	ReportSourceType(v SessionSourceType)
	ReportRegion(v string)
	ReportRoomID(v string)
	ReportStatus(v SessionStatus)
	ReportDetails(v string)
	ReportError(v string)
	ReportErrorCode(v int32)
	ReportManifestLocation(v string)
	ReportBackupStorageUsed(v bool)
	ReportResult(v string)
}