routingfakes

package
v1.10.6 Latest Latest
Warning

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

 Go to latest Published: Jul 13, 2021 License: Apache-2.0 Imports: 4 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.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeMessageSink 

type FakeMessageSink struct {
	CloseStub func()

	OnCloseStub func(func())

	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) Invocations 

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

func (*FakeMessageSink) OnClose 

func (fake *FakeMessageSink) OnClose(arg1 func())

func (*FakeMessageSink) OnCloseArgsForCall 

func (fake *FakeMessageSink) OnCloseArgsForCall(i int) func()

func (*FakeMessageSink) OnCloseCallCount 

func (fake *FakeMessageSink) OnCloseCallCount() int

func (*FakeMessageSink) OnCloseCalls 

func (fake *FakeMessageSink) OnCloseCalls(stub func(func()))

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 {
	ReadChanStub func() <-chan protoreflect.ProtoMessage
	// contains filtered or unexported fields
}

func (*FakeMessageSource) Invocations 

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

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 FakeNodeSelector 

type FakeNodeSelector struct {
	SelectNodeStub func([]*livekit.Node, *livekit.Room) (*livekit.Node, error)
	// contains filtered or unexported fields
}

func (*FakeNodeSelector) Invocations 

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

func (*FakeNodeSelector) SelectNode 

func (fake *FakeNodeSelector) SelectNode(arg1 []*livekit.Node, arg2 *livekit.Room) (*livekit.Node, error)

func (*FakeNodeSelector) SelectNodeArgsForCall 

func (fake *FakeNodeSelector) SelectNodeArgsForCall(i int) ([]*livekit.Node, *livekit.Room)

func (*FakeNodeSelector) SelectNodeCallCount 

func (fake *FakeNodeSelector) SelectNodeCallCount() int

func (*FakeNodeSelector) SelectNodeCalls 

func (fake *FakeNodeSelector) SelectNodeCalls(stub func([]*livekit.Node, *livekit.Room) (*livekit.Node, error))

func (*FakeNodeSelector) SelectNodeReturns 

func (fake *FakeNodeSelector) SelectNodeReturns(result1 *livekit.Node, result2 error)

func (*FakeNodeSelector) SelectNodeReturnsOnCall 

func (fake *FakeNodeSelector) SelectNodeReturnsOnCall(i int, result1 *livekit.Node, result2 error)

type FakeRouter 

