routingfakes

package
v0.15.4 Latest Latest
Warning

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

 Go to latest Published: Feb 9, 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()

	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 FakeRouter 

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

	DrainStub func()

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

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

	StartStub func() error

	StartParticipantSignalStub func(context.Context, livekit.RoomName, routing.ParticipantInit) (string, 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 added in v0.13.5 

func (fake *FakeRouter) Drain()

func (*FakeRouter) DrainCallCount added in v0.13.5 

func (fake *FakeRouter) DrainCallCount() int

func (*FakeRouter) DrainCalls added in v0.13.5 

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

func (*FakeRouter) SetNodeForRoomArgsForCall 

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

func (*FakeRouter) SetNodeForRoomCallCount 

func (fake *FakeRouter) SetNodeForRoomCallCount() int

func (*FakeRouter) SetNodeForRoomCalls 

func (fake *FakeRouter) SetNodeForRoomCalls(stub func(context.Context, livekit.RoomName, 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 context.Context, arg2 livekit.RoomName, arg3 routing.ParticipantInit) (string, 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) (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)

func (*FakeRouter) WriteParticipantRTC added in v0.14.2 

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

func (*FakeRouter) WriteParticipantRTCArgsForCall added in v0.14.2 

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

func (*FakeRouter) WriteParticipantRTCCallCount added in v0.14.2 

func (fake *FakeRouter) WriteParticipantRTCCallCount() int

func (*FakeRouter) WriteParticipantRTCCalls added in v0.14.2 

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

func (*FakeRouter) WriteParticipantRTCReturns added in v0.14.2 

func (fake *FakeRouter) WriteParticipantRTCReturns(result1 error)

func (*FakeRouter) WriteParticipantRTCReturnsOnCall added in v0.14.2 

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

func (*FakeRouter) WriteRoomRTC added in v0.14.2 

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

func (*FakeRouter) WriteRoomRTCArgsForCall added in v0.14.2 

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

func (*FakeRouter) WriteRoomRTCCallCount added in v0.14.2 

func (fake *FakeRouter) WriteRoomRTCCallCount() int

func (*FakeRouter) WriteRoomRTCCalls added in v0.14.2 

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

func (*FakeRouter) WriteRoomRTCReturns added in v0.14.2 

func (fake *FakeRouter) WriteRoomRTCReturns(result1 error)

func (*FakeRouter) WriteRoomRTCReturnsOnCall added in v0.14.2 

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.