routingfakes

package
v0.0.0-...-6941808 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 22, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeMessageSink 

type FakeMessageSink struct {
	CloseStub func()

	ConnectionIDStub func() livekit.ConnectionID

	IsClosedStub func() bool

	WriteMessageStub func(protoreflect.ProtoMessage) error
	// contains filtered or unexported fields
}

func (*FakeMessageSink) Close 

func (fake *FakeMessageSink) Close()

func (*FakeMessageSink) CloseCallCount 

func (fake *FakeMessageSink) CloseCallCount() int

func (*FakeMessageSink) CloseCalls 

func (fake *FakeMessageSink) CloseCalls(stub func())

func (*FakeMessageSink) ConnectionID 

func (fake *FakeMessageSink) ConnectionID() livekit.ConnectionID

func (*FakeMessageSink) ConnectionIDCallCount 

func (fake *FakeMessageSink) ConnectionIDCallCount() int

func (*FakeMessageSink) ConnectionIDCalls 

func (fake *FakeMessageSink) ConnectionIDCalls(stub func() livekit.ConnectionID)

func (*FakeMessageSink) ConnectionIDReturns 

func (fake *FakeMessageSink) ConnectionIDReturns(result1 livekit.ConnectionID)

func (*FakeMessageSink) ConnectionIDReturnsOnCall 

func (fake *FakeMessageSink) ConnectionIDReturnsOnCall(i int, result1 livekit.ConnectionID)

func (*FakeMessageSink) Invocations 

func (fake *FakeMessageSink) Invocations() map[string][][]interface{}

func (*FakeMessageSink) IsClosed 

func (fake *FakeMessageSink) IsClosed() bool

func (*FakeMessageSink) IsClosedCallCount 

func (fake *FakeMessageSink) IsClosedCallCount() int

func (*FakeMessageSink) IsClosedCalls 

func (fake *FakeMessageSink) IsClosedCalls(stub func() bool)

func (*FakeMessageSink) IsClosedReturns 

func (fake *FakeMessageSink) IsClosedReturns(result1 bool)

func (*FakeMessageSink) IsClosedReturnsOnCall 

func (fake *FakeMessageSink) IsClosedReturnsOnCall(i int, result1 bool)

func (*FakeMessageSink) WriteMessage 

func (fake *FakeMessageSink) WriteMessage(arg1 protoreflect.ProtoMessage) error

func (*FakeMessageSink) WriteMessageArgsForCall 

func (fake *FakeMessageSink) WriteMessageArgsForCall(i int) protoreflect.ProtoMessage

func (*FakeMessageSink) WriteMessageCallCount 

func (fake *FakeMessageSink) WriteMessageCallCount() int

func (*FakeMessageSink) WriteMessageCalls 

func (fake *FakeMessageSink) WriteMessageCalls(stub func(protoreflect.ProtoMessage) error)

func (*FakeMessageSink) WriteMessageReturns 

func (fake *FakeMessageSink) WriteMessageReturns(result1 error)

func (*FakeMessageSink) WriteMessageReturnsOnCall 

func (fake *FakeMessageSink) WriteMessageReturnsOnCall(i int, result1 error)

type FakeMessageSource 

type FakeMessageSource struct {
	CloseStub func()

	ConnectionIDStub func() livekit.ConnectionID

	IsClosedStub func() bool

	ReadChanStub func() <-chan protoreflect.ProtoMessage
	// contains filtered or unexported fields
}

func (*FakeMessageSource) Close 

func (fake *FakeMessageSource) Close()

func (*FakeMessageSource) CloseCallCount 

func (fake *FakeMessageSource) CloseCallCount() int

func (*FakeMessageSource) CloseCalls 

func (fake *FakeMessageSource) CloseCalls(stub func())

func (*FakeMessageSource) ConnectionID 

func (fake *FakeMessageSource) ConnectionID() livekit.ConnectionID

func (*FakeMessageSource) ConnectionIDCallCount 

func (fake *FakeMessageSource) ConnectionIDCallCount() int

func (*FakeMessageSource) ConnectionIDCalls 

func (fake *FakeMessageSource) ConnectionIDCalls(stub func() livekit.ConnectionID)

func (*FakeMessageSource) ConnectionIDReturns 

func (fake *FakeMessageSource) ConnectionIDReturns(result1 livekit.ConnectionID)

func (*FakeMessageSource) ConnectionIDReturnsOnCall 

func (fake *FakeMessageSource) ConnectionIDReturnsOnCall(i int, result1 livekit.ConnectionID)

func (*FakeMessageSource) Invocations 

func (fake *FakeMessageSource) Invocations() map[string][][]interface{}

func (*FakeMessageSource) IsClosed 

func (fake *FakeMessageSource) IsClosed() bool

func (*FakeMessageSource) IsClosedCallCount 

func (fake *FakeMessageSource) IsClosedCallCount() int

func (*FakeMessageSource) IsClosedCalls 

func (fake *FakeMessageSource) IsClosedCalls(stub func() bool)

func (*FakeMessageSource) IsClosedReturns 

func (fake *FakeMessageSource) IsClosedReturns(result1 bool)

func (*FakeMessageSource) IsClosedReturnsOnCall 

func (fake *FakeMessageSource) IsClosedReturnsOnCall(i int, result1 bool)

func (*FakeMessageSource) ReadChan 

func (fake *FakeMessageSource) ReadChan() <-chan protoreflect.ProtoMessage

func (*FakeMessageSource) ReadChanCallCount 

func (fake *FakeMessageSource) ReadChanCallCount() int

func (*FakeMessageSource) ReadChanCalls 

func (fake *FakeMessageSource) ReadChanCalls(stub func() <-chan protoreflect.ProtoMessage)

func (*FakeMessageSource) ReadChanReturns 

func (fake *FakeMessageSource) ReadChanReturns(result1 <-chan protoreflect.ProtoMessage)

func (*FakeMessageSource) ReadChanReturnsOnCall 

func (fake *FakeMessageSource) ReadChanReturnsOnCall(i int, result1 <-chan protoreflect.ProtoMessage)

type FakeRoomManagerClient 

type FakeRoomManagerClient struct {
	CloseStub func()

	CreateRoomStub func(context.Context, livekit.NodeID, *livekit.CreateRoomRequest, ...psrpc.RequestOption) (*livekit.Room, error)
	// contains filtered or unexported fields
}

func (*FakeRoomManagerClient) Close 

func (fake *FakeRoomManagerClient) Close()

func (*FakeRoomManagerClient) CloseCallCount 

func (fake *FakeRoomManagerClient) CloseCallCount() int

func (*FakeRoomManagerClient) CloseCalls 

func (fake *FakeRoomManagerClient) CloseCalls(stub func())

func (*FakeRoomManagerClient) CreateRoom 

func (fake *FakeRoomManagerClient) CreateRoom(arg1 context.Context, arg2 livekit.NodeID, arg3 *livekit.CreateRoomRequest, arg4 ...psrpc.RequestOption) (*livekit.Room, error)

func (*FakeRoomManagerClient) CreateRoomArgsForCall 

func (fake *FakeRoomManagerClient) CreateRoomArgsForCall(i int) (context.Context, livekit.NodeID, *livekit.CreateRoomRequest, []psrpc.RequestOption)

func (*FakeRoomManagerClient) CreateRoomCallCount 

func (fake *FakeRoomManagerClient) CreateRoomCallCount() int

func (*FakeRoomManagerClient) CreateRoomCalls 

func (fake *FakeRoomManagerClient) CreateRoomCalls(stub func(context.Context, livekit.NodeID, *livekit.CreateRoomRequest, ...psrpc.RequestOption) (*livekit.Room, error))

func (*FakeRoomManagerClient) CreateRoomReturns 

func (fake *FakeRoomManagerClient) CreateRoomReturns(result1 *livekit.Room, result2 error)

func (*FakeRoomManagerClient) CreateRoomReturnsOnCall 

func (fake *FakeRoomManagerClient) CreateRoomReturnsOnCall(i int, result1 *livekit.Room, result2 error)

func (*FakeRoomManagerClient) Invocations 

func (fake *FakeRoomManagerClient) Invocations() map[string][][]interface{}

type FakeRouter 

type FakeRouter struct {
	ClearRoomStateStub func(context.Context, livekit.RoomName) error

	CreateRoomStub func(context.Context, *livekit.CreateRoomRequest) (*livekit.Room, error)

	DrainStub func()

	GetNodeForRoomStub func(context.Context, livekit.RoomName) (*livekit.Node, error)

	GetRegionStub func() string

	ListNodesStub func() ([]*livekit.Node, error)

	RegisterNodeStub func() error

	RemoveDeadNodesStub func() error

	SetNodeForRoomStub func(context.Context, livekit.RoomName, livekit.NodeID) error

	StartStub func() error

	StartParticipantSignalStub func(context.Context, livekit.RoomName, routing.ParticipantInit) (routing.StartParticipantSignalResults, error)

	StopStub func()

	UnregisterNodeStub func() error
	// contains filtered or unexported fields
}

func (*FakeRouter) ClearRoomState 

func (fake *FakeRouter) ClearRoomState(arg1 context.Context, arg2 livekit.RoomName) error

func (*FakeRouter) ClearRoomStateArgsForCall 

func (fake *FakeRouter) ClearRoomStateArgsForCall(i int) (context.Context, livekit.RoomName)

func (*FakeRouter) ClearRoomStateCallCount 

func (fake *FakeRouter) ClearRoomStateCallCount() int

func (*FakeRouter) ClearRoomStateCalls 

func (fake *FakeRouter) ClearRoomStateCalls(stub func(context.Context, livekit.RoomName) error)

func (*FakeRouter) ClearRoomStateReturns 

func (fake *FakeRouter) ClearRoomStateReturns(result1 error)

func (*FakeRouter) ClearRoomStateReturnsOnCall 

func (fake *FakeRouter) ClearRoomStateReturnsOnCall(i int, result1 error)

func (*FakeRouter) CreateRoom 

func (fake *FakeRouter) CreateRoom(arg1 context.Context, arg2 *livekit.CreateRoomRequest) (*livekit.Room, error)

func (*FakeRouter) CreateRoomArgsForCall 

func (fake *FakeRouter) CreateRoomArgsForCall(i int) (context.Context, *livekit.CreateRoomRequest)

func (*FakeRouter) CreateRoomCallCount 

func (fake *FakeRouter) CreateRoomCallCount() int

func (*FakeRouter) CreateRoomCalls 

func (fake *FakeRouter) CreateRoomCalls(stub func(context.Context, *livekit.CreateRoomRequest) (*livekit.Room, error))

func (*FakeRouter) CreateRoomReturns 

func (fake *FakeRouter) CreateRoomReturns(result1 *livekit.Room, result2 error)

func (*FakeRouter) CreateRoomReturnsOnCall 

func (fake *FakeRouter) CreateRoomReturnsOnCall(i int, result1 *livekit.Room, result2 error)

func (*FakeRouter) Drain 

func (fake *FakeRouter) Drain()

func (*FakeRouter) DrainCallCount 

func (fake *FakeRouter) DrainCallCount() int

func (*FakeRouter) DrainCalls 

func (fake *FakeRouter) DrainCalls(stub func())

func (*FakeRouter) GetNodeForRoom 

func (fake *FakeRouter) GetNodeForRoom(arg1 context.Context, arg2 livekit.RoomName) (*livekit.Node, error)

func (*FakeRouter) GetNodeForRoomArgsForCall 

func (fake *FakeRouter) GetNodeForRoomArgsForCall(i int) (context.Context, livekit.RoomName)

func (*FakeRouter) GetNodeForRoomCallCount 

func (fake *FakeRouter) GetNodeForRoomCallCount() int

func (*FakeRouter) GetNodeForRoomCalls 

func (fake *FakeRouter) GetNodeForRoomCalls(stub func(context.Context, livekit.RoomName) (*livekit.Node, error))

func (*FakeRouter) GetNodeForRoomReturns 

func (fake *FakeRouter) GetNodeForRoomReturns(result1 *livekit.Node, result2 error)

func (*FakeRouter) GetNodeForRoomReturnsOnCall 

func (fake *FakeRouter) GetNodeForRoomReturnsOnCall(i int, result1 *livekit.Node, result2 error)

func (*FakeRouter) GetRegion 

func (fake *FakeRouter) GetRegion() string

func (*FakeRouter) GetRegionCallCount 

func (fake *FakeRouter) GetRegionCallCount() int

func (*FakeRouter) GetRegionCalls 

func (fake *FakeRouter) GetRegionCalls(stub func() string)

func (*FakeRouter) GetRegionReturns 

func (fake *FakeRouter) GetRegionReturns(result1 string)

func (*FakeRouter) GetRegionReturnsOnCall 

func (fake *FakeRouter) GetRegionReturnsOnCall(i int, result1 string)

func (*FakeRouter) Invocations 

func (fake *FakeRouter) Invocations() map[string][][]interface{}

func (*FakeRouter) ListNodes 

func (fake *FakeRouter) ListNodes() ([]*livekit.Node, error)

func (*FakeRouter) ListNodesCallCount 

func (fake *FakeRouter) ListNodesCallCount() int

func (*FakeRouter) ListNodesCalls 

func (fake *FakeRouter) ListNodesCalls(stub func() ([]*livekit.Node, error))

func (*FakeRouter) ListNodesReturns 

func (fake *FakeRouter) ListNodesReturns(result1 []*livekit.Node, result2 error)

func (*FakeRouter) ListNodesReturnsOnCall 

func (fake *FakeRouter) ListNodesReturnsOnCall(i int, result1 []*livekit.Node, result2 error)

func (*FakeRouter) RegisterNode 

func (fake *FakeRouter) RegisterNode() error

func (*FakeRouter) RegisterNodeCallCount 

func (fake *FakeRouter) RegisterNodeCallCount() int

func (*FakeRouter) RegisterNodeCalls 

func (fake *FakeRouter) RegisterNodeCalls(stub func() error)

func (*FakeRouter) RegisterNodeReturns 

func (fake *FakeRouter) RegisterNodeReturns(result1 error)

func (*FakeRouter) RegisterNodeReturnsOnCall 

func (fake *FakeRouter) RegisterNodeReturnsOnCall(i int, result1 error)

func (*FakeRouter) RemoveDeadNodes 

func (fake *FakeRouter) RemoveDeadNodes() error

func (*FakeRouter) RemoveDeadNodesCallCount 

func (fake *FakeRouter) RemoveDeadNodesCallCount() int

func (*FakeRouter) RemoveDeadNodesCalls 

func (fake *FakeRouter) RemoveDeadNodesCalls(stub func() error)

func (*FakeRouter) RemoveDeadNodesReturns 

func (fake *FakeRouter) RemoveDeadNodesReturns(result1 error)

func (*FakeRouter) RemoveDeadNodesReturnsOnCall 

func (fake *FakeRouter) RemoveDeadNodesReturnsOnCall(i int, result1 error)

func (*FakeRouter) SetNodeForRoom 

func (fake *FakeRouter) SetNodeForRoom(arg1 context.Context, arg2 livekit.RoomName, arg3 livekit.NodeID) error

func (*FakeRouter) SetNodeForRoomArgsForCall 

func (fake *FakeRouter) SetNodeForRoomArgsForCall(i int) (context.Context, livekit.RoomName, livekit.NodeID)

func (*FakeRouter) SetNodeForRoomCallCount 

func (fake *FakeRouter) SetNodeForRoomCallCount() int

func (*FakeRouter) SetNodeForRoomCalls 

func (fake *FakeRouter) SetNodeForRoomCalls(stub func(context.Context, livekit.RoomName, livekit.NodeID) error)

func (*FakeRouter) SetNodeForRoomReturns 

func (fake *FakeRouter) SetNodeForRoomReturns(result1 error)

func (*FakeRouter) SetNodeForRoomReturnsOnCall 

func (fake *FakeRouter) SetNodeForRoomReturnsOnCall(i int, result1 error)

func (*FakeRouter) Start 

func (fake *FakeRouter) Start() error

func (*FakeRouter) StartCallCount 

func (fake *FakeRouter) StartCallCount() int

func (*FakeRouter) StartCalls 

func (fake *FakeRouter) StartCalls(stub func() error)

func (*FakeRouter) StartParticipantSignal 

func (fake *FakeRouter) StartParticipantSignal(arg1 context.Context, arg2 livekit.RoomName, arg3 routing.ParticipantInit) (routing.StartParticipantSignalResults, error)

func (*FakeRouter) StartParticipantSignalArgsForCall 

func (fake *FakeRouter) StartParticipantSignalArgsForCall(i int) (context.Context, livekit.RoomName, routing.ParticipantInit)

func (*FakeRouter) StartParticipantSignalCallCount 

func (fake *FakeRouter) StartParticipantSignalCallCount() int

func (*FakeRouter) StartParticipantSignalCalls 

func (fake *FakeRouter) StartParticipantSignalCalls(stub func(context.Context, livekit.RoomName, routing.ParticipantInit) (routing.StartParticipantSignalResults, error))

func (*FakeRouter) StartParticipantSignalReturns 

func (fake *FakeRouter) StartParticipantSignalReturns(result1 routing.StartParticipantSignalResults, result2 error)

func (*FakeRouter) StartParticipantSignalReturnsOnCall 

func (fake *FakeRouter) StartParticipantSignalReturnsOnCall(i int, result1 routing.StartParticipantSignalResults, result2 error)

func (*FakeRouter) StartReturns 

func (fake *FakeRouter) StartReturns(result1 error)

func (*FakeRouter) StartReturnsOnCall 

func (fake *FakeRouter) StartReturnsOnCall(i int, result1 error)

func (*FakeRouter) Stop 

func (fake *FakeRouter) Stop()

func (*FakeRouter) StopCallCount 

func (fake *FakeRouter) StopCallCount() int

func (*FakeRouter) StopCalls 

func (fake *FakeRouter) StopCalls(stub func())

func (*FakeRouter) UnregisterNode 

func (fake *FakeRouter) UnregisterNode() error

func (*FakeRouter) UnregisterNodeCallCount 

func (fake *FakeRouter) UnregisterNodeCallCount() int

func (*FakeRouter) UnregisterNodeCalls 

func (fake *FakeRouter) UnregisterNodeCalls(stub func() error)

func (*FakeRouter) UnregisterNodeReturns 

func (fake *FakeRouter) UnregisterNodeReturns(result1 error)

func (*FakeRouter) UnregisterNodeReturnsOnCall 

func (fake *FakeRouter) UnregisterNodeReturnsOnCall(i int, result1 error)

type FakeSignalClient 

type FakeSignalClient struct {
	ActiveCountStub func() int

	StartParticipantSignalStub func(context.Context, livekit.RoomName, routing.ParticipantInit, livekit.NodeID) (livekit.ConnectionID, routing.MessageSink, routing.MessageSource, error)
	// contains filtered or unexported fields
}

func (*FakeSignalClient) ActiveCount 

func (fake *FakeSignalClient) ActiveCount() int

func (*FakeSignalClient) ActiveCountCallCount 

func (fake *FakeSignalClient) ActiveCountCallCount() int

func (*FakeSignalClient) ActiveCountCalls 

func (fake *FakeSignalClient) ActiveCountCalls(stub func() int)

func (*FakeSignalClient) ActiveCountReturns 

func (fake *FakeSignalClient) ActiveCountReturns(result1 int)

func (*FakeSignalClient) ActiveCountReturnsOnCall 

func (fake *FakeSignalClient) ActiveCountReturnsOnCall(i int, result1 int)

func (*FakeSignalClient) Invocations 

func (fake *FakeSignalClient) Invocations() map[string][][]interface{}

func (*FakeSignalClient) StartParticipantSignal 

func (fake *FakeSignalClient) StartParticipantSignal(arg1 context.Context, arg2 livekit.RoomName, arg3 routing.ParticipantInit, arg4 livekit.NodeID) (livekit.ConnectionID, routing.MessageSink, routing.MessageSource, error)

func (*FakeSignalClient) StartParticipantSignalArgsForCall 

func (fake *FakeSignalClient) StartParticipantSignalArgsForCall(i int) (context.Context, livekit.RoomName, routing.ParticipantInit, livekit.NodeID)

func (*FakeSignalClient) StartParticipantSignalCallCount 

func (fake *FakeSignalClient) StartParticipantSignalCallCount() int

func (*FakeSignalClient) StartParticipantSignalCalls 

func (fake *FakeSignalClient) StartParticipantSignalCalls(stub func(context.Context, livekit.RoomName, routing.ParticipantInit, livekit.NodeID) (livekit.ConnectionID, routing.MessageSink, routing.MessageSource, error))

func (*FakeSignalClient) StartParticipantSignalReturns 

func (fake *FakeSignalClient) StartParticipantSignalReturns(result1 livekit.ConnectionID, result2 routing.MessageSink, result3 routing.MessageSource, result4 error)

func (*FakeSignalClient) StartParticipantSignalReturnsOnCall 

func (fake *FakeSignalClient) StartParticipantSignalReturnsOnCall(i int, result1 livekit.ConnectionID, result2 routing.MessageSink, result3 routing.MessageSource, result4 error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.