routingfakes

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Nov 30, 2022 License: Apache-2.0 Imports: 5 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.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeMessageSink 

type FakeMessageSink struct {
	CloseStub 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) 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()

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

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

	DrainStub func()

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

	GetRegionStub func() string

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

	OnNewParticipantRTCStub func(routing.NewParticipantCallback)

	OnRTCMessageStub func(routing.RTCMessageCallback)

	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) (livekit.ConnectionID, routing.MessageSink, routing.MessageSource, error)

	StopStub func()

	UnregisterNodeStub func() error

	WriteParticipantRTCStub func(context.Context, livekit.RoomName, livekit.ParticipantIdentity, *livekit.RTCNodeMessage) error

	WriteRoomRTCStub func(context.Context, livekit.RoomName, *livekit.RTCNodeMessage) 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) 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) 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 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) (livekit.ConnectionID, routing.MessageSink, routing.MessageSource, 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) (livekit.ConnectionID, routing.MessageSink, routing.MessageSource, error))

func (*FakeRouter) StartParticipantSignalReturns 

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

func (*FakeRouter) StartParticipantSignalReturnsOnCall 

func (fake *FakeRouter) StartParticipantSignalReturnsOnCall(i int, result1 livekit.ConnectionID, 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)

func (*FakeRouter) WriteParticipantRTC 

func (fake *FakeRouter) WriteParticipantRTC(arg1 context.Context, arg2 livekit.RoomName, arg3 livekit.ParticipantIdentity, arg4 *livekit.RTCNodeMessage) error

func (*FakeRouter) WriteParticipantRTCArgsForCall 

func (fake *FakeRouter) WriteParticipantRTCArgsForCall(i int) (context.Context, livekit.RoomName, livekit.ParticipantIdentity, *livekit.RTCNodeMessage)

func (*FakeRouter) WriteParticipantRTCCallCount 

func (fake *FakeRouter) WriteParticipantRTCCallCount() int

func (*FakeRouter) WriteParticipantRTCCalls 

func (fake *FakeRouter) WriteParticipantRTCCalls(stub func(context.Context, livekit.RoomName, livekit.ParticipantIdentity, *livekit.RTCNodeMessage) error)

func (*FakeRouter) WriteParticipantRTCReturns 

func (fake *FakeRouter) WriteParticipantRTCReturns(result1 error)

func (*FakeRouter) WriteParticipantRTCReturnsOnCall 

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

func (*FakeRouter) WriteRoomRTC 

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

func (*FakeRouter) WriteRoomRTCArgsForCall 

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

func (*FakeRouter) WriteRoomRTCCallCount 

func (fake *FakeRouter) WriteRoomRTCCallCount() int

func (*FakeRouter) WriteRoomRTCCalls 

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

func (*FakeRouter) WriteRoomRTCReturns 

func (fake *FakeRouter) WriteRoomRTCReturns(result1 error)

func (*FakeRouter) WriteRoomRTCReturnsOnCall 

func (fake *FakeRouter) WriteRoomRTCReturnsOnCall(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.