diff --git a/observability/telelphonycallobs/gen_reporter.go b/observability/telelphonycallobs/gen_reporter.go new file mode 100644 index 000000000..873f1a0c5 --- /dev/null +++ b/observability/telelphonycallobs/gen_reporter.go @@ -0,0 +1,74 @@ +// Code generated; DO NOT EDIT. + +package telelphonycallobs + +import ( + "time" +) + +const Version_J8004V8 = 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)) + WithCall(id string) CallReporter + WithDeferredCall() (CallReporter, KeyResolver) + ProjectTx +} + +type CallTx interface { + ReportStartTime(v time.Time) + ReportEndTime(v time.Time) + ReportDuration(v uint64) + ReportDurationMinutes(v uint16) + ReportTrunkID(v string) + ReportDispatchID(v string) + ReportCalleeNumber(v string) + ReportCalleeHost(v string) + ReportCallerNumber(v string) + ReportCallerHost(v string) + ReportDirection(v CallDirection) + ReportTransport(v CallTransport) + ReportProviderCallID(v string) + ReportProviderName(v string) + ReportSIPCallID(v string) + ReportRoomID(v string) + ReportRoomName(v string) + ReportParticipantIdentity(v string) + ReportError(v string) + ReportStatus(v CallStatus) + ReportResponseCode(v uint16) + ReportDisconnectReason(v string) + ReportTransferID(v string) + ReportTransferTo(v string) + ReportTransferDuration(v uint32) + ReportTransferStatus(v CallTransferStatus) + ReportTransferStatusCode(v uint16) + ReportTransferError(v string) + ReportCodec(v string) + ReportRegion(v string) + ReportPcapLink(v string) + ReportAttributes(v string) + ReportFeatures(v uint16) + ReportEncryption(v CallEncryption) +} + +type CallReporter interface { + RegisterFunc(func(ts time.Time, tx CallTx) bool) + Tx(func(tx CallTx)) + TxAt(time.Time, func(tx CallTx)) + CallTx +} diff --git a/observability/telelphonycallobs/gen_reporter_noop.go b/observability/telelphonycallobs/gen_reporter_noop.go new file mode 100644 index 000000000..7b41ddc48 --- /dev/null +++ b/observability/telelphonycallobs/gen_reporter_noop.go @@ -0,0 +1,92 @@ +// Code generated; DO NOT EDIT. + +package telelphonycallobs + +import ( + "time" +) + +var ( + _ Reporter = (*noopReporter)(nil) + _ ProjectReporter = (*noopProjectReporter)(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) WithCall(id string) CallReporter { + return &noopCallReporter{} +} +func (r *noopProjectReporter) 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) ReportStartTime(v time.Time) {} +func (r *noopCallReporter) ReportEndTime(v time.Time) {} +func (r *noopCallReporter) ReportDuration(v uint64) {} +func (r *noopCallReporter) ReportDurationMinutes(v uint16) {} +func (r *noopCallReporter) ReportTrunkID(v string) {} +func (r *noopCallReporter) ReportDispatchID(v string) {} +func (r *noopCallReporter) ReportCalleeNumber(v string) {} +func (r *noopCallReporter) ReportCalleeHost(v string) {} +func (r *noopCallReporter) ReportCallerNumber(v string) {} +func (r *noopCallReporter) ReportCallerHost(v string) {} +func (r *noopCallReporter) ReportDirection(v CallDirection) {} +func (r *noopCallReporter) ReportTransport(v CallTransport) {} +func (r *noopCallReporter) ReportProviderCallID(v string) {} +func (r *noopCallReporter) ReportProviderName(v string) {} +func (r *noopCallReporter) ReportSIPCallID(v string) {} +func (r *noopCallReporter) ReportRoomID(v string) {} +func (r *noopCallReporter) ReportRoomName(v string) {} +func (r *noopCallReporter) ReportParticipantIdentity(v string) {} +func (r *noopCallReporter) ReportError(v string) {} +func (r *noopCallReporter) ReportStatus(v CallStatus) {} +func (r *noopCallReporter) ReportResponseCode(v uint16) {} +func (r *noopCallReporter) ReportDisconnectReason(v string) {} +func (r *noopCallReporter) ReportTransferID(v string) {} +func (r *noopCallReporter) ReportTransferTo(v string) {} +func (r *noopCallReporter) ReportTransferDuration(v uint32) {} +func (r *noopCallReporter) ReportTransferStatus(v CallTransferStatus) {} +func (r *noopCallReporter) ReportTransferStatusCode(v uint16) {} +func (r *noopCallReporter) ReportTransferError(v string) {} +func (r *noopCallReporter) ReportCodec(v string) {} +func (r *noopCallReporter) ReportRegion(v string) {} +func (r *noopCallReporter) ReportPcapLink(v string) {} +func (r *noopCallReporter) ReportAttributes(v string) {} +func (r *noopCallReporter) ReportFeatures(v uint16) {} +func (r *noopCallReporter) ReportEncryption(v CallEncryption) {} diff --git a/observability/telelphonycallobs/gen_source.go b/observability/telelphonycallobs/gen_source.go new file mode 100644 index 000000000..5a526d63d --- /dev/null +++ b/observability/telelphonycallobs/gen_source.go @@ -0,0 +1,60 @@ +// Code generated; DO NOT EDIT. +package telelphonycallobs + +type CallDirection string + +const ( + CallDirectionUndefined CallDirection = "" + CallDirectionUnknown CallDirection = "unknown" + CallDirectionInbound CallDirection = "inbound" + CallDirectionOutbound CallDirection = "outbound" +) + +type CallTransport string + +const ( + CallTransportUndefined CallTransport = "" + CallTransportAuto CallTransport = "auto" + CallTransportUDP CallTransport = "udp" + CallTransportTCP CallTransport = "tcp" + CallTransportTLS CallTransport = "tls" +) + +type CallStatus string + +const ( + CallStatusUndefined CallStatus = "" + CallStatusActive CallStatus = "active" + CallStatusCallIncoming CallStatus = "call_incoming" + CallStatusParticipantJoined CallStatus = "participant_joined" + CallStatusDisconnected CallStatus = "disconnected" + CallStatusError CallStatus = "error" +) + +type CallTransferStatus string + +const ( + CallTransferStatusUndefined CallTransferStatus = "" + CallTransferStatusOngoing CallTransferStatus = "ongoing" + CallTransferStatusSuccess CallTransferStatus = "success" + CallTransferStatusFailed CallTransferStatus = "failed" +) + +type CallEncryption string + +const ( + CallEncryptionUndefined CallEncryption = "" + CallEncryptionDisable CallEncryption = "disable" + CallEncryptionAllow CallEncryption = "allow" + CallEncryptionRequire CallEncryption = "require" +) + +type Rollup string + +const ( + RollupUndefined Rollup = "" + RollupProject Rollup = "project" + RollupCallIndex Rollup = "call_index" + RollupStartTimeIndex Rollup = "start_time_index" + RollupEndTimeIndex Rollup = "end_time_index" +) diff --git a/observability/telephonycallobs/gen_reporter.go b/observability/telephonycallobs/gen_reporter.go new file mode 100644 index 000000000..966e2bb14 --- /dev/null +++ b/observability/telephonycallobs/gen_reporter.go @@ -0,0 +1,74 @@ +// Code generated; DO NOT EDIT. + +package telephonycallobs + +import ( + "time" +) + +const Version_J8004V8 = 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)) + WithCall(id string) CallReporter + WithDeferredCall() (CallReporter, KeyResolver) + ProjectTx +} + +type CallTx interface { + ReportStartTime(v time.Time) + ReportEndTime(v time.Time) + ReportDuration(v uint64) + ReportDurationMinutes(v uint16) + ReportTrunkID(v string) + ReportDispatchID(v string) + ReportCalleeNumber(v string) + ReportCalleeHost(v string) + ReportCallerNumber(v string) + ReportCallerHost(v string) + ReportDirection(v CallDirection) + ReportTransport(v CallTransport) + ReportProviderCallID(v string) + ReportProviderName(v string) + ReportSIPCallID(v string) + ReportRoomID(v string) + ReportRoomName(v string) + ReportParticipantIdentity(v string) + ReportError(v string) + ReportStatus(v CallStatus) + ReportResponseCode(v uint16) + ReportDisconnectReason(v string) + ReportTransferID(v string) + ReportTransferTo(v string) + ReportTransferDuration(v uint32) + ReportTransferStatus(v CallTransferStatus) + ReportTransferStatusCode(v uint16) + ReportTransferError(v string) + ReportCodec(v string) + ReportRegion(v string) + ReportPcapLink(v string) + ReportAttributes(v string) + ReportFeatures(v uint16) + ReportEncryption(v CallEncryption) +} + +type CallReporter interface { + RegisterFunc(func(ts time.Time, tx CallTx) bool) + Tx(func(tx CallTx)) + TxAt(time.Time, func(tx CallTx)) + CallTx +} diff --git a/observability/telephonycallobs/gen_reporter_noop.go b/observability/telephonycallobs/gen_reporter_noop.go new file mode 100644 index 000000000..c7398c069 --- /dev/null +++ b/observability/telephonycallobs/gen_reporter_noop.go @@ -0,0 +1,92 @@ +// Code generated; DO NOT EDIT. + +package telephonycallobs + +import ( + "time" +) + +var ( + _ Reporter = (*noopReporter)(nil) + _ ProjectReporter = (*noopProjectReporter)(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) WithCall(id string) CallReporter { + return &noopCallReporter{} +} +func (r *noopProjectReporter) 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) ReportStartTime(v time.Time) {} +func (r *noopCallReporter) ReportEndTime(v time.Time) {} +func (r *noopCallReporter) ReportDuration(v uint64) {} +func (r *noopCallReporter) ReportDurationMinutes(v uint16) {} +func (r *noopCallReporter) ReportTrunkID(v string) {} +func (r *noopCallReporter) ReportDispatchID(v string) {} +func (r *noopCallReporter) ReportCalleeNumber(v string) {} +func (r *noopCallReporter) ReportCalleeHost(v string) {} +func (r *noopCallReporter) ReportCallerNumber(v string) {} +func (r *noopCallReporter) ReportCallerHost(v string) {} +func (r *noopCallReporter) ReportDirection(v CallDirection) {} +func (r *noopCallReporter) ReportTransport(v CallTransport) {} +func (r *noopCallReporter) ReportProviderCallID(v string) {} +func (r *noopCallReporter) ReportProviderName(v string) {} +func (r *noopCallReporter) ReportSIPCallID(v string) {} +func (r *noopCallReporter) ReportRoomID(v string) {} +func (r *noopCallReporter) ReportRoomName(v string) {} +func (r *noopCallReporter) ReportParticipantIdentity(v string) {} +func (r *noopCallReporter) ReportError(v string) {} +func (r *noopCallReporter) ReportStatus(v CallStatus) {} +func (r *noopCallReporter) ReportResponseCode(v uint16) {} +func (r *noopCallReporter) ReportDisconnectReason(v string) {} +func (r *noopCallReporter) ReportTransferID(v string) {} +func (r *noopCallReporter) ReportTransferTo(v string) {} +func (r *noopCallReporter) ReportTransferDuration(v uint32) {} +func (r *noopCallReporter) ReportTransferStatus(v CallTransferStatus) {} +func (r *noopCallReporter) ReportTransferStatusCode(v uint16) {} +func (r *noopCallReporter) ReportTransferError(v string) {} +func (r *noopCallReporter) ReportCodec(v string) {} +func (r *noopCallReporter) ReportRegion(v string) {} +func (r *noopCallReporter) ReportPcapLink(v string) {} +func (r *noopCallReporter) ReportAttributes(v string) {} +func (r *noopCallReporter) ReportFeatures(v uint16) {} +func (r *noopCallReporter) ReportEncryption(v CallEncryption) {} diff --git a/observability/telephonycallobs/gen_source.go b/observability/telephonycallobs/gen_source.go new file mode 100644 index 000000000..6acb1f332 --- /dev/null +++ b/observability/telephonycallobs/gen_source.go @@ -0,0 +1,60 @@ +// Code generated; DO NOT EDIT. +package telephonycallobs + +type CallDirection string + +const ( + CallDirectionUndefined CallDirection = "" + CallDirectionUnknown CallDirection = "unknown" + CallDirectionInbound CallDirection = "inbound" + CallDirectionOutbound CallDirection = "outbound" +) + +type CallTransport string + +const ( + CallTransportUndefined CallTransport = "" + CallTransportAuto CallTransport = "auto" + CallTransportUDP CallTransport = "udp" + CallTransportTCP CallTransport = "tcp" + CallTransportTLS CallTransport = "tls" +) + +type CallStatus string + +const ( + CallStatusUndefined CallStatus = "" + CallStatusActive CallStatus = "active" + CallStatusCallIncoming CallStatus = "call_incoming" + CallStatusParticipantJoined CallStatus = "participant_joined" + CallStatusDisconnected CallStatus = "disconnected" + CallStatusError CallStatus = "error" +) + +type CallTransferStatus string + +const ( + CallTransferStatusUndefined CallTransferStatus = "" + CallTransferStatusOngoing CallTransferStatus = "ongoing" + CallTransferStatusSuccess CallTransferStatus = "success" + CallTransferStatusFailed CallTransferStatus = "failed" +) + +type CallEncryption string + +const ( + CallEncryptionUndefined CallEncryption = "" + CallEncryptionDisable CallEncryption = "disable" + CallEncryptionAllow CallEncryption = "allow" + CallEncryptionRequire CallEncryption = "require" +) + +type Rollup string + +const ( + RollupUndefined Rollup = "" + RollupProject Rollup = "project" + RollupCallIndex Rollup = "call_index" + RollupStartTimeIndex Rollup = "start_time_index" + RollupEndTimeIndex Rollup = "end_time_index" +)