add telephony obs interface (#1236)

Signed-off-by: shishir gowda <[email protected]>

Author: shishirng

observability/telephonyobs/gen_reporter.go

@@ -0,0 +1,72 @@
+// Code generated; DO NOT EDIT.
+
+package telephonyobs
+
+import (
+	"time"
+)
+
+const Version_6TP95J0 = true
+
+type KeyResolver interface {
+	Resolve(string)
+	Reset()
+}
+
+type Reporter interface {
+	WithProject(id string) ProjectReporter
+	WithDeferredProject() (ProjectReporter, KeyResolver)
+}
+
+type ProjectTx interface{}
+
+type ProjectReporter interface {
+	RegisterFunc(func(ts time.Time, tx ProjectTx) bool)
+	Tx(func(tx ProjectTx))
+	TxAt(time.Time, func(tx ProjectTx))
+	WithCarrier(id string) CarrierReporter
+	WithDeferredCarrier() (CarrierReporter, KeyResolver)
+	ProjectTx
+}
+
+type CarrierTx interface{}
+
+type CarrierReporter interface {
+	RegisterFunc(func(ts time.Time, tx CarrierTx) bool)
+	Tx(func(tx CarrierTx))
+	TxAt(time.Time, func(tx CarrierTx))
+	WithCountry(callCountryCode string) CountryReporter
+	WithDeferredCountry() (CountryReporter, KeyResolver)
+	CarrierTx
+}
+
+type CountryTx interface{}
+
+type CountryReporter interface {
+	RegisterFunc(func(ts time.Time, tx CountryTx) bool)
+	Tx(func(tx CountryTx))
+	TxAt(time.Time, func(tx CountryTx))
+	WithCall(id string) CallReporter
+	WithDeferredCall() (CallReporter, KeyResolver)
+	CountryTx
+}
+
+type CallTx interface {
+	ReportDirection(v DirectionType)
+	ReportNumberType(v NumberType)
+	ReportStatus(v CallStatus)
+	ReportTrunkType(v TrunkType)
+	ReportCountryCode(v string)
+	ReportPhoneNumber(v string)
+	ReportDuration(v uint32)
+	ReportDurationMinutes(v uint16)
+	ReportStartTime(v time.Time)
+	ReportEndTime(v time.Time)
+}
+
+type CallReporter interface {
+	RegisterFunc(func(ts time.Time, tx CallTx) bool)
+	Tx(func(tx CallTx))
+	TxAt(time.Time, func(tx CallTx))
+	CallTx
+}

observability/telephonyobs/gen_reporter_noop.go

@@ -0,0 +1,102 @@
+// Code generated; DO NOT EDIT.
+
+package telephonyobs
+
+import (
+	"time"
+)
+
+var (
+	_ Reporter        = (*noopReporter)(nil)
+	_ ProjectReporter = (*noopProjectReporter)(nil)
+	_ CarrierReporter = (*noopCarrierReporter)(nil)
+	_ CountryReporter = (*noopCountryReporter)(nil)
+	_ CallReporter    = (*noopCallReporter)(nil)
+)
+
+type noopKeyResolver struct{}
+
+func (noopKeyResolver) Resolve(string) {}
+func (noopKeyResolver) Reset()         {}
+
+type noopReporter struct{}
+
+func NewNoopReporter() Reporter {
+	return &noopReporter{}
+}
+
+func (r *noopReporter) WithProject(id string) ProjectReporter {
+	return &noopProjectReporter{}
+}
+
+func (r *noopReporter) WithDeferredProject() (ProjectReporter, KeyResolver) {
+	return &noopProjectReporter{}, noopKeyResolver{}
+}
+
+type noopProjectReporter struct{}
+
+func NewNoopProjectReporter() ProjectReporter {
+	return &noopProjectReporter{}
+}
+
+func (r *noopProjectReporter) RegisterFunc(f func(ts time.Time, tx ProjectTx) bool) {}
+func (r *noopProjectReporter) Tx(f func(ProjectTx))                                 {}
+func (r *noopProjectReporter) TxAt(ts time.Time, f func(ProjectTx))                 {}
+func (r *noopProjectReporter) WithCarrier(id string) CarrierReporter {
+	return &noopCarrierReporter{}
+}
+func (r *noopProjectReporter) WithDeferredCarrier() (CarrierReporter, KeyResolver) {
+	return &noopCarrierReporter{}, noopKeyResolver{}
+}
+
+type noopCarrierReporter struct{}
+
+func NewNoopCarrierReporter() CarrierReporter {
+	return &noopCarrierReporter{}
+}
+
+func (r *noopCarrierReporter) RegisterFunc(f func(ts time.Time, tx CarrierTx) bool) {}
+func (r *noopCarrierReporter) Tx(f func(CarrierTx))                                 {}
+func (r *noopCarrierReporter) TxAt(ts time.Time, f func(CarrierTx))                 {}
+func (r *noopCarrierReporter) WithCountry(callCountryCode string) CountryReporter {
+	return &noopCountryReporter{}
+}
+func (r *noopCarrierReporter) WithDeferredCountry() (CountryReporter, KeyResolver) {
+	return &noopCountryReporter{}, noopKeyResolver{}
+}
+
+type noopCountryReporter struct{}
+
+func NewNoopCountryReporter() CountryReporter {
+	return &noopCountryReporter{}
+}
+
+func (r *noopCountryReporter) RegisterFunc(f func(ts time.Time, tx CountryTx) bool) {}
+func (r *noopCountryReporter) Tx(f func(CountryTx))                                 {}
+func (r *noopCountryReporter) TxAt(ts time.Time, f func(CountryTx))                 {}
+func (r *noopCountryReporter) WithCall(id string) CallReporter {
+	return &noopCallReporter{}
+}
+func (r *noopCountryReporter) WithDeferredCall() (CallReporter, KeyResolver) {
+	return &noopCallReporter{}, noopKeyResolver{}
+}
+
+type noopCallReporter struct{}
+
+func NewNoopCallReporter() CallReporter {
+	return &noopCallReporter{}
+}
+
+func (r *noopCallReporter) RegisterFunc(f func(ts time.Time, tx CallTx) bool) {}
+func (r *noopCallReporter) Tx(f func(CallTx))                                 {}
+func (r *noopCallReporter) TxAt(ts time.Time, f func(CallTx))                 {}
+func (r *noopCallReporter) ReportDirection(v DirectionType)                   {}
+func (r *noopCallReporter) ReportNumberType(v NumberType)                     {}
+func (r *noopCallReporter) ReportStatus(v CallStatus)                         {}
+func (r *noopCallReporter) ReportTrunkType(v TrunkType)                       {}
+func (r *noopCallReporter) ReportCountryCode(v string)                        {}
+func (r *noopCallReporter) ReportPhoneNumber(v string)                        {}
+func (r *noopCallReporter) ReportDuration(v uint32)                           {}
+func (r *noopCallReporter) ReportDurationMinutes(v uint16)                    {}
+func (r *noopCallReporter) ReportStartTime(v time.Time)                       {}
+func (r *noopCallReporter) ReportEndTime(v time.Time)                         {}

observability/telephonyobs/gen_source.go

@@ -0,0 +1,44 @@
+// Code generated; DO NOT EDIT.
+package telephonyobs
+
+type DirectionType string
+
+const (
+	DirectionTypeUndefined DirectionType = ""
+	DirectionTypeInbound   DirectionType = "inbound"
+	DirectionTypeOutbound  DirectionType = "outbound"
+)
+
+type NumberType string
+
+const (
+	NumberTypeUndefined NumberType = ""
+	NumberTypeTollFree  NumberType = "toll_free"
+	NumberTypeRegular   NumberType = "regular"
+)
+
+type CallStatus string
+
+const (
+	CallStatusUndefined CallStatus = ""
+	CallStatusAnswered  CallStatus = "answered"
+	CallStatusMissed    CallStatus = "missed"
+	CallStatusBusy      CallStatus = "busy"
+	CallStatusFailed    CallStatus = "failed"
+)
+
+type TrunkType string
+
+const (
+	TrunkTypeUndefined TrunkType = ""
+	TrunkTypeInternal  TrunkType = "internal"
+	TrunkTypeExternal  TrunkType = "external"
+)
+
+type Rollup string
+
+const (
+	RollupUndefined Rollup = ""
+	RollupCountry   Rollup = "country"
+	RollupCall      Rollup = "call"
+)