Files
David ColburnandGitHub 80ff104bd2 Remove egress store (#552)
* Remove egress store

* fix imports
2022-03-22 12:37:31 -07:00

761 lines
23 KiB
Go

// Code generated by counterfeiter. DO NOT EDIT.
package servicefakes
import (
"context"
"sync"
"github.com/livekit/livekit-server/pkg/service"
"github.com/livekit/protocol/livekit"
)
type FakeServiceStore struct {
DeleteEgressStub func(context.Context, *livekit.EgressInfo) error
deleteEgressMutex sync.RWMutex
deleteEgressArgsForCall []struct {
arg1 context.Context
arg2 *livekit.EgressInfo
}
deleteEgressReturns struct {
result1 error
}
deleteEgressReturnsOnCall map[int]struct {
result1 error
}
ListEgressStub func(context.Context, livekit.RoomID) ([]*livekit.EgressInfo, error)
listEgressMutex sync.RWMutex
listEgressArgsForCall []struct {
arg1 context.Context
arg2 livekit.RoomID
}
listEgressReturns struct {
result1 []*livekit.EgressInfo
result2 error
}
listEgressReturnsOnCall map[int]struct {
result1 []*livekit.EgressInfo
result2 error
}
ListParticipantsStub func(context.Context, livekit.RoomName) ([]*livekit.ParticipantInfo, error)
listParticipantsMutex sync.RWMutex
listParticipantsArgsForCall []struct {
arg1 context.Context
arg2 livekit.RoomName
}
listParticipantsReturns struct {
result1 []*livekit.ParticipantInfo
result2 error
}
listParticipantsReturnsOnCall map[int]struct {
result1 []*livekit.ParticipantInfo
result2 error
}
ListRoomsStub func(context.Context, []livekit.RoomName) ([]*livekit.Room, error)
listRoomsMutex sync.RWMutex
listRoomsArgsForCall []struct {
arg1 context.Context
arg2 []livekit.RoomName
}
listRoomsReturns struct {
result1 []*livekit.Room
result2 error
}
listRoomsReturnsOnCall map[int]struct {
result1 []*livekit.Room
result2 error
}
LoadEgressStub func(context.Context, string) (*livekit.EgressInfo, error)
loadEgressMutex sync.RWMutex
loadEgressArgsForCall []struct {
arg1 context.Context
arg2 string
}
loadEgressReturns struct {
result1 *livekit.EgressInfo
result2 error
}
loadEgressReturnsOnCall map[int]struct {
result1 *livekit.EgressInfo
result2 error
}
LoadParticipantStub func(context.Context, livekit.RoomName, livekit.ParticipantIdentity) (*livekit.ParticipantInfo, error)
loadParticipantMutex sync.RWMutex
loadParticipantArgsForCall []struct {
arg1 context.Context
arg2 livekit.RoomName
arg3 livekit.ParticipantIdentity
}
loadParticipantReturns struct {
result1 *livekit.ParticipantInfo
result2 error
}
loadParticipantReturnsOnCall map[int]struct {
result1 *livekit.ParticipantInfo
result2 error
}
LoadRoomStub func(context.Context, livekit.RoomName) (*livekit.Room, error)
loadRoomMutex sync.RWMutex
loadRoomArgsForCall []struct {
arg1 context.Context
arg2 livekit.RoomName
}
loadRoomReturns struct {
result1 *livekit.Room
result2 error
}
loadRoomReturnsOnCall map[int]struct {
result1 *livekit.Room
result2 error
}
StoreEgressStub func(context.Context, *livekit.EgressInfo) error
storeEgressMutex sync.RWMutex
storeEgressArgsForCall []struct {
arg1 context.Context
arg2 *livekit.EgressInfo
}
storeEgressReturns struct {
result1 error
}
storeEgressReturnsOnCall map[int]struct {
result1 error
}
UpdateEgressStub func(context.Context, *livekit.EgressInfo) error
updateEgressMutex sync.RWMutex
updateEgressArgsForCall []struct {
arg1 context.Context
arg2 *livekit.EgressInfo
}
updateEgressReturns struct {
result1 error
}
updateEgressReturnsOnCall map[int]struct {
result1 error
}
invocations map[string][][]interface{}
invocationsMutex sync.RWMutex
}
func (fake *FakeServiceStore) DeleteEgress(arg1 context.Context, arg2 *livekit.EgressInfo) error {
fake.deleteEgressMutex.Lock()
ret, specificReturn := fake.deleteEgressReturnsOnCall[len(fake.deleteEgressArgsForCall)]
fake.deleteEgressArgsForCall = append(fake.deleteEgressArgsForCall, struct {
arg1 context.Context
arg2 *livekit.EgressInfo
}{arg1, arg2})
stub := fake.DeleteEgressStub
fakeReturns := fake.deleteEgressReturns
fake.recordInvocation("DeleteEgress", []interface{}{arg1, arg2})
fake.deleteEgressMutex.Unlock()
if stub != nil {
return stub(arg1, arg2)
}
if specificReturn {
return ret.result1
}
return fakeReturns.result1
}
func (fake *FakeServiceStore) DeleteEgressCallCount() int {
fake.deleteEgressMutex.RLock()
defer fake.deleteEgressMutex.RUnlock()
return len(fake.deleteEgressArgsForCall)
}
func (fake *FakeServiceStore) DeleteEgressCalls(stub func(context.Context, *livekit.EgressInfo) error) {
fake.deleteEgressMutex.Lock()
defer fake.deleteEgressMutex.Unlock()
fake.DeleteEgressStub = stub
}
func (fake *FakeServiceStore) DeleteEgressArgsForCall(i int) (context.Context, *livekit.EgressInfo) {
fake.deleteEgressMutex.RLock()
defer fake.deleteEgressMutex.RUnlock()
argsForCall := fake.deleteEgressArgsForCall[i]
return argsForCall.arg1, argsForCall.arg2
}
func (fake *FakeServiceStore) DeleteEgressReturns(result1 error) {
fake.deleteEgressMutex.Lock()
defer fake.deleteEgressMutex.Unlock()
fake.DeleteEgressStub = nil
fake.deleteEgressReturns = struct {
result1 error
}{result1}
}
func (fake *FakeServiceStore) DeleteEgressReturnsOnCall(i int, result1 error) {
fake.deleteEgressMutex.Lock()
defer fake.deleteEgressMutex.Unlock()
fake.DeleteEgressStub = nil
if fake.deleteEgressReturnsOnCall == nil {
fake.deleteEgressReturnsOnCall = make(map[int]struct {
result1 error
})
}
fake.deleteEgressReturnsOnCall[i] = struct {
result1 error
}{result1}
}
func (fake *FakeServiceStore) ListEgress(arg1 context.Context, arg2 livekit.RoomID) ([]*livekit.EgressInfo, error) {
fake.listEgressMutex.Lock()
ret, specificReturn := fake.listEgressReturnsOnCall[len(fake.listEgressArgsForCall)]
fake.listEgressArgsForCall = append(fake.listEgressArgsForCall, struct {
arg1 context.Context
arg2 livekit.RoomID
}{arg1, arg2})
stub := fake.ListEgressStub
fakeReturns := fake.listEgressReturns
fake.recordInvocation("ListEgress", []interface{}{arg1, arg2})
fake.listEgressMutex.Unlock()
if stub != nil {
return stub(arg1, arg2)
}
if specificReturn {
return ret.result1, ret.result2
}
return fakeReturns.result1, fakeReturns.result2
}
func (fake *FakeServiceStore) ListEgressCallCount() int {
fake.listEgressMutex.RLock()
defer fake.listEgressMutex.RUnlock()
return len(fake.listEgressArgsForCall)
}
func (fake *FakeServiceStore) ListEgressCalls(stub func(context.Context, livekit.RoomID) ([]*livekit.EgressInfo, error)) {
fake.listEgressMutex.Lock()
defer fake.listEgressMutex.Unlock()
fake.ListEgressStub = stub
}
func (fake *FakeServiceStore) ListEgressArgsForCall(i int) (context.Context, livekit.RoomID) {
fake.listEgressMutex.RLock()
defer fake.listEgressMutex.RUnlock()
argsForCall := fake.listEgressArgsForCall[i]
return argsForCall.arg1, argsForCall.arg2
}
func (fake *FakeServiceStore) ListEgressReturns(result1 []*livekit.EgressInfo, result2 error) {
fake.listEgressMutex.Lock()
defer fake.listEgressMutex.Unlock()
fake.ListEgressStub = nil
fake.listEgressReturns = struct {
result1 []*livekit.EgressInfo
result2 error
}{result1, result2}
}
func (fake *FakeServiceStore) ListEgressReturnsOnCall(i int, result1 []*livekit.EgressInfo, result2 error) {
fake.listEgressMutex.Lock()
defer fake.listEgressMutex.Unlock()
fake.ListEgressStub = nil
if fake.listEgressReturnsOnCall == nil {
fake.listEgressReturnsOnCall = make(map[int]struct {
result1 []*livekit.EgressInfo
result2 error
})
}
fake.listEgressReturnsOnCall[i] = struct {
result1 []*livekit.EgressInfo
result2 error
}{result1, result2}
}
func (fake *FakeServiceStore) ListParticipants(arg1 context.Context, arg2 livekit.RoomName) ([]*livekit.ParticipantInfo, error) {
fake.listParticipantsMutex.Lock()
ret, specificReturn := fake.listParticipantsReturnsOnCall[len(fake.listParticipantsArgsForCall)]
fake.listParticipantsArgsForCall = append(fake.listParticipantsArgsForCall, struct {
arg1 context.Context
arg2 livekit.RoomName
}{arg1, arg2})
stub := fake.ListParticipantsStub
fakeReturns := fake.listParticipantsReturns
fake.recordInvocation("ListParticipants", []interface{}{arg1, arg2})
fake.listParticipantsMutex.Unlock()
if stub != nil {
return stub(arg1, arg2)
}
if specificReturn {
return ret.result1, ret.result2
}
return fakeReturns.result1, fakeReturns.result2
}
func (fake *FakeServiceStore) ListParticipantsCallCount() int {
fake.listParticipantsMutex.RLock()
defer fake.listParticipantsMutex.RUnlock()
return len(fake.listParticipantsArgsForCall)
}
func (fake *FakeServiceStore) ListParticipantsCalls(stub func(context.Context, livekit.RoomName) ([]*livekit.ParticipantInfo, error)) {
fake.listParticipantsMutex.Lock()
defer fake.listParticipantsMutex.Unlock()
fake.ListParticipantsStub = stub
}
func (fake *FakeServiceStore) ListParticipantsArgsForCall(i int) (context.Context, livekit.RoomName) {
fake.listParticipantsMutex.RLock()
defer fake.listParticipantsMutex.RUnlock()
argsForCall := fake.listParticipantsArgsForCall[i]
return argsForCall.arg1, argsForCall.arg2
}
func (fake *FakeServiceStore) ListParticipantsReturns(result1 []*livekit.ParticipantInfo, result2 error) {
fake.listParticipantsMutex.Lock()
defer fake.listParticipantsMutex.Unlock()
fake.ListParticipantsStub = nil
fake.listParticipantsReturns = struct {
result1 []*livekit.ParticipantInfo
result2 error
}{result1, result2}
}
func (fake *FakeServiceStore) ListParticipantsReturnsOnCall(i int, result1 []*livekit.ParticipantInfo, result2 error) {
fake.listParticipantsMutex.Lock()
defer fake.listParticipantsMutex.Unlock()
fake.ListParticipantsStub = nil
if fake.listParticipantsReturnsOnCall == nil {
fake.listParticipantsReturnsOnCall = make(map[int]struct {
result1 []*livekit.ParticipantInfo
result2 error
})
}
fake.listParticipantsReturnsOnCall[i] = struct {
result1 []*livekit.ParticipantInfo
result2 error
}{result1, result2}
}
func (fake *FakeServiceStore) ListRooms(arg1 context.Context, arg2 []livekit.RoomName) ([]*livekit.Room, error) {
var arg2Copy []livekit.RoomName
if arg2 != nil {
arg2Copy = make([]livekit.RoomName, len(arg2))
copy(arg2Copy, arg2)
}
fake.listRoomsMutex.Lock()
ret, specificReturn := fake.listRoomsReturnsOnCall[len(fake.listRoomsArgsForCall)]
fake.listRoomsArgsForCall = append(fake.listRoomsArgsForCall, struct {
arg1 context.Context
arg2 []livekit.RoomName
}{arg1, arg2Copy})
stub := fake.ListRoomsStub
fakeReturns := fake.listRoomsReturns
fake.recordInvocation("ListRooms", []interface{}{arg1, arg2Copy})
fake.listRoomsMutex.Unlock()
if stub != nil {
return stub(arg1, arg2)
}
if specificReturn {
return ret.result1, ret.result2
}
return fakeReturns.result1, fakeReturns.result2
}
func (fake *FakeServiceStore) ListRoomsCallCount() int {
fake.listRoomsMutex.RLock()
defer fake.listRoomsMutex.RUnlock()
return len(fake.listRoomsArgsForCall)
}
func (fake *FakeServiceStore) ListRoomsCalls(stub func(context.Context, []livekit.RoomName) ([]*livekit.Room, error)) {
fake.listRoomsMutex.Lock()
defer fake.listRoomsMutex.Unlock()
fake.ListRoomsStub = stub
}
func (fake *FakeServiceStore) ListRoomsArgsForCall(i int) (context.Context, []livekit.RoomName) {
fake.listRoomsMutex.RLock()
defer fake.listRoomsMutex.RUnlock()
argsForCall := fake.listRoomsArgsForCall[i]
return argsForCall.arg1, argsForCall.arg2
}
func (fake *FakeServiceStore) ListRoomsReturns(result1 []*livekit.Room, result2 error) {
fake.listRoomsMutex.Lock()
defer fake.listRoomsMutex.Unlock()
fake.ListRoomsStub = nil
fake.listRoomsReturns = struct {
result1 []*livekit.Room
result2 error
}{result1, result2}
}
func (fake *FakeServiceStore) ListRoomsReturnsOnCall(i int, result1 []*livekit.Room, result2 error) {
fake.listRoomsMutex.Lock()
defer fake.listRoomsMutex.Unlock()
fake.ListRoomsStub = nil
if fake.listRoomsReturnsOnCall == nil {
fake.listRoomsReturnsOnCall = make(map[int]struct {
result1 []*livekit.Room
result2 error
})
}
fake.listRoomsReturnsOnCall[i] = struct {
result1 []*livekit.Room
result2 error
}{result1, result2}
}
func (fake *FakeServiceStore) LoadEgress(arg1 context.Context, arg2 string) (*livekit.EgressInfo, error) {
fake.loadEgressMutex.Lock()
ret, specificReturn := fake.loadEgressReturnsOnCall[len(fake.loadEgressArgsForCall)]
fake.loadEgressArgsForCall = append(fake.loadEgressArgsForCall, struct {
arg1 context.Context
arg2 string
}{arg1, arg2})
stub := fake.LoadEgressStub
fakeReturns := fake.loadEgressReturns
fake.recordInvocation("LoadEgress", []interface{}{arg1, arg2})
fake.loadEgressMutex.Unlock()
if stub != nil {
return stub(arg1, arg2)
}
if specificReturn {
return ret.result1, ret.result2
}
return fakeReturns.result1, fakeReturns.result2
}
func (fake *FakeServiceStore) LoadEgressCallCount() int {
fake.loadEgressMutex.RLock()
defer fake.loadEgressMutex.RUnlock()
return len(fake.loadEgressArgsForCall)
}
func (fake *FakeServiceStore) LoadEgressCalls(stub func(context.Context, string) (*livekit.EgressInfo, error)) {
fake.loadEgressMutex.Lock()
defer fake.loadEgressMutex.Unlock()
fake.LoadEgressStub = stub
}
func (fake *FakeServiceStore) LoadEgressArgsForCall(i int) (context.Context, string) {
fake.loadEgressMutex.RLock()
defer fake.loadEgressMutex.RUnlock()
argsForCall := fake.loadEgressArgsForCall[i]
return argsForCall.arg1, argsForCall.arg2
}
func (fake *FakeServiceStore) LoadEgressReturns(result1 *livekit.EgressInfo, result2 error) {
fake.loadEgressMutex.Lock()
defer fake.loadEgressMutex.Unlock()
fake.LoadEgressStub = nil
fake.loadEgressReturns = struct {
result1 *livekit.EgressInfo
result2 error
}{result1, result2}
}
func (fake *FakeServiceStore) LoadEgressReturnsOnCall(i int, result1 *livekit.EgressInfo, result2 error) {
fake.loadEgressMutex.Lock()
defer fake.loadEgressMutex.Unlock()
fake.LoadEgressStub = nil
if fake.loadEgressReturnsOnCall == nil {
fake.loadEgressReturnsOnCall = make(map[int]struct {
result1 *livekit.EgressInfo
result2 error
})
}
fake.loadEgressReturnsOnCall[i] = struct {
result1 *livekit.EgressInfo
result2 error
}{result1, result2}
}
func (fake *FakeServiceStore) LoadParticipant(arg1 context.Context, arg2 livekit.RoomName, arg3 livekit.ParticipantIdentity) (*livekit.ParticipantInfo, error) {
fake.loadParticipantMutex.Lock()
ret, specificReturn := fake.loadParticipantReturnsOnCall[len(fake.loadParticipantArgsForCall)]
fake.loadParticipantArgsForCall = append(fake.loadParticipantArgsForCall, struct {
arg1 context.Context
arg2 livekit.RoomName
arg3 livekit.ParticipantIdentity
}{arg1, arg2, arg3})
stub := fake.LoadParticipantStub
fakeReturns := fake.loadParticipantReturns
fake.recordInvocation("LoadParticipant", []interface{}{arg1, arg2, arg3})
fake.loadParticipantMutex.Unlock()
if stub != nil {
return stub(arg1, arg2, arg3)
}
if specificReturn {
return ret.result1, ret.result2
}
return fakeReturns.result1, fakeReturns.result2
}
func (fake *FakeServiceStore) LoadParticipantCallCount() int {
fake.loadParticipantMutex.RLock()
defer fake.loadParticipantMutex.RUnlock()
return len(fake.loadParticipantArgsForCall)
}
func (fake *FakeServiceStore) LoadParticipantCalls(stub func(context.Context, livekit.RoomName, livekit.ParticipantIdentity) (*livekit.ParticipantInfo, error)) {
fake.loadParticipantMutex.Lock()
defer fake.loadParticipantMutex.Unlock()
fake.LoadParticipantStub = stub
}
func (fake *FakeServiceStore) LoadParticipantArgsForCall(i int) (context.Context, livekit.RoomName, livekit.ParticipantIdentity) {
fake.loadParticipantMutex.RLock()
defer fake.loadParticipantMutex.RUnlock()
argsForCall := fake.loadParticipantArgsForCall[i]
return argsForCall.arg1, argsForCall.arg2, argsForCall.arg3
}
func (fake *FakeServiceStore) LoadParticipantReturns(result1 *livekit.ParticipantInfo, result2 error) {
fake.loadParticipantMutex.Lock()
defer fake.loadParticipantMutex.Unlock()
fake.LoadParticipantStub = nil
fake.loadParticipantReturns = struct {
result1 *livekit.ParticipantInfo
result2 error
}{result1, result2}
}
func (fake *FakeServiceStore) LoadParticipantReturnsOnCall(i int, result1 *livekit.ParticipantInfo, result2 error) {
fake.loadParticipantMutex.Lock()
defer fake.loadParticipantMutex.Unlock()
fake.LoadParticipantStub = nil
if fake.loadParticipantReturnsOnCall == nil {
fake.loadParticipantReturnsOnCall = make(map[int]struct {
result1 *livekit.ParticipantInfo
result2 error
})
}
fake.loadParticipantReturnsOnCall[i] = struct {
result1 *livekit.ParticipantInfo
result2 error
}{result1, result2}
}
func (fake *FakeServiceStore) LoadRoom(arg1 context.Context, arg2 livekit.RoomName) (*livekit.Room, error) {
fake.loadRoomMutex.Lock()
ret, specificReturn := fake.loadRoomReturnsOnCall[len(fake.loadRoomArgsForCall)]
fake.loadRoomArgsForCall = append(fake.loadRoomArgsForCall, struct {
arg1 context.Context
arg2 livekit.RoomName
}{arg1, arg2})
stub := fake.LoadRoomStub
fakeReturns := fake.loadRoomReturns
fake.recordInvocation("LoadRoom", []interface{}{arg1, arg2})
fake.loadRoomMutex.Unlock()
if stub != nil {
return stub(arg1, arg2)
}
if specificReturn {
return ret.result1, ret.result2
}
return fakeReturns.result1, fakeReturns.result2
}
func (fake *FakeServiceStore) LoadRoomCallCount() int {
fake.loadRoomMutex.RLock()
defer fake.loadRoomMutex.RUnlock()
return len(fake.loadRoomArgsForCall)
}
func (fake *FakeServiceStore) LoadRoomCalls(stub func(context.Context, livekit.RoomName) (*livekit.Room, error)) {
fake.loadRoomMutex.Lock()
defer fake.loadRoomMutex.Unlock()
fake.LoadRoomStub = stub
}
func (fake *FakeServiceStore) LoadRoomArgsForCall(i int) (context.Context, livekit.RoomName) {
fake.loadRoomMutex.RLock()
defer fake.loadRoomMutex.RUnlock()
argsForCall := fake.loadRoomArgsForCall[i]
return argsForCall.arg1, argsForCall.arg2
}
func (fake *FakeServiceStore) LoadRoomReturns(result1 *livekit.Room, result2 error) {
fake.loadRoomMutex.Lock()
defer fake.loadRoomMutex.Unlock()
fake.LoadRoomStub = nil
fake.loadRoomReturns = struct {
result1 *livekit.Room
result2 error
}{result1, result2}
}
func (fake *FakeServiceStore) LoadRoomReturnsOnCall(i int, result1 *livekit.Room, result2 error) {
fake.loadRoomMutex.Lock()
defer fake.loadRoomMutex.Unlock()
fake.LoadRoomStub = nil
if fake.loadRoomReturnsOnCall == nil {
fake.loadRoomReturnsOnCall = make(map[int]struct {
result1 *livekit.Room
result2 error
})
}
fake.loadRoomReturnsOnCall[i] = struct {
result1 *livekit.Room
result2 error
}{result1, result2}
}
func (fake *FakeServiceStore) StoreEgress(arg1 context.Context, arg2 *livekit.EgressInfo) error {
fake.storeEgressMutex.Lock()
ret, specificReturn := fake.storeEgressReturnsOnCall[len(fake.storeEgressArgsForCall)]
fake.storeEgressArgsForCall = append(fake.storeEgressArgsForCall, struct {
arg1 context.Context
arg2 *livekit.EgressInfo
}{arg1, arg2})
stub := fake.StoreEgressStub
fakeReturns := fake.storeEgressReturns
fake.recordInvocation("StoreEgress", []interface{}{arg1, arg2})
fake.storeEgressMutex.Unlock()
if stub != nil {
return stub(arg1, arg2)
}
if specificReturn {
return ret.result1
}
return fakeReturns.result1
}
func (fake *FakeServiceStore) StoreEgressCallCount() int {
fake.storeEgressMutex.RLock()
defer fake.storeEgressMutex.RUnlock()
return len(fake.storeEgressArgsForCall)
}
func (fake *FakeServiceStore) StoreEgressCalls(stub func(context.Context, *livekit.EgressInfo) error) {
fake.storeEgressMutex.Lock()
defer fake.storeEgressMutex.Unlock()
fake.StoreEgressStub = stub
}
func (fake *FakeServiceStore) StoreEgressArgsForCall(i int) (context.Context, *livekit.EgressInfo) {
fake.storeEgressMutex.RLock()
defer fake.storeEgressMutex.RUnlock()
argsForCall := fake.storeEgressArgsForCall[i]
return argsForCall.arg1, argsForCall.arg2
}
func (fake *FakeServiceStore) StoreEgressReturns(result1 error) {
fake.storeEgressMutex.Lock()
defer fake.storeEgressMutex.Unlock()
fake.StoreEgressStub = nil
fake.storeEgressReturns = struct {
result1 error
}{result1}
}
func (fake *FakeServiceStore) StoreEgressReturnsOnCall(i int, result1 error) {
fake.storeEgressMutex.Lock()
defer fake.storeEgressMutex.Unlock()
fake.StoreEgressStub = nil
if fake.storeEgressReturnsOnCall == nil {
fake.storeEgressReturnsOnCall = make(map[int]struct {
result1 error
})
}
fake.storeEgressReturnsOnCall[i] = struct {
result1 error
}{result1}
}
func (fake *FakeServiceStore) UpdateEgress(arg1 context.Context, arg2 *livekit.EgressInfo) error {
fake.updateEgressMutex.Lock()
ret, specificReturn := fake.updateEgressReturnsOnCall[len(fake.updateEgressArgsForCall)]
fake.updateEgressArgsForCall = append(fake.updateEgressArgsForCall, struct {
arg1 context.Context
arg2 *livekit.EgressInfo
}{arg1, arg2})
stub := fake.UpdateEgressStub
fakeReturns := fake.updateEgressReturns
fake.recordInvocation("UpdateEgress", []interface{}{arg1, arg2})
fake.updateEgressMutex.Unlock()
if stub != nil {
return stub(arg1, arg2)
}
if specificReturn {
return ret.result1
}
return fakeReturns.result1
}
func (fake *FakeServiceStore) UpdateEgressCallCount() int {
fake.updateEgressMutex.RLock()
defer fake.updateEgressMutex.RUnlock()
return len(fake.updateEgressArgsForCall)
}
func (fake *FakeServiceStore) UpdateEgressCalls(stub func(context.Context, *livekit.EgressInfo) error) {
fake.updateEgressMutex.Lock()
defer fake.updateEgressMutex.Unlock()
fake.UpdateEgressStub = stub
}
func (fake *FakeServiceStore) UpdateEgressArgsForCall(i int) (context.Context, *livekit.EgressInfo) {
fake.updateEgressMutex.RLock()
defer fake.updateEgressMutex.RUnlock()
argsForCall := fake.updateEgressArgsForCall[i]
return argsForCall.arg1, argsForCall.arg2
}
func (fake *FakeServiceStore) UpdateEgressReturns(result1 error) {
fake.updateEgressMutex.Lock()
defer fake.updateEgressMutex.Unlock()
fake.UpdateEgressStub = nil
fake.updateEgressReturns = struct {
result1 error
}{result1}
}
func (fake *FakeServiceStore) UpdateEgressReturnsOnCall(i int, result1 error) {
fake.updateEgressMutex.Lock()
defer fake.updateEgressMutex.Unlock()
fake.UpdateEgressStub = nil
if fake.updateEgressReturnsOnCall == nil {
fake.updateEgressReturnsOnCall = make(map[int]struct {
result1 error
})
}
fake.updateEgressReturnsOnCall[i] = struct {
result1 error
}{result1}
}
func (fake *FakeServiceStore) Invocations() map[string][][]interface{} {
fake.invocationsMutex.RLock()
defer fake.invocationsMutex.RUnlock()
fake.deleteEgressMutex.RLock()
defer fake.deleteEgressMutex.RUnlock()
fake.listEgressMutex.RLock()
defer fake.listEgressMutex.RUnlock()
fake.listParticipantsMutex.RLock()
defer fake.listParticipantsMutex.RUnlock()
fake.listRoomsMutex.RLock()
defer fake.listRoomsMutex.RUnlock()
fake.loadEgressMutex.RLock()
defer fake.loadEgressMutex.RUnlock()
fake.loadParticipantMutex.RLock()
defer fake.loadParticipantMutex.RUnlock()
fake.loadRoomMutex.RLock()
defer fake.loadRoomMutex.RUnlock()
fake.storeEgressMutex.RLock()
defer fake.storeEgressMutex.RUnlock()
fake.updateEgressMutex.RLock()
defer fake.updateEgressMutex.RUnlock()
copiedInvocations := map[string][][]interface{}{}
for key, value := range fake.invocations {
copiedInvocations[key] = value
}
return copiedInvocations
}
func (fake *FakeServiceStore) 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.ServiceStore = new(FakeServiceStore)