routingfakes

package
v1.7.2 Latest Latest
Warning

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

 Go to latest Published: Aug 12, 2024 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.

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 added in v1.4.4 

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

func (*FakeMessageSink) ConnectionIDCallCount added in v1.4.4 

func (fake *FakeMessageSink) ConnectionIDCallCount() int

func (*FakeMessageSink) ConnectionIDCalls added in v1.4.4 

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

func (*FakeMessageSink) ConnectionIDReturns added in v1.4.4 

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

func (*FakeMessageSink) ConnectionIDReturnsOnCall added in v1.4.4 

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

func (*FakeMessageSink) Invocations 

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

func (*FakeMessageSink) IsClosed added in v1.3.4 

func (fake *FakeMessageSink) IsClosed() bool

func (*FakeMessageSink) IsClosedCallCount added in v1.3.4 

func (fake *FakeMessageSink) IsClosedCallCount() int

func (*FakeMessageSink) IsClosedCalls added in v1.3.4 

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

func (*FakeMessageSink) IsClosedReturns added in v1.3.4 

func (fake *FakeMessageSink) IsClosedReturns(result1 bool)

func (*FakeMessageSink) IsClosedReturnsOnCall added in v1.3.4 

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 added in v0.15.7 

func (fake *FakeMessageSource) Close()

func (*FakeMessageSource) CloseCallCount added in v0.15.7 

func (fake *FakeMessageSource) CloseCallCount() int

func (*FakeMessageSource) CloseCalls added in v0.15.7 

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

func (*FakeMessageSource) ConnectionID added in v1.4.4 

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

func (*FakeMessageSource) ConnectionIDCallCount added in v1.4.4 

func (fake *FakeMessageSource) ConnectionIDCallCount() int

func (*FakeMessageSource) ConnectionIDCalls added in v1.4.4 

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

func (*FakeMessageSource) ConnectionIDReturns added in v1.4.4 

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

func (*FakeMessageSource) ConnectionIDReturnsOnCall added in v1.4.4 

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

func (*FakeMessageSource) Invocations 

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

func (*FakeMessageSource) IsClosed added in v1.3.4 

func (fake *FakeMessageSource) IsClosed() bool

func (*FakeMessageSource) IsClosedCallCount added in v1.3.4 

func (fake *FakeMessageSource) IsClosedCallCount() int

func (*FakeMessageSource) IsClosedCalls added in v1.3.4 

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

func (*FakeMessageSource) IsClosedReturns added in v1.3.4 

func (fake *FakeMessageSource) IsClosedReturns(result1 bool)

func (*FakeMessageSource) IsClosedReturnsOnCall added in v1.3.4 

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

	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) 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) GetRegion added in v0.15.7 

func (fake *FakeRouter) GetRegion() string

func (*FakeRouter) GetRegionCallCount added in v0.15.7 

func (fake *FakeRouter) GetRegionCallCount() int

func (*FakeRouter) GetRegionCalls added in v0.15.7 

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

func (*FakeRouter) GetRegionReturns added in v0.15.7 

func (fake *FakeRouter) GetRegionReturns(result1 string)

func (*FakeRouter) GetRegionReturnsOnCall added in v0.15.7 

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 added in v1.4.0 

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 added in v1.4.0 

func (fake *FakeSignalClient) ActiveCount() int

func (*FakeSignalClient) ActiveCountCallCount added in v1.4.0 

func (fake *FakeSignalClient) ActiveCountCallCount() int

func (*FakeSignalClient) ActiveCountCalls added in v1.4.0 

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

func (*FakeSignalClient) ActiveCountReturns added in v1.4.0 

func (fake *FakeSignalClient) ActiveCountReturns(result1 int)

func (*FakeSignalClient) ActiveCountReturnsOnCall added in v1.4.0 

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

func (*FakeSignalClient) Invocations added in v1.4.0 

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

func (*FakeSignalClient) StartParticipantSignal added in v1.4.0 

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 added in v1.4.0 

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

func (*FakeSignalClient) StartParticipantSignalCallCount added in v1.4.0 

func (fake *FakeSignalClient) StartParticipantSignalCallCount() int

func (*FakeSignalClient) StartParticipantSignalCalls added in v1.4.0 

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

func (*FakeSignalClient) StartParticipantSignalReturns added in v1.4.0 

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

func (*FakeSignalClient) StartParticipantSignalReturnsOnCall added in v1.4.0 

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.