ingressobs

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)
	IngressTx
}

type IngressTx interface{}

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))
	WithIngress(id string) IngressReporter
	WithDeferredIngress() (IngressReporter, KeyResolver)
	ProjectTx
}

type ProjectTx interface{}

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

type Rollup string

type SessionInputType string

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

type SessionStatus string

type SessionTx interface {
	ReportStartTime(v time.Time)
	ReportEndTime(v time.Time)
	ReportDuration(v uint64)
	ReportInputType(v SessionInputType)
	ReportRegion(v string)
	ReportRoomName(v string)
	ReportRoomID(v string)
	ReportError(v string)
	ReportStatus(v SessionStatus)
	ReportAudioOnly(v bool)
	ReportTranscoded(v bool)
	ReportReusable(v bool)
}