type FakeRouter struct {
	ClearRoomStateStub func(string) error

	CreateRTCSinkStub func(string, string) (routing.MessageSink, error)

	GetNodeStub func(string) (*livekit.Node, error)

	GetNodeForRoomStub func(string) (*livekit.Node, error)

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

	OnNewParticipantRTCStub func(routing.NewParticipantCallback)

	OnRTCMessageStub func(routing.RTCMessageCallback)

	RegisterNodeStub func() error

	RemoveDeadNodesStub func() error

	SetNodeForRoomStub func(string, string) error

	StartStub func() error

	StartParticipantSignalStub func(string, routing.ParticipantInit) (string, routing.MessageSink, routing.MessageSource, error)

	StopStub func()

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

func (*FakeRouter) ClearRoomState 

func (fake *FakeRouter) ClearRoomState(arg1 string) error

func (*FakeRouter) ClearRoomStateArgsForCall 

func (fake *FakeRouter) ClearRoomStateArgsForCall(i int) string

func (*FakeRouter) ClearRoomStateCallCount 

func (fake *FakeRouter) ClearRoomStateCallCount() int

func (*FakeRouter) ClearRoomStateCalls 

func (fake *FakeRouter) ClearRoomStateCalls(stub func(string) error)

func (*FakeRouter) ClearRoomStateReturns 

func (fake *FakeRouter) ClearRoomStateReturns(result1 error)

func (*FakeRouter) ClearRoomStateReturnsOnCall 

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

func (*FakeRouter) CreateRTCSink 

func (fake *FakeRouter) CreateRTCSink(arg1 string, arg2 string) (routing.MessageSink, error)

func (*FakeRouter) CreateRTCSinkArgsForCall 

func (fake *FakeRouter) CreateRTCSinkArgsForCall(i int) (string, string)

func (*FakeRouter) CreateRTCSinkCallCount 

func (fake *FakeRouter) CreateRTCSinkCallCount() int

func (*FakeRouter) CreateRTCSinkCalls 

func (fake *FakeRouter) CreateRTCSinkCalls(stub func(string, string) (routing.MessageSink, error))

func (*FakeRouter) CreateRTCSinkReturns 

func (fake *FakeRouter) CreateRTCSinkReturns(result1 routing.MessageSink, result2 error)

func (*FakeRouter) CreateRTCSinkReturnsOnCall 

func (fake *FakeRouter) CreateRTCSinkReturnsOnCall(i int, result1 routing.MessageSink, result2 error)

func (*FakeRouter) GetNode 

func (fake *FakeRouter) GetNode(arg1 string) (*livekit.Node, error)

func (*FakeRouter) GetNodeArgsForCall 

func (fake *FakeRouter) GetNodeArgsForCall(i int) string

func (*FakeRouter) GetNodeCallCount 

func (fake *FakeRouter) GetNodeCallCount() int

func (*FakeRouter) GetNodeCalls 

func (fake *FakeRouter) GetNodeCalls(stub func(string) (*livekit.Node, error))

func (*FakeRouter) GetNodeForRoom 

func (fake *FakeRouter) GetNodeForRoom(arg1 string) (*livekit.Node, error)

func (*FakeRouter) GetNodeForRoomArgsForCall 

func (fake *FakeRouter) GetNodeForRoomArgsForCall(i int) string

func (*FakeRouter) GetNodeForRoomCallCount 

func (fake *FakeRouter) GetNodeForRoomCallCount() int

func (*FakeRouter) GetNodeForRoomCalls 

func (fake *FakeRouter) GetNodeForRoomCalls(stub func(string) (*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) GetNodeReturns 

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

func (*FakeRouter) GetNodeReturnsOnCall 

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

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) OnNewParticipantRTC 

func (fake *FakeRouter) OnNewParticipantRTC(arg1 routing.NewParticipantCallback)

func (*FakeRouter) OnNewParticipantRTCArgsForCall 

func (fake *FakeRouter) OnNewParticipantRTCArgsForCall(i int) routing.NewParticipantCallback

func (*FakeRouter) OnNewParticipantRTCCallCount 

func (fake *FakeRouter) OnNewParticipantRTCCallCount() int

func (*FakeRouter) OnNewParticipantRTCCalls 

func (fake *FakeRouter) OnNewParticipantRTCCalls(stub func(routing.NewParticipantCallback))

func (*FakeRouter) OnRTCMessage 

func (fake *FakeRouter) OnRTCMessage(arg1 routing.RTCMessageCallback)

func (*FakeRouter) OnRTCMessageArgsForCall 

func (fake *FakeRouter) OnRTCMessageArgsForCall(i int) routing.RTCMessageCallback

func (*FakeRouter) OnRTCMessageCallCount 

func (fake *FakeRouter) OnRTCMessageCallCount() int

func (*FakeRouter) OnRTCMessageCalls 

func (fake *FakeRouter) OnRTCMessageCalls(stub func(routing.RTCMessageCallback))

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 string, arg2 string) error

func (*FakeRouter) SetNodeForRoomArgsForCall 

func (fake *FakeRouter) SetNodeForRoomArgsForCall(i int) (string, string)

func (*FakeRouter) SetNodeForRoomCallCount 

func (fake *FakeRouter) SetNodeForRoomCallCount() int

func (*FakeRouter) SetNodeForRoomCalls 

func (fake *FakeRouter) SetNodeForRoomCalls(stub func(string, string) 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 string, arg2 routing.ParticipantInit) (string, routing.MessageSink, routing.MessageSource, error)

func (*FakeRouter) StartParticipantSignalArgsForCall 

func (fake *FakeRouter) StartParticipantSignalArgsForCall(i int) (string, routing.ParticipantInit)

func (*FakeRouter) StartParticipantSignalCallCount 

func (fake *FakeRouter) StartParticipantSignalCallCount() int

func (*FakeRouter) StartParticipantSignalCalls 

func (fake *FakeRouter) StartParticipantSignalCalls(stub func(string, routing.ParticipantInit) (string, routing.MessageSink, routing.MessageSource, error))

func (*FakeRouter) StartParticipantSignalReturns 

func (fake *FakeRouter) StartParticipantSignalReturns(result1 string, result2 routing.MessageSink, result3 routing.MessageSource, result4 error)

func (*FakeRouter) StartParticipantSignalReturnsOnCall 

func (fake *FakeRouter) StartParticipantSignalReturnsOnCall(i int, result1 string, result2 routing.MessageSink, result3 routing.MessageSource, result4 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)

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.