mirror of
https://github.com/hanzoai/livekit.git
synced 2026-10-30 18:29:34 +00:00
This fork lived at github.com/hanzoai/livekit but still declared
`module github.com/livekit/livekit-server`, so all 505 self-references pointed
at upstream. A fork that does not own its module path is the exact thing the
owned-module-paths rule exists to prevent: every import line in every consumer
carries someone else's brand, and `go get` resolves to their code, not ours.
module + 505 self-imports github.com/livekit/livekit-server -> github.com/hanzoai/livekit
KV client github.com/redis/go-redis/v9 -> github.com/hanzokv/go/v9
message bus github.com/livekit/psrpc -> github.com/hanzoai/psrpc
psrpc had to be forked (hanzoai/psrpc, Apache-2.0) because its bus is typed
against the KV client — the same shape redsync had for hanzoai/git.
DELIBERATELY NOT FORKED: github.com/livekit/{protocol,mediatransportutil,
mageutil} keep their addresses. Only `protocol` still reaches go-redis, through
a single file (redis/redis.go) out of 305. Forking an 11.5MB core wire-protocol
library that this server must track in lockstep — and that upstream pushed
yesterday — to change one file trades a tidy dependency graph for permanent
divergence on the fastest-moving dependency here. So one indirect
github.com/redis/go-redis entry remains, via livekit/protocol/redis, and that
is the correct place for it to live.
1116 lines
38 KiB
Go
1116 lines
38 KiB
Go
// Code generated by counterfeiter. DO NOT EDIT.
|
|
package servicefakes
|
|
|
|
import (
|
|
"context"
|
|
"sync"
|
|
|
|
"github.com/hanzoai/livekit/pkg/service"
|
|
"github.com/livekit/protocol/livekit"
|
|
)
|
|
|
|
type FakeSIPStore struct {
|
|
DeleteSIPDispatchRuleStub func(context.Context, string) error
|
|
deleteSIPDispatchRuleMutex sync.RWMutex
|
|
deleteSIPDispatchRuleArgsForCall []struct {
|
|
arg1 context.Context
|
|
arg2 string
|
|
}
|
|
deleteSIPDispatchRuleReturns struct {
|
|
result1 error
|
|
}
|
|
deleteSIPDispatchRuleReturnsOnCall map[int]struct {
|
|
result1 error
|
|
}
|
|
DeleteSIPTrunkStub func(context.Context, string) error
|
|
deleteSIPTrunkMutex sync.RWMutex
|
|
deleteSIPTrunkArgsForCall []struct {
|
|
arg1 context.Context
|
|
arg2 string
|
|
}
|
|
deleteSIPTrunkReturns struct {
|
|
result1 error
|
|
}
|
|
deleteSIPTrunkReturnsOnCall map[int]struct {
|
|
result1 error
|
|
}
|
|
ListSIPDispatchRuleStub func(context.Context, *livekit.ListSIPDispatchRuleRequest) (*livekit.ListSIPDispatchRuleResponse, error)
|
|
listSIPDispatchRuleMutex sync.RWMutex
|
|
listSIPDispatchRuleArgsForCall []struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.ListSIPDispatchRuleRequest
|
|
}
|
|
listSIPDispatchRuleReturns struct {
|
|
result1 *livekit.ListSIPDispatchRuleResponse
|
|
result2 error
|
|
}
|
|
listSIPDispatchRuleReturnsOnCall map[int]struct {
|
|
result1 *livekit.ListSIPDispatchRuleResponse
|
|
result2 error
|
|
}
|
|
ListSIPInboundTrunkStub func(context.Context, *livekit.ListSIPInboundTrunkRequest) (*livekit.ListSIPInboundTrunkResponse, error)
|
|
listSIPInboundTrunkMutex sync.RWMutex
|
|
listSIPInboundTrunkArgsForCall []struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.ListSIPInboundTrunkRequest
|
|
}
|
|
listSIPInboundTrunkReturns struct {
|
|
result1 *livekit.ListSIPInboundTrunkResponse
|
|
result2 error
|
|
}
|
|
listSIPInboundTrunkReturnsOnCall map[int]struct {
|
|
result1 *livekit.ListSIPInboundTrunkResponse
|
|
result2 error
|
|
}
|
|
ListSIPOutboundTrunkStub func(context.Context, *livekit.ListSIPOutboundTrunkRequest) (*livekit.ListSIPOutboundTrunkResponse, error)
|
|
listSIPOutboundTrunkMutex sync.RWMutex
|
|
listSIPOutboundTrunkArgsForCall []struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.ListSIPOutboundTrunkRequest
|
|
}
|
|
listSIPOutboundTrunkReturns struct {
|
|
result1 *livekit.ListSIPOutboundTrunkResponse
|
|
result2 error
|
|
}
|
|
listSIPOutboundTrunkReturnsOnCall map[int]struct {
|
|
result1 *livekit.ListSIPOutboundTrunkResponse
|
|
result2 error
|
|
}
|
|
ListSIPTrunkStub func(context.Context, *livekit.ListSIPTrunkRequest) (*livekit.ListSIPTrunkResponse, error)
|
|
listSIPTrunkMutex sync.RWMutex
|
|
listSIPTrunkArgsForCall []struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.ListSIPTrunkRequest
|
|
}
|
|
listSIPTrunkReturns struct {
|
|
result1 *livekit.ListSIPTrunkResponse
|
|
result2 error
|
|
}
|
|
listSIPTrunkReturnsOnCall map[int]struct {
|
|
result1 *livekit.ListSIPTrunkResponse
|
|
result2 error
|
|
}
|
|
LoadSIPDispatchRuleStub func(context.Context, string) (*livekit.SIPDispatchRuleInfo, error)
|
|
loadSIPDispatchRuleMutex sync.RWMutex
|
|
loadSIPDispatchRuleArgsForCall []struct {
|
|
arg1 context.Context
|
|
arg2 string
|
|
}
|
|
loadSIPDispatchRuleReturns struct {
|
|
result1 *livekit.SIPDispatchRuleInfo
|
|
result2 error
|
|
}
|
|
loadSIPDispatchRuleReturnsOnCall map[int]struct {
|
|
result1 *livekit.SIPDispatchRuleInfo
|
|
result2 error
|
|
}
|
|
LoadSIPInboundTrunkStub func(context.Context, string) (*livekit.SIPInboundTrunkInfo, error)
|
|
loadSIPInboundTrunkMutex sync.RWMutex
|
|
loadSIPInboundTrunkArgsForCall []struct {
|
|
arg1 context.Context
|
|
arg2 string
|
|
}
|
|
loadSIPInboundTrunkReturns struct {
|
|
result1 *livekit.SIPInboundTrunkInfo
|
|
result2 error
|
|
}
|
|
loadSIPInboundTrunkReturnsOnCall map[int]struct {
|
|
result1 *livekit.SIPInboundTrunkInfo
|
|
result2 error
|
|
}
|
|
LoadSIPOutboundTrunkStub func(context.Context, string) (*livekit.SIPOutboundTrunkInfo, error)
|
|
loadSIPOutboundTrunkMutex sync.RWMutex
|
|
loadSIPOutboundTrunkArgsForCall []struct {
|
|
arg1 context.Context
|
|
arg2 string
|
|
}
|
|
loadSIPOutboundTrunkReturns struct {
|
|
result1 *livekit.SIPOutboundTrunkInfo
|
|
result2 error
|
|
}
|
|
loadSIPOutboundTrunkReturnsOnCall map[int]struct {
|
|
result1 *livekit.SIPOutboundTrunkInfo
|
|
result2 error
|
|
}
|
|
LoadSIPTrunkStub func(context.Context, string) (*livekit.SIPTrunkInfo, error)
|
|
loadSIPTrunkMutex sync.RWMutex
|
|
loadSIPTrunkArgsForCall []struct {
|
|
arg1 context.Context
|
|
arg2 string
|
|
}
|
|
loadSIPTrunkReturns struct {
|
|
result1 *livekit.SIPTrunkInfo
|
|
result2 error
|
|
}
|
|
loadSIPTrunkReturnsOnCall map[int]struct {
|
|
result1 *livekit.SIPTrunkInfo
|
|
result2 error
|
|
}
|
|
StoreSIPDispatchRuleStub func(context.Context, *livekit.SIPDispatchRuleInfo) error
|
|
storeSIPDispatchRuleMutex sync.RWMutex
|
|
storeSIPDispatchRuleArgsForCall []struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.SIPDispatchRuleInfo
|
|
}
|
|
storeSIPDispatchRuleReturns struct {
|
|
result1 error
|
|
}
|
|
storeSIPDispatchRuleReturnsOnCall map[int]struct {
|
|
result1 error
|
|
}
|
|
StoreSIPInboundTrunkStub func(context.Context, *livekit.SIPInboundTrunkInfo) error
|
|
storeSIPInboundTrunkMutex sync.RWMutex
|
|
storeSIPInboundTrunkArgsForCall []struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.SIPInboundTrunkInfo
|
|
}
|
|
storeSIPInboundTrunkReturns struct {
|
|
result1 error
|
|
}
|
|
storeSIPInboundTrunkReturnsOnCall map[int]struct {
|
|
result1 error
|
|
}
|
|
StoreSIPOutboundTrunkStub func(context.Context, *livekit.SIPOutboundTrunkInfo) error
|
|
storeSIPOutboundTrunkMutex sync.RWMutex
|
|
storeSIPOutboundTrunkArgsForCall []struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.SIPOutboundTrunkInfo
|
|
}
|
|
storeSIPOutboundTrunkReturns struct {
|
|
result1 error
|
|
}
|
|
storeSIPOutboundTrunkReturnsOnCall map[int]struct {
|
|
result1 error
|
|
}
|
|
StoreSIPTrunkStub func(context.Context, *livekit.SIPTrunkInfo) error
|
|
storeSIPTrunkMutex sync.RWMutex
|
|
storeSIPTrunkArgsForCall []struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.SIPTrunkInfo
|
|
}
|
|
storeSIPTrunkReturns struct {
|
|
result1 error
|
|
}
|
|
storeSIPTrunkReturnsOnCall map[int]struct {
|
|
result1 error
|
|
}
|
|
invocations map[string][][]interface{}
|
|
invocationsMutex sync.RWMutex
|
|
}
|
|
|
|
func (fake *FakeSIPStore) DeleteSIPDispatchRule(arg1 context.Context, arg2 string) error {
|
|
fake.deleteSIPDispatchRuleMutex.Lock()
|
|
ret, specificReturn := fake.deleteSIPDispatchRuleReturnsOnCall[len(fake.deleteSIPDispatchRuleArgsForCall)]
|
|
fake.deleteSIPDispatchRuleArgsForCall = append(fake.deleteSIPDispatchRuleArgsForCall, struct {
|
|
arg1 context.Context
|
|
arg2 string
|
|
}{arg1, arg2})
|
|
stub := fake.DeleteSIPDispatchRuleStub
|
|
fakeReturns := fake.deleteSIPDispatchRuleReturns
|
|
fake.recordInvocation("DeleteSIPDispatchRule", []interface{}{arg1, arg2})
|
|
fake.deleteSIPDispatchRuleMutex.Unlock()
|
|
if stub != nil {
|
|
return stub(arg1, arg2)
|
|
}
|
|
if specificReturn {
|
|
return ret.result1
|
|
}
|
|
return fakeReturns.result1
|
|
}
|
|
|
|
func (fake *FakeSIPStore) DeleteSIPDispatchRuleCallCount() int {
|
|
fake.deleteSIPDispatchRuleMutex.RLock()
|
|
defer fake.deleteSIPDispatchRuleMutex.RUnlock()
|
|
return len(fake.deleteSIPDispatchRuleArgsForCall)
|
|
}
|
|
|
|
func (fake *FakeSIPStore) DeleteSIPDispatchRuleCalls(stub func(context.Context, string) error) {
|
|
fake.deleteSIPDispatchRuleMutex.Lock()
|
|
defer fake.deleteSIPDispatchRuleMutex.Unlock()
|
|
fake.DeleteSIPDispatchRuleStub = stub
|
|
}
|
|
|
|
func (fake *FakeSIPStore) DeleteSIPDispatchRuleArgsForCall(i int) (context.Context, string) {
|
|
fake.deleteSIPDispatchRuleMutex.RLock()
|
|
defer fake.deleteSIPDispatchRuleMutex.RUnlock()
|
|
argsForCall := fake.deleteSIPDispatchRuleArgsForCall[i]
|
|
return argsForCall.arg1, argsForCall.arg2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) DeleteSIPDispatchRuleReturns(result1 error) {
|
|
fake.deleteSIPDispatchRuleMutex.Lock()
|
|
defer fake.deleteSIPDispatchRuleMutex.Unlock()
|
|
fake.DeleteSIPDispatchRuleStub = nil
|
|
fake.deleteSIPDispatchRuleReturns = struct {
|
|
result1 error
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) DeleteSIPDispatchRuleReturnsOnCall(i int, result1 error) {
|
|
fake.deleteSIPDispatchRuleMutex.Lock()
|
|
defer fake.deleteSIPDispatchRuleMutex.Unlock()
|
|
fake.DeleteSIPDispatchRuleStub = nil
|
|
if fake.deleteSIPDispatchRuleReturnsOnCall == nil {
|
|
fake.deleteSIPDispatchRuleReturnsOnCall = make(map[int]struct {
|
|
result1 error
|
|
})
|
|
}
|
|
fake.deleteSIPDispatchRuleReturnsOnCall[i] = struct {
|
|
result1 error
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) DeleteSIPTrunk(arg1 context.Context, arg2 string) error {
|
|
fake.deleteSIPTrunkMutex.Lock()
|
|
ret, specificReturn := fake.deleteSIPTrunkReturnsOnCall[len(fake.deleteSIPTrunkArgsForCall)]
|
|
fake.deleteSIPTrunkArgsForCall = append(fake.deleteSIPTrunkArgsForCall, struct {
|
|
arg1 context.Context
|
|
arg2 string
|
|
}{arg1, arg2})
|
|
stub := fake.DeleteSIPTrunkStub
|
|
fakeReturns := fake.deleteSIPTrunkReturns
|
|
fake.recordInvocation("DeleteSIPTrunk", []interface{}{arg1, arg2})
|
|
fake.deleteSIPTrunkMutex.Unlock()
|
|
if stub != nil {
|
|
return stub(arg1, arg2)
|
|
}
|
|
if specificReturn {
|
|
return ret.result1
|
|
}
|
|
return fakeReturns.result1
|
|
}
|
|
|
|
func (fake *FakeSIPStore) DeleteSIPTrunkCallCount() int {
|
|
fake.deleteSIPTrunkMutex.RLock()
|
|
defer fake.deleteSIPTrunkMutex.RUnlock()
|
|
return len(fake.deleteSIPTrunkArgsForCall)
|
|
}
|
|
|
|
func (fake *FakeSIPStore) DeleteSIPTrunkCalls(stub func(context.Context, string) error) {
|
|
fake.deleteSIPTrunkMutex.Lock()
|
|
defer fake.deleteSIPTrunkMutex.Unlock()
|
|
fake.DeleteSIPTrunkStub = stub
|
|
}
|
|
|
|
func (fake *FakeSIPStore) DeleteSIPTrunkArgsForCall(i int) (context.Context, string) {
|
|
fake.deleteSIPTrunkMutex.RLock()
|
|
defer fake.deleteSIPTrunkMutex.RUnlock()
|
|
argsForCall := fake.deleteSIPTrunkArgsForCall[i]
|
|
return argsForCall.arg1, argsForCall.arg2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) DeleteSIPTrunkReturns(result1 error) {
|
|
fake.deleteSIPTrunkMutex.Lock()
|
|
defer fake.deleteSIPTrunkMutex.Unlock()
|
|
fake.DeleteSIPTrunkStub = nil
|
|
fake.deleteSIPTrunkReturns = struct {
|
|
result1 error
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) DeleteSIPTrunkReturnsOnCall(i int, result1 error) {
|
|
fake.deleteSIPTrunkMutex.Lock()
|
|
defer fake.deleteSIPTrunkMutex.Unlock()
|
|
fake.DeleteSIPTrunkStub = nil
|
|
if fake.deleteSIPTrunkReturnsOnCall == nil {
|
|
fake.deleteSIPTrunkReturnsOnCall = make(map[int]struct {
|
|
result1 error
|
|
})
|
|
}
|
|
fake.deleteSIPTrunkReturnsOnCall[i] = struct {
|
|
result1 error
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPDispatchRule(arg1 context.Context, arg2 *livekit.ListSIPDispatchRuleRequest) (*livekit.ListSIPDispatchRuleResponse, error) {
|
|
fake.listSIPDispatchRuleMutex.Lock()
|
|
ret, specificReturn := fake.listSIPDispatchRuleReturnsOnCall[len(fake.listSIPDispatchRuleArgsForCall)]
|
|
fake.listSIPDispatchRuleArgsForCall = append(fake.listSIPDispatchRuleArgsForCall, struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.ListSIPDispatchRuleRequest
|
|
}{arg1, arg2})
|
|
stub := fake.ListSIPDispatchRuleStub
|
|
fakeReturns := fake.listSIPDispatchRuleReturns
|
|
fake.recordInvocation("ListSIPDispatchRule", []interface{}{arg1, arg2})
|
|
fake.listSIPDispatchRuleMutex.Unlock()
|
|
if stub != nil {
|
|
return stub(arg1, arg2)
|
|
}
|
|
if specificReturn {
|
|
return ret.result1, ret.result2
|
|
}
|
|
return fakeReturns.result1, fakeReturns.result2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPDispatchRuleCallCount() int {
|
|
fake.listSIPDispatchRuleMutex.RLock()
|
|
defer fake.listSIPDispatchRuleMutex.RUnlock()
|
|
return len(fake.listSIPDispatchRuleArgsForCall)
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPDispatchRuleCalls(stub func(context.Context, *livekit.ListSIPDispatchRuleRequest) (*livekit.ListSIPDispatchRuleResponse, error)) {
|
|
fake.listSIPDispatchRuleMutex.Lock()
|
|
defer fake.listSIPDispatchRuleMutex.Unlock()
|
|
fake.ListSIPDispatchRuleStub = stub
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPDispatchRuleArgsForCall(i int) (context.Context, *livekit.ListSIPDispatchRuleRequest) {
|
|
fake.listSIPDispatchRuleMutex.RLock()
|
|
defer fake.listSIPDispatchRuleMutex.RUnlock()
|
|
argsForCall := fake.listSIPDispatchRuleArgsForCall[i]
|
|
return argsForCall.arg1, argsForCall.arg2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPDispatchRuleReturns(result1 *livekit.ListSIPDispatchRuleResponse, result2 error) {
|
|
fake.listSIPDispatchRuleMutex.Lock()
|
|
defer fake.listSIPDispatchRuleMutex.Unlock()
|
|
fake.ListSIPDispatchRuleStub = nil
|
|
fake.listSIPDispatchRuleReturns = struct {
|
|
result1 *livekit.ListSIPDispatchRuleResponse
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPDispatchRuleReturnsOnCall(i int, result1 *livekit.ListSIPDispatchRuleResponse, result2 error) {
|
|
fake.listSIPDispatchRuleMutex.Lock()
|
|
defer fake.listSIPDispatchRuleMutex.Unlock()
|
|
fake.ListSIPDispatchRuleStub = nil
|
|
if fake.listSIPDispatchRuleReturnsOnCall == nil {
|
|
fake.listSIPDispatchRuleReturnsOnCall = make(map[int]struct {
|
|
result1 *livekit.ListSIPDispatchRuleResponse
|
|
result2 error
|
|
})
|
|
}
|
|
fake.listSIPDispatchRuleReturnsOnCall[i] = struct {
|
|
result1 *livekit.ListSIPDispatchRuleResponse
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPInboundTrunk(arg1 context.Context, arg2 *livekit.ListSIPInboundTrunkRequest) (*livekit.ListSIPInboundTrunkResponse, error) {
|
|
fake.listSIPInboundTrunkMutex.Lock()
|
|
ret, specificReturn := fake.listSIPInboundTrunkReturnsOnCall[len(fake.listSIPInboundTrunkArgsForCall)]
|
|
fake.listSIPInboundTrunkArgsForCall = append(fake.listSIPInboundTrunkArgsForCall, struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.ListSIPInboundTrunkRequest
|
|
}{arg1, arg2})
|
|
stub := fake.ListSIPInboundTrunkStub
|
|
fakeReturns := fake.listSIPInboundTrunkReturns
|
|
fake.recordInvocation("ListSIPInboundTrunk", []interface{}{arg1, arg2})
|
|
fake.listSIPInboundTrunkMutex.Unlock()
|
|
if stub != nil {
|
|
return stub(arg1, arg2)
|
|
}
|
|
if specificReturn {
|
|
return ret.result1, ret.result2
|
|
}
|
|
return fakeReturns.result1, fakeReturns.result2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPInboundTrunkCallCount() int {
|
|
fake.listSIPInboundTrunkMutex.RLock()
|
|
defer fake.listSIPInboundTrunkMutex.RUnlock()
|
|
return len(fake.listSIPInboundTrunkArgsForCall)
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPInboundTrunkCalls(stub func(context.Context, *livekit.ListSIPInboundTrunkRequest) (*livekit.ListSIPInboundTrunkResponse, error)) {
|
|
fake.listSIPInboundTrunkMutex.Lock()
|
|
defer fake.listSIPInboundTrunkMutex.Unlock()
|
|
fake.ListSIPInboundTrunkStub = stub
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPInboundTrunkArgsForCall(i int) (context.Context, *livekit.ListSIPInboundTrunkRequest) {
|
|
fake.listSIPInboundTrunkMutex.RLock()
|
|
defer fake.listSIPInboundTrunkMutex.RUnlock()
|
|
argsForCall := fake.listSIPInboundTrunkArgsForCall[i]
|
|
return argsForCall.arg1, argsForCall.arg2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPInboundTrunkReturns(result1 *livekit.ListSIPInboundTrunkResponse, result2 error) {
|
|
fake.listSIPInboundTrunkMutex.Lock()
|
|
defer fake.listSIPInboundTrunkMutex.Unlock()
|
|
fake.ListSIPInboundTrunkStub = nil
|
|
fake.listSIPInboundTrunkReturns = struct {
|
|
result1 *livekit.ListSIPInboundTrunkResponse
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPInboundTrunkReturnsOnCall(i int, result1 *livekit.ListSIPInboundTrunkResponse, result2 error) {
|
|
fake.listSIPInboundTrunkMutex.Lock()
|
|
defer fake.listSIPInboundTrunkMutex.Unlock()
|
|
fake.ListSIPInboundTrunkStub = nil
|
|
if fake.listSIPInboundTrunkReturnsOnCall == nil {
|
|
fake.listSIPInboundTrunkReturnsOnCall = make(map[int]struct {
|
|
result1 *livekit.ListSIPInboundTrunkResponse
|
|
result2 error
|
|
})
|
|
}
|
|
fake.listSIPInboundTrunkReturnsOnCall[i] = struct {
|
|
result1 *livekit.ListSIPInboundTrunkResponse
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPOutboundTrunk(arg1 context.Context, arg2 *livekit.ListSIPOutboundTrunkRequest) (*livekit.ListSIPOutboundTrunkResponse, error) {
|
|
fake.listSIPOutboundTrunkMutex.Lock()
|
|
ret, specificReturn := fake.listSIPOutboundTrunkReturnsOnCall[len(fake.listSIPOutboundTrunkArgsForCall)]
|
|
fake.listSIPOutboundTrunkArgsForCall = append(fake.listSIPOutboundTrunkArgsForCall, struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.ListSIPOutboundTrunkRequest
|
|
}{arg1, arg2})
|
|
stub := fake.ListSIPOutboundTrunkStub
|
|
fakeReturns := fake.listSIPOutboundTrunkReturns
|
|
fake.recordInvocation("ListSIPOutboundTrunk", []interface{}{arg1, arg2})
|
|
fake.listSIPOutboundTrunkMutex.Unlock()
|
|
if stub != nil {
|
|
return stub(arg1, arg2)
|
|
}
|
|
if specificReturn {
|
|
return ret.result1, ret.result2
|
|
}
|
|
return fakeReturns.result1, fakeReturns.result2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPOutboundTrunkCallCount() int {
|
|
fake.listSIPOutboundTrunkMutex.RLock()
|
|
defer fake.listSIPOutboundTrunkMutex.RUnlock()
|
|
return len(fake.listSIPOutboundTrunkArgsForCall)
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPOutboundTrunkCalls(stub func(context.Context, *livekit.ListSIPOutboundTrunkRequest) (*livekit.ListSIPOutboundTrunkResponse, error)) {
|
|
fake.listSIPOutboundTrunkMutex.Lock()
|
|
defer fake.listSIPOutboundTrunkMutex.Unlock()
|
|
fake.ListSIPOutboundTrunkStub = stub
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPOutboundTrunkArgsForCall(i int) (context.Context, *livekit.ListSIPOutboundTrunkRequest) {
|
|
fake.listSIPOutboundTrunkMutex.RLock()
|
|
defer fake.listSIPOutboundTrunkMutex.RUnlock()
|
|
argsForCall := fake.listSIPOutboundTrunkArgsForCall[i]
|
|
return argsForCall.arg1, argsForCall.arg2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPOutboundTrunkReturns(result1 *livekit.ListSIPOutboundTrunkResponse, result2 error) {
|
|
fake.listSIPOutboundTrunkMutex.Lock()
|
|
defer fake.listSIPOutboundTrunkMutex.Unlock()
|
|
fake.ListSIPOutboundTrunkStub = nil
|
|
fake.listSIPOutboundTrunkReturns = struct {
|
|
result1 *livekit.ListSIPOutboundTrunkResponse
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPOutboundTrunkReturnsOnCall(i int, result1 *livekit.ListSIPOutboundTrunkResponse, result2 error) {
|
|
fake.listSIPOutboundTrunkMutex.Lock()
|
|
defer fake.listSIPOutboundTrunkMutex.Unlock()
|
|
fake.ListSIPOutboundTrunkStub = nil
|
|
if fake.listSIPOutboundTrunkReturnsOnCall == nil {
|
|
fake.listSIPOutboundTrunkReturnsOnCall = make(map[int]struct {
|
|
result1 *livekit.ListSIPOutboundTrunkResponse
|
|
result2 error
|
|
})
|
|
}
|
|
fake.listSIPOutboundTrunkReturnsOnCall[i] = struct {
|
|
result1 *livekit.ListSIPOutboundTrunkResponse
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPTrunk(arg1 context.Context, arg2 *livekit.ListSIPTrunkRequest) (*livekit.ListSIPTrunkResponse, error) {
|
|
fake.listSIPTrunkMutex.Lock()
|
|
ret, specificReturn := fake.listSIPTrunkReturnsOnCall[len(fake.listSIPTrunkArgsForCall)]
|
|
fake.listSIPTrunkArgsForCall = append(fake.listSIPTrunkArgsForCall, struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.ListSIPTrunkRequest
|
|
}{arg1, arg2})
|
|
stub := fake.ListSIPTrunkStub
|
|
fakeReturns := fake.listSIPTrunkReturns
|
|
fake.recordInvocation("ListSIPTrunk", []interface{}{arg1, arg2})
|
|
fake.listSIPTrunkMutex.Unlock()
|
|
if stub != nil {
|
|
return stub(arg1, arg2)
|
|
}
|
|
if specificReturn {
|
|
return ret.result1, ret.result2
|
|
}
|
|
return fakeReturns.result1, fakeReturns.result2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPTrunkCallCount() int {
|
|
fake.listSIPTrunkMutex.RLock()
|
|
defer fake.listSIPTrunkMutex.RUnlock()
|
|
return len(fake.listSIPTrunkArgsForCall)
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPTrunkCalls(stub func(context.Context, *livekit.ListSIPTrunkRequest) (*livekit.ListSIPTrunkResponse, error)) {
|
|
fake.listSIPTrunkMutex.Lock()
|
|
defer fake.listSIPTrunkMutex.Unlock()
|
|
fake.ListSIPTrunkStub = stub
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPTrunkArgsForCall(i int) (context.Context, *livekit.ListSIPTrunkRequest) {
|
|
fake.listSIPTrunkMutex.RLock()
|
|
defer fake.listSIPTrunkMutex.RUnlock()
|
|
argsForCall := fake.listSIPTrunkArgsForCall[i]
|
|
return argsForCall.arg1, argsForCall.arg2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPTrunkReturns(result1 *livekit.ListSIPTrunkResponse, result2 error) {
|
|
fake.listSIPTrunkMutex.Lock()
|
|
defer fake.listSIPTrunkMutex.Unlock()
|
|
fake.ListSIPTrunkStub = nil
|
|
fake.listSIPTrunkReturns = struct {
|
|
result1 *livekit.ListSIPTrunkResponse
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) ListSIPTrunkReturnsOnCall(i int, result1 *livekit.ListSIPTrunkResponse, result2 error) {
|
|
fake.listSIPTrunkMutex.Lock()
|
|
defer fake.listSIPTrunkMutex.Unlock()
|
|
fake.ListSIPTrunkStub = nil
|
|
if fake.listSIPTrunkReturnsOnCall == nil {
|
|
fake.listSIPTrunkReturnsOnCall = make(map[int]struct {
|
|
result1 *livekit.ListSIPTrunkResponse
|
|
result2 error
|
|
})
|
|
}
|
|
fake.listSIPTrunkReturnsOnCall[i] = struct {
|
|
result1 *livekit.ListSIPTrunkResponse
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPDispatchRule(arg1 context.Context, arg2 string) (*livekit.SIPDispatchRuleInfo, error) {
|
|
fake.loadSIPDispatchRuleMutex.Lock()
|
|
ret, specificReturn := fake.loadSIPDispatchRuleReturnsOnCall[len(fake.loadSIPDispatchRuleArgsForCall)]
|
|
fake.loadSIPDispatchRuleArgsForCall = append(fake.loadSIPDispatchRuleArgsForCall, struct {
|
|
arg1 context.Context
|
|
arg2 string
|
|
}{arg1, arg2})
|
|
stub := fake.LoadSIPDispatchRuleStub
|
|
fakeReturns := fake.loadSIPDispatchRuleReturns
|
|
fake.recordInvocation("LoadSIPDispatchRule", []interface{}{arg1, arg2})
|
|
fake.loadSIPDispatchRuleMutex.Unlock()
|
|
if stub != nil {
|
|
return stub(arg1, arg2)
|
|
}
|
|
if specificReturn {
|
|
return ret.result1, ret.result2
|
|
}
|
|
return fakeReturns.result1, fakeReturns.result2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPDispatchRuleCallCount() int {
|
|
fake.loadSIPDispatchRuleMutex.RLock()
|
|
defer fake.loadSIPDispatchRuleMutex.RUnlock()
|
|
return len(fake.loadSIPDispatchRuleArgsForCall)
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPDispatchRuleCalls(stub func(context.Context, string) (*livekit.SIPDispatchRuleInfo, error)) {
|
|
fake.loadSIPDispatchRuleMutex.Lock()
|
|
defer fake.loadSIPDispatchRuleMutex.Unlock()
|
|
fake.LoadSIPDispatchRuleStub = stub
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPDispatchRuleArgsForCall(i int) (context.Context, string) {
|
|
fake.loadSIPDispatchRuleMutex.RLock()
|
|
defer fake.loadSIPDispatchRuleMutex.RUnlock()
|
|
argsForCall := fake.loadSIPDispatchRuleArgsForCall[i]
|
|
return argsForCall.arg1, argsForCall.arg2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPDispatchRuleReturns(result1 *livekit.SIPDispatchRuleInfo, result2 error) {
|
|
fake.loadSIPDispatchRuleMutex.Lock()
|
|
defer fake.loadSIPDispatchRuleMutex.Unlock()
|
|
fake.LoadSIPDispatchRuleStub = nil
|
|
fake.loadSIPDispatchRuleReturns = struct {
|
|
result1 *livekit.SIPDispatchRuleInfo
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPDispatchRuleReturnsOnCall(i int, result1 *livekit.SIPDispatchRuleInfo, result2 error) {
|
|
fake.loadSIPDispatchRuleMutex.Lock()
|
|
defer fake.loadSIPDispatchRuleMutex.Unlock()
|
|
fake.LoadSIPDispatchRuleStub = nil
|
|
if fake.loadSIPDispatchRuleReturnsOnCall == nil {
|
|
fake.loadSIPDispatchRuleReturnsOnCall = make(map[int]struct {
|
|
result1 *livekit.SIPDispatchRuleInfo
|
|
result2 error
|
|
})
|
|
}
|
|
fake.loadSIPDispatchRuleReturnsOnCall[i] = struct {
|
|
result1 *livekit.SIPDispatchRuleInfo
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPInboundTrunk(arg1 context.Context, arg2 string) (*livekit.SIPInboundTrunkInfo, error) {
|
|
fake.loadSIPInboundTrunkMutex.Lock()
|
|
ret, specificReturn := fake.loadSIPInboundTrunkReturnsOnCall[len(fake.loadSIPInboundTrunkArgsForCall)]
|
|
fake.loadSIPInboundTrunkArgsForCall = append(fake.loadSIPInboundTrunkArgsForCall, struct {
|
|
arg1 context.Context
|
|
arg2 string
|
|
}{arg1, arg2})
|
|
stub := fake.LoadSIPInboundTrunkStub
|
|
fakeReturns := fake.loadSIPInboundTrunkReturns
|
|
fake.recordInvocation("LoadSIPInboundTrunk", []interface{}{arg1, arg2})
|
|
fake.loadSIPInboundTrunkMutex.Unlock()
|
|
if stub != nil {
|
|
return stub(arg1, arg2)
|
|
}
|
|
if specificReturn {
|
|
return ret.result1, ret.result2
|
|
}
|
|
return fakeReturns.result1, fakeReturns.result2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPInboundTrunkCallCount() int {
|
|
fake.loadSIPInboundTrunkMutex.RLock()
|
|
defer fake.loadSIPInboundTrunkMutex.RUnlock()
|
|
return len(fake.loadSIPInboundTrunkArgsForCall)
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPInboundTrunkCalls(stub func(context.Context, string) (*livekit.SIPInboundTrunkInfo, error)) {
|
|
fake.loadSIPInboundTrunkMutex.Lock()
|
|
defer fake.loadSIPInboundTrunkMutex.Unlock()
|
|
fake.LoadSIPInboundTrunkStub = stub
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPInboundTrunkArgsForCall(i int) (context.Context, string) {
|
|
fake.loadSIPInboundTrunkMutex.RLock()
|
|
defer fake.loadSIPInboundTrunkMutex.RUnlock()
|
|
argsForCall := fake.loadSIPInboundTrunkArgsForCall[i]
|
|
return argsForCall.arg1, argsForCall.arg2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPInboundTrunkReturns(result1 *livekit.SIPInboundTrunkInfo, result2 error) {
|
|
fake.loadSIPInboundTrunkMutex.Lock()
|
|
defer fake.loadSIPInboundTrunkMutex.Unlock()
|
|
fake.LoadSIPInboundTrunkStub = nil
|
|
fake.loadSIPInboundTrunkReturns = struct {
|
|
result1 *livekit.SIPInboundTrunkInfo
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPInboundTrunkReturnsOnCall(i int, result1 *livekit.SIPInboundTrunkInfo, result2 error) {
|
|
fake.loadSIPInboundTrunkMutex.Lock()
|
|
defer fake.loadSIPInboundTrunkMutex.Unlock()
|
|
fake.LoadSIPInboundTrunkStub = nil
|
|
if fake.loadSIPInboundTrunkReturnsOnCall == nil {
|
|
fake.loadSIPInboundTrunkReturnsOnCall = make(map[int]struct {
|
|
result1 *livekit.SIPInboundTrunkInfo
|
|
result2 error
|
|
})
|
|
}
|
|
fake.loadSIPInboundTrunkReturnsOnCall[i] = struct {
|
|
result1 *livekit.SIPInboundTrunkInfo
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPOutboundTrunk(arg1 context.Context, arg2 string) (*livekit.SIPOutboundTrunkInfo, error) {
|
|
fake.loadSIPOutboundTrunkMutex.Lock()
|
|
ret, specificReturn := fake.loadSIPOutboundTrunkReturnsOnCall[len(fake.loadSIPOutboundTrunkArgsForCall)]
|
|
fake.loadSIPOutboundTrunkArgsForCall = append(fake.loadSIPOutboundTrunkArgsForCall, struct {
|
|
arg1 context.Context
|
|
arg2 string
|
|
}{arg1, arg2})
|
|
stub := fake.LoadSIPOutboundTrunkStub
|
|
fakeReturns := fake.loadSIPOutboundTrunkReturns
|
|
fake.recordInvocation("LoadSIPOutboundTrunk", []interface{}{arg1, arg2})
|
|
fake.loadSIPOutboundTrunkMutex.Unlock()
|
|
if stub != nil {
|
|
return stub(arg1, arg2)
|
|
}
|
|
if specificReturn {
|
|
return ret.result1, ret.result2
|
|
}
|
|
return fakeReturns.result1, fakeReturns.result2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPOutboundTrunkCallCount() int {
|
|
fake.loadSIPOutboundTrunkMutex.RLock()
|
|
defer fake.loadSIPOutboundTrunkMutex.RUnlock()
|
|
return len(fake.loadSIPOutboundTrunkArgsForCall)
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPOutboundTrunkCalls(stub func(context.Context, string) (*livekit.SIPOutboundTrunkInfo, error)) {
|
|
fake.loadSIPOutboundTrunkMutex.Lock()
|
|
defer fake.loadSIPOutboundTrunkMutex.Unlock()
|
|
fake.LoadSIPOutboundTrunkStub = stub
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPOutboundTrunkArgsForCall(i int) (context.Context, string) {
|
|
fake.loadSIPOutboundTrunkMutex.RLock()
|
|
defer fake.loadSIPOutboundTrunkMutex.RUnlock()
|
|
argsForCall := fake.loadSIPOutboundTrunkArgsForCall[i]
|
|
return argsForCall.arg1, argsForCall.arg2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPOutboundTrunkReturns(result1 *livekit.SIPOutboundTrunkInfo, result2 error) {
|
|
fake.loadSIPOutboundTrunkMutex.Lock()
|
|
defer fake.loadSIPOutboundTrunkMutex.Unlock()
|
|
fake.LoadSIPOutboundTrunkStub = nil
|
|
fake.loadSIPOutboundTrunkReturns = struct {
|
|
result1 *livekit.SIPOutboundTrunkInfo
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPOutboundTrunkReturnsOnCall(i int, result1 *livekit.SIPOutboundTrunkInfo, result2 error) {
|
|
fake.loadSIPOutboundTrunkMutex.Lock()
|
|
defer fake.loadSIPOutboundTrunkMutex.Unlock()
|
|
fake.LoadSIPOutboundTrunkStub = nil
|
|
if fake.loadSIPOutboundTrunkReturnsOnCall == nil {
|
|
fake.loadSIPOutboundTrunkReturnsOnCall = make(map[int]struct {
|
|
result1 *livekit.SIPOutboundTrunkInfo
|
|
result2 error
|
|
})
|
|
}
|
|
fake.loadSIPOutboundTrunkReturnsOnCall[i] = struct {
|
|
result1 *livekit.SIPOutboundTrunkInfo
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPTrunk(arg1 context.Context, arg2 string) (*livekit.SIPTrunkInfo, error) {
|
|
fake.loadSIPTrunkMutex.Lock()
|
|
ret, specificReturn := fake.loadSIPTrunkReturnsOnCall[len(fake.loadSIPTrunkArgsForCall)]
|
|
fake.loadSIPTrunkArgsForCall = append(fake.loadSIPTrunkArgsForCall, struct {
|
|
arg1 context.Context
|
|
arg2 string
|
|
}{arg1, arg2})
|
|
stub := fake.LoadSIPTrunkStub
|
|
fakeReturns := fake.loadSIPTrunkReturns
|
|
fake.recordInvocation("LoadSIPTrunk", []interface{}{arg1, arg2})
|
|
fake.loadSIPTrunkMutex.Unlock()
|
|
if stub != nil {
|
|
return stub(arg1, arg2)
|
|
}
|
|
if specificReturn {
|
|
return ret.result1, ret.result2
|
|
}
|
|
return fakeReturns.result1, fakeReturns.result2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPTrunkCallCount() int {
|
|
fake.loadSIPTrunkMutex.RLock()
|
|
defer fake.loadSIPTrunkMutex.RUnlock()
|
|
return len(fake.loadSIPTrunkArgsForCall)
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPTrunkCalls(stub func(context.Context, string) (*livekit.SIPTrunkInfo, error)) {
|
|
fake.loadSIPTrunkMutex.Lock()
|
|
defer fake.loadSIPTrunkMutex.Unlock()
|
|
fake.LoadSIPTrunkStub = stub
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPTrunkArgsForCall(i int) (context.Context, string) {
|
|
fake.loadSIPTrunkMutex.RLock()
|
|
defer fake.loadSIPTrunkMutex.RUnlock()
|
|
argsForCall := fake.loadSIPTrunkArgsForCall[i]
|
|
return argsForCall.arg1, argsForCall.arg2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPTrunkReturns(result1 *livekit.SIPTrunkInfo, result2 error) {
|
|
fake.loadSIPTrunkMutex.Lock()
|
|
defer fake.loadSIPTrunkMutex.Unlock()
|
|
fake.LoadSIPTrunkStub = nil
|
|
fake.loadSIPTrunkReturns = struct {
|
|
result1 *livekit.SIPTrunkInfo
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) LoadSIPTrunkReturnsOnCall(i int, result1 *livekit.SIPTrunkInfo, result2 error) {
|
|
fake.loadSIPTrunkMutex.Lock()
|
|
defer fake.loadSIPTrunkMutex.Unlock()
|
|
fake.LoadSIPTrunkStub = nil
|
|
if fake.loadSIPTrunkReturnsOnCall == nil {
|
|
fake.loadSIPTrunkReturnsOnCall = make(map[int]struct {
|
|
result1 *livekit.SIPTrunkInfo
|
|
result2 error
|
|
})
|
|
}
|
|
fake.loadSIPTrunkReturnsOnCall[i] = struct {
|
|
result1 *livekit.SIPTrunkInfo
|
|
result2 error
|
|
}{result1, result2}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPDispatchRule(arg1 context.Context, arg2 *livekit.SIPDispatchRuleInfo) error {
|
|
fake.storeSIPDispatchRuleMutex.Lock()
|
|
ret, specificReturn := fake.storeSIPDispatchRuleReturnsOnCall[len(fake.storeSIPDispatchRuleArgsForCall)]
|
|
fake.storeSIPDispatchRuleArgsForCall = append(fake.storeSIPDispatchRuleArgsForCall, struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.SIPDispatchRuleInfo
|
|
}{arg1, arg2})
|
|
stub := fake.StoreSIPDispatchRuleStub
|
|
fakeReturns := fake.storeSIPDispatchRuleReturns
|
|
fake.recordInvocation("StoreSIPDispatchRule", []interface{}{arg1, arg2})
|
|
fake.storeSIPDispatchRuleMutex.Unlock()
|
|
if stub != nil {
|
|
return stub(arg1, arg2)
|
|
}
|
|
if specificReturn {
|
|
return ret.result1
|
|
}
|
|
return fakeReturns.result1
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPDispatchRuleCallCount() int {
|
|
fake.storeSIPDispatchRuleMutex.RLock()
|
|
defer fake.storeSIPDispatchRuleMutex.RUnlock()
|
|
return len(fake.storeSIPDispatchRuleArgsForCall)
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPDispatchRuleCalls(stub func(context.Context, *livekit.SIPDispatchRuleInfo) error) {
|
|
fake.storeSIPDispatchRuleMutex.Lock()
|
|
defer fake.storeSIPDispatchRuleMutex.Unlock()
|
|
fake.StoreSIPDispatchRuleStub = stub
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPDispatchRuleArgsForCall(i int) (context.Context, *livekit.SIPDispatchRuleInfo) {
|
|
fake.storeSIPDispatchRuleMutex.RLock()
|
|
defer fake.storeSIPDispatchRuleMutex.RUnlock()
|
|
argsForCall := fake.storeSIPDispatchRuleArgsForCall[i]
|
|
return argsForCall.arg1, argsForCall.arg2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPDispatchRuleReturns(result1 error) {
|
|
fake.storeSIPDispatchRuleMutex.Lock()
|
|
defer fake.storeSIPDispatchRuleMutex.Unlock()
|
|
fake.StoreSIPDispatchRuleStub = nil
|
|
fake.storeSIPDispatchRuleReturns = struct {
|
|
result1 error
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPDispatchRuleReturnsOnCall(i int, result1 error) {
|
|
fake.storeSIPDispatchRuleMutex.Lock()
|
|
defer fake.storeSIPDispatchRuleMutex.Unlock()
|
|
fake.StoreSIPDispatchRuleStub = nil
|
|
if fake.storeSIPDispatchRuleReturnsOnCall == nil {
|
|
fake.storeSIPDispatchRuleReturnsOnCall = make(map[int]struct {
|
|
result1 error
|
|
})
|
|
}
|
|
fake.storeSIPDispatchRuleReturnsOnCall[i] = struct {
|
|
result1 error
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPInboundTrunk(arg1 context.Context, arg2 *livekit.SIPInboundTrunkInfo) error {
|
|
fake.storeSIPInboundTrunkMutex.Lock()
|
|
ret, specificReturn := fake.storeSIPInboundTrunkReturnsOnCall[len(fake.storeSIPInboundTrunkArgsForCall)]
|
|
fake.storeSIPInboundTrunkArgsForCall = append(fake.storeSIPInboundTrunkArgsForCall, struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.SIPInboundTrunkInfo
|
|
}{arg1, arg2})
|
|
stub := fake.StoreSIPInboundTrunkStub
|
|
fakeReturns := fake.storeSIPInboundTrunkReturns
|
|
fake.recordInvocation("StoreSIPInboundTrunk", []interface{}{arg1, arg2})
|
|
fake.storeSIPInboundTrunkMutex.Unlock()
|
|
if stub != nil {
|
|
return stub(arg1, arg2)
|
|
}
|
|
if specificReturn {
|
|
return ret.result1
|
|
}
|
|
return fakeReturns.result1
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPInboundTrunkCallCount() int {
|
|
fake.storeSIPInboundTrunkMutex.RLock()
|
|
defer fake.storeSIPInboundTrunkMutex.RUnlock()
|
|
return len(fake.storeSIPInboundTrunkArgsForCall)
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPInboundTrunkCalls(stub func(context.Context, *livekit.SIPInboundTrunkInfo) error) {
|
|
fake.storeSIPInboundTrunkMutex.Lock()
|
|
defer fake.storeSIPInboundTrunkMutex.Unlock()
|
|
fake.StoreSIPInboundTrunkStub = stub
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPInboundTrunkArgsForCall(i int) (context.Context, *livekit.SIPInboundTrunkInfo) {
|
|
fake.storeSIPInboundTrunkMutex.RLock()
|
|
defer fake.storeSIPInboundTrunkMutex.RUnlock()
|
|
argsForCall := fake.storeSIPInboundTrunkArgsForCall[i]
|
|
return argsForCall.arg1, argsForCall.arg2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPInboundTrunkReturns(result1 error) {
|
|
fake.storeSIPInboundTrunkMutex.Lock()
|
|
defer fake.storeSIPInboundTrunkMutex.Unlock()
|
|
fake.StoreSIPInboundTrunkStub = nil
|
|
fake.storeSIPInboundTrunkReturns = struct {
|
|
result1 error
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPInboundTrunkReturnsOnCall(i int, result1 error) {
|
|
fake.storeSIPInboundTrunkMutex.Lock()
|
|
defer fake.storeSIPInboundTrunkMutex.Unlock()
|
|
fake.StoreSIPInboundTrunkStub = nil
|
|
if fake.storeSIPInboundTrunkReturnsOnCall == nil {
|
|
fake.storeSIPInboundTrunkReturnsOnCall = make(map[int]struct {
|
|
result1 error
|
|
})
|
|
}
|
|
fake.storeSIPInboundTrunkReturnsOnCall[i] = struct {
|
|
result1 error
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPOutboundTrunk(arg1 context.Context, arg2 *livekit.SIPOutboundTrunkInfo) error {
|
|
fake.storeSIPOutboundTrunkMutex.Lock()
|
|
ret, specificReturn := fake.storeSIPOutboundTrunkReturnsOnCall[len(fake.storeSIPOutboundTrunkArgsForCall)]
|
|
fake.storeSIPOutboundTrunkArgsForCall = append(fake.storeSIPOutboundTrunkArgsForCall, struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.SIPOutboundTrunkInfo
|
|
}{arg1, arg2})
|
|
stub := fake.StoreSIPOutboundTrunkStub
|
|
fakeReturns := fake.storeSIPOutboundTrunkReturns
|
|
fake.recordInvocation("StoreSIPOutboundTrunk", []interface{}{arg1, arg2})
|
|
fake.storeSIPOutboundTrunkMutex.Unlock()
|
|
if stub != nil {
|
|
return stub(arg1, arg2)
|
|
}
|
|
if specificReturn {
|
|
return ret.result1
|
|
}
|
|
return fakeReturns.result1
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPOutboundTrunkCallCount() int {
|
|
fake.storeSIPOutboundTrunkMutex.RLock()
|
|
defer fake.storeSIPOutboundTrunkMutex.RUnlock()
|
|
return len(fake.storeSIPOutboundTrunkArgsForCall)
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPOutboundTrunkCalls(stub func(context.Context, *livekit.SIPOutboundTrunkInfo) error) {
|
|
fake.storeSIPOutboundTrunkMutex.Lock()
|
|
defer fake.storeSIPOutboundTrunkMutex.Unlock()
|
|
fake.StoreSIPOutboundTrunkStub = stub
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPOutboundTrunkArgsForCall(i int) (context.Context, *livekit.SIPOutboundTrunkInfo) {
|
|
fake.storeSIPOutboundTrunkMutex.RLock()
|
|
defer fake.storeSIPOutboundTrunkMutex.RUnlock()
|
|
argsForCall := fake.storeSIPOutboundTrunkArgsForCall[i]
|
|
return argsForCall.arg1, argsForCall.arg2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPOutboundTrunkReturns(result1 error) {
|
|
fake.storeSIPOutboundTrunkMutex.Lock()
|
|
defer fake.storeSIPOutboundTrunkMutex.Unlock()
|
|
fake.StoreSIPOutboundTrunkStub = nil
|
|
fake.storeSIPOutboundTrunkReturns = struct {
|
|
result1 error
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPOutboundTrunkReturnsOnCall(i int, result1 error) {
|
|
fake.storeSIPOutboundTrunkMutex.Lock()
|
|
defer fake.storeSIPOutboundTrunkMutex.Unlock()
|
|
fake.StoreSIPOutboundTrunkStub = nil
|
|
if fake.storeSIPOutboundTrunkReturnsOnCall == nil {
|
|
fake.storeSIPOutboundTrunkReturnsOnCall = make(map[int]struct {
|
|
result1 error
|
|
})
|
|
}
|
|
fake.storeSIPOutboundTrunkReturnsOnCall[i] = struct {
|
|
result1 error
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPTrunk(arg1 context.Context, arg2 *livekit.SIPTrunkInfo) error {
|
|
fake.storeSIPTrunkMutex.Lock()
|
|
ret, specificReturn := fake.storeSIPTrunkReturnsOnCall[len(fake.storeSIPTrunkArgsForCall)]
|
|
fake.storeSIPTrunkArgsForCall = append(fake.storeSIPTrunkArgsForCall, struct {
|
|
arg1 context.Context
|
|
arg2 *livekit.SIPTrunkInfo
|
|
}{arg1, arg2})
|
|
stub := fake.StoreSIPTrunkStub
|
|
fakeReturns := fake.storeSIPTrunkReturns
|
|
fake.recordInvocation("StoreSIPTrunk", []interface{}{arg1, arg2})
|
|
fake.storeSIPTrunkMutex.Unlock()
|
|
if stub != nil {
|
|
return stub(arg1, arg2)
|
|
}
|
|
if specificReturn {
|
|
return ret.result1
|
|
}
|
|
return fakeReturns.result1
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPTrunkCallCount() int {
|
|
fake.storeSIPTrunkMutex.RLock()
|
|
defer fake.storeSIPTrunkMutex.RUnlock()
|
|
return len(fake.storeSIPTrunkArgsForCall)
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPTrunkCalls(stub func(context.Context, *livekit.SIPTrunkInfo) error) {
|
|
fake.storeSIPTrunkMutex.Lock()
|
|
defer fake.storeSIPTrunkMutex.Unlock()
|
|
fake.StoreSIPTrunkStub = stub
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPTrunkArgsForCall(i int) (context.Context, *livekit.SIPTrunkInfo) {
|
|
fake.storeSIPTrunkMutex.RLock()
|
|
defer fake.storeSIPTrunkMutex.RUnlock()
|
|
argsForCall := fake.storeSIPTrunkArgsForCall[i]
|
|
return argsForCall.arg1, argsForCall.arg2
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPTrunkReturns(result1 error) {
|
|
fake.storeSIPTrunkMutex.Lock()
|
|
defer fake.storeSIPTrunkMutex.Unlock()
|
|
fake.StoreSIPTrunkStub = nil
|
|
fake.storeSIPTrunkReturns = struct {
|
|
result1 error
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) StoreSIPTrunkReturnsOnCall(i int, result1 error) {
|
|
fake.storeSIPTrunkMutex.Lock()
|
|
defer fake.storeSIPTrunkMutex.Unlock()
|
|
fake.StoreSIPTrunkStub = nil
|
|
if fake.storeSIPTrunkReturnsOnCall == nil {
|
|
fake.storeSIPTrunkReturnsOnCall = make(map[int]struct {
|
|
result1 error
|
|
})
|
|
}
|
|
fake.storeSIPTrunkReturnsOnCall[i] = struct {
|
|
result1 error
|
|
}{result1}
|
|
}
|
|
|
|
func (fake *FakeSIPStore) Invocations() map[string][][]interface{} {
|
|
fake.invocationsMutex.RLock()
|
|
defer fake.invocationsMutex.RUnlock()
|
|
copiedInvocations := map[string][][]interface{}{}
|
|
for key, value := range fake.invocations {
|
|
copiedInvocations[key] = value
|
|
}
|
|
return copiedInvocations
|
|
}
|
|
|
|
func (fake *FakeSIPStore) recordInvocation(key string, args []interface{}) {
|
|
fake.invocationsMutex.Lock()
|
|
defer fake.invocationsMutex.Unlock()
|
|
if fake.invocations == nil {
|
|
fake.invocations = map[string][][]interface{}{}
|
|
}
|
|
if fake.invocations[key] == nil {
|
|
fake.invocations[key] = [][]interface{}{}
|
|
}
|
|
fake.invocations[key] = append(fake.invocations[key], args)
|
|
}
|
|
|
|
var _ service.SIPStore = new(FakeSIPStore)
|