rpcfakes

package
v1.19.1 Latest Latest
Warning

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

 Go to latest Published: Jul 2, 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.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FakeKeepalivePubSub added in v1.9.5 

type FakeKeepalivePubSub struct {
	KillStub func()

	PublishPingStub func(context.Context, livekit.NodeID, *rpc.KeepalivePing) error

	ShutdownStub func()

	SubscribePingStub func(context.Context, livekit.NodeID) (psrpc.Subscription[*rpc.KeepalivePing], error)
	// contains filtered or unexported fields
}

func (*FakeKeepalivePubSub) Invocations added in v1.9.5 

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

func (*FakeKeepalivePubSub) Kill added in v1.9.5 

func (fake *FakeKeepalivePubSub) Kill()

func (*FakeKeepalivePubSub) KillCallCount added in v1.9.5 

func (fake *FakeKeepalivePubSub) KillCallCount() int

func (*FakeKeepalivePubSub) KillCalls added in v1.9.5 

func (fake *FakeKeepalivePubSub) KillCalls(stub func())

func (*FakeKeepalivePubSub) PublishPing added in v1.9.5 

func (fake *FakeKeepalivePubSub) PublishPing(arg1 context.Context, arg2 livekit.NodeID, arg3 *rpc.KeepalivePing) error

func (*FakeKeepalivePubSub) PublishPingArgsForCall added in v1.9.5 

func (fake *FakeKeepalivePubSub) PublishPingArgsForCall(i int) (context.Context, livekit.NodeID, *rpc.KeepalivePing)

func (*FakeKeepalivePubSub) PublishPingCallCount added in v1.9.5 

func (fake *FakeKeepalivePubSub) PublishPingCallCount() int

func (*FakeKeepalivePubSub) PublishPingCalls added in v1.9.5 

func (fake *FakeKeepalivePubSub) PublishPingCalls(stub func(context.Context, livekit.NodeID, *rpc.KeepalivePing) error)

func (*FakeKeepalivePubSub) PublishPingReturns added in v1.9.5 

func (fake *FakeKeepalivePubSub) PublishPingReturns(result1 error)

func (*FakeKeepalivePubSub) PublishPingReturnsOnCall added in v1.9.5 

func (fake *FakeKeepalivePubSub) PublishPingReturnsOnCall(i int, result1 error)

func (*FakeKeepalivePubSub) Shutdown added in v1.9.5 

func (fake *FakeKeepalivePubSub) Shutdown()

func (*FakeKeepalivePubSub) ShutdownCallCount added in v1.9.5 

func (fake *FakeKeepalivePubSub) ShutdownCallCount() int

func (*FakeKeepalivePubSub) ShutdownCalls added in v1.9.5 

func (fake *FakeKeepalivePubSub) ShutdownCalls(stub func())

func (*FakeKeepalivePubSub) SubscribePing added in v1.9.5 

func (fake *FakeKeepalivePubSub) SubscribePing(arg1 context.Context, arg2 livekit.NodeID) (psrpc.Subscription[*rpc.KeepalivePing], error)

func (*FakeKeepalivePubSub) SubscribePingArgsForCall added in v1.9.5 

func (fake *FakeKeepalivePubSub) SubscribePingArgsForCall(i int) (context.Context, livekit.NodeID)

func (*FakeKeepalivePubSub) SubscribePingCallCount added in v1.9.5 

func (fake *FakeKeepalivePubSub) SubscribePingCallCount() int

func (*FakeKeepalivePubSub) SubscribePingCalls added in v1.9.5 

func (fake *FakeKeepalivePubSub) SubscribePingCalls(stub func(context.Context, livekit.NodeID) (psrpc.Subscription[*rpc.KeepalivePing], error))

func (*FakeKeepalivePubSub) SubscribePingReturns added in v1.9.5 

func (fake *FakeKeepalivePubSub) SubscribePingReturns(result1 psrpc.Subscription[*rpc.KeepalivePing], result2 error)

func (*FakeKeepalivePubSub) SubscribePingReturnsOnCall added in v1.9.5 

func (fake *FakeKeepalivePubSub) SubscribePingReturnsOnCall(i int, result1 psrpc.Subscription[*rpc.KeepalivePing], result2 error)

type FakeTypedParticipantClient added in v1.9.0 

type FakeTypedParticipantClient struct {
	MutePublishedTrackStub func(context.Context, rpc.ParticipantTopic, *livekit.MuteRoomTrackRequest, ...psrpc.RequestOption) (*livekit.MuteRoomTrackResponse, error)

	RemoveParticipantStub func(context.Context, rpc.ParticipantTopic, *livekit.RoomParticipantIdentity, ...psrpc.RequestOption) (*livekit.RemoveParticipantResponse, error)

	UpdateParticipantStub func(context.Context, rpc.ParticipantTopic, *livekit.UpdateParticipantRequest, ...psrpc.RequestOption) (*livekit.ParticipantInfo, error)

	UpdateSubscriptionsStub func(context.Context, rpc.ParticipantTopic, *livekit.UpdateSubscriptionsRequest, ...psrpc.RequestOption) (*livekit.UpdateSubscriptionsResponse, error)
	// contains filtered or unexported fields
}

func (*FakeTypedParticipantClient) Invocations added in v1.9.0 

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

func (*FakeTypedParticipantClient) MutePublishedTrack added in v1.9.0 

func (fake *FakeTypedParticipantClient) MutePublishedTrack(arg1 context.Context, arg2 rpc.ParticipantTopic, arg3 *livekit.MuteRoomTrackRequest, arg4 ...psrpc.RequestOption) (*livekit.MuteRoomTrackResponse, error)

func (*FakeTypedParticipantClient) MutePublishedTrackArgsForCall added in v1.9.0 

func (fake *FakeTypedParticipantClient) MutePublishedTrackArgsForCall(i int) (context.Context, rpc.ParticipantTopic, *livekit.MuteRoomTrackRequest, []psrpc.RequestOption)

func (*FakeTypedParticipantClient) MutePublishedTrackCallCount added in v1.9.0 

func (fake *FakeTypedParticipantClient) MutePublishedTrackCallCount() int

func (*FakeTypedParticipantClient) MutePublishedTrackCalls added in v1.9.0 

func (fake *FakeTypedParticipantClient) MutePublishedTrackCalls(stub func(context.Context, rpc.ParticipantTopic, *livekit.MuteRoomTrackRequest, ...psrpc.RequestOption) (*livekit.MuteRoomTrackResponse, error))

func (*FakeTypedParticipantClient) MutePublishedTrackReturns added in v1.9.0 

func (fake *FakeTypedParticipantClient) MutePublishedTrackReturns(result1 *livekit.MuteRoomTrackResponse, result2 error)

func (*FakeTypedParticipantClient) MutePublishedTrackReturnsOnCall added in v1.9.0 

func (fake *FakeTypedParticipantClient) MutePublishedTrackReturnsOnCall(i int, result1 *livekit.MuteRoomTrackResponse, result2 error)

func (*FakeTypedParticipantClient) RemoveParticipant added in v1.9.0 

func (fake *FakeTypedParticipantClient) RemoveParticipant(arg1 context.Context, arg2 rpc.ParticipantTopic, arg3 *livekit.RoomParticipantIdentity, arg4 ...psrpc.RequestOption) (*livekit.RemoveParticipantResponse, error)

func (*FakeTypedParticipantClient) RemoveParticipantArgsForCall added in v1.9.0 

func (fake *FakeTypedParticipantClient) RemoveParticipantArgsForCall(i int) (context.Context, rpc.ParticipantTopic, *livekit.RoomParticipantIdentity, []psrpc.RequestOption)

func (*FakeTypedParticipantClient) RemoveParticipantCallCount added in v1.9.0 

func (fake *FakeTypedParticipantClient) RemoveParticipantCallCount() int

func (*FakeTypedParticipantClient) RemoveParticipantCalls added in v1.9.0 

func (fake *FakeTypedParticipantClient) RemoveParticipantCalls(stub func(context.Context, rpc.ParticipantTopic, *livekit.RoomParticipantIdentity, ...psrpc.RequestOption) (*livekit.RemoveParticipantResponse, error))

func (*FakeTypedParticipantClient) RemoveParticipantReturns added in v1.9.0 

func (fake *FakeTypedParticipantClient) RemoveParticipantReturns(result1 *livekit.RemoveParticipantResponse, result2 error)

func (*FakeTypedParticipantClient) RemoveParticipantReturnsOnCall added in v1.9.0 

func (fake *FakeTypedParticipantClient) RemoveParticipantReturnsOnCall(i int, result1 *livekit.RemoveParticipantResponse, result2 error)

func (*FakeTypedParticipantClient) UpdateParticipant added in v1.9.0 

func (fake *FakeTypedParticipantClient) UpdateParticipant(arg1 context.Context, arg2 rpc.ParticipantTopic, arg3 *livekit.UpdateParticipantRequest, arg4 ...psrpc.RequestOption) (*livekit.ParticipantInfo, error)

func (*FakeTypedParticipantClient) UpdateParticipantArgsForCall added in v1.9.0 

func (fake *FakeTypedParticipantClient) UpdateParticipantArgsForCall(i int) (context.Context, rpc.ParticipantTopic, *livekit.UpdateParticipantRequest, []psrpc.RequestOption)

func (*FakeTypedParticipantClient) UpdateParticipantCallCount added in v1.9.0 

func (fake *FakeTypedParticipantClient) UpdateParticipantCallCount() int

func (*FakeTypedParticipantClient) UpdateParticipantCalls added in v1.9.0 

func (fake *FakeTypedParticipantClient) UpdateParticipantCalls(stub func(context.Context, rpc.ParticipantTopic, *livekit.UpdateParticipantRequest, ...psrpc.RequestOption) (*livekit.ParticipantInfo, error))

func (*FakeTypedParticipantClient) UpdateParticipantReturns added in v1.9.0 

func (fake *FakeTypedParticipantClient) UpdateParticipantReturns(result1 *livekit.ParticipantInfo, result2 error)

func (*FakeTypedParticipantClient) UpdateParticipantReturnsOnCall added in v1.9.0 

func (fake *FakeTypedParticipantClient) UpdateParticipantReturnsOnCall(i int, result1 *livekit.ParticipantInfo, result2 error)

func (*FakeTypedParticipantClient) UpdateSubscriptions added in v1.9.0 

func (fake *FakeTypedParticipantClient) UpdateSubscriptions(arg1 context.Context, arg2 rpc.ParticipantTopic, arg3 *livekit.UpdateSubscriptionsRequest, arg4 ...psrpc.RequestOption) (*livekit.UpdateSubscriptionsResponse, error)

func (*FakeTypedParticipantClient) UpdateSubscriptionsArgsForCall added in v1.9.0 

func (fake *FakeTypedParticipantClient) UpdateSubscriptionsArgsForCall(i int) (context.Context, rpc.ParticipantTopic, *livekit.UpdateSubscriptionsRequest, []psrpc.RequestOption)

func (*FakeTypedParticipantClient) UpdateSubscriptionsCallCount added in v1.9.0 

func (fake *FakeTypedParticipantClient) UpdateSubscriptionsCallCount() int

func (*FakeTypedParticipantClient) UpdateSubscriptionsCalls added in v1.9.0 

func (fake *FakeTypedParticipantClient) UpdateSubscriptionsCalls(stub func(context.Context, rpc.ParticipantTopic, *livekit.UpdateSubscriptionsRequest, ...psrpc.RequestOption) (*livekit.UpdateSubscriptionsResponse, error))

func (*FakeTypedParticipantClient) UpdateSubscriptionsReturns added in v1.9.0 

func (fake *FakeTypedParticipantClient) UpdateSubscriptionsReturns(result1 *livekit.UpdateSubscriptionsResponse, result2 error)

func (*FakeTypedParticipantClient) UpdateSubscriptionsReturnsOnCall added in v1.9.0 

func (fake *FakeTypedParticipantClient) UpdateSubscriptionsReturnsOnCall(i int, result1 *livekit.UpdateSubscriptionsResponse, result2 error)

type FakeTypedRoomClient 

type FakeTypedRoomClient struct {
	DeleteRoomStub func(context.Context, rpc.RoomTopic, *livekit.DeleteRoomRequest, ...psrpc.RequestOption) (*livekit.DeleteRoomResponse, error)

	SendDataStub func(context.Context, rpc.RoomTopic, *livekit.SendDataRequest, ...psrpc.RequestOption) (*livekit.SendDataResponse, error)

	UpdateRoomMetadataStub func(context.Context, rpc.RoomTopic, *livekit.UpdateRoomMetadataRequest, ...psrpc.RequestOption) (*livekit.Room, error)
	// contains filtered or unexported fields
}

func (*FakeTypedRoomClient) DeleteRoom 

func (fake *FakeTypedRoomClient) DeleteRoom(arg1 context.Context, arg2 rpc.RoomTopic, arg3 *livekit.DeleteRoomRequest, arg4 ...psrpc.RequestOption) (*livekit.DeleteRoomResponse, error)

func (*FakeTypedRoomClient) DeleteRoomArgsForCall 

func (fake *FakeTypedRoomClient) DeleteRoomArgsForCall(i int) (context.Context, rpc.RoomTopic, *livekit.DeleteRoomRequest, []psrpc.RequestOption)

func (*FakeTypedRoomClient) DeleteRoomCallCount 

func (fake *FakeTypedRoomClient) DeleteRoomCallCount() int

func (*FakeTypedRoomClient) DeleteRoomCalls 

func (fake *FakeTypedRoomClient) DeleteRoomCalls(stub func(context.Context, rpc.RoomTopic, *livekit.DeleteRoomRequest, ...psrpc.RequestOption) (*livekit.DeleteRoomResponse, error))

func (*FakeTypedRoomClient) DeleteRoomReturns 

func (fake *FakeTypedRoomClient) DeleteRoomReturns(result1 *livekit.DeleteRoomResponse, result2 error)

func (*FakeTypedRoomClient) DeleteRoomReturnsOnCall 

func (fake *FakeTypedRoomClient) DeleteRoomReturnsOnCall(i int, result1 *livekit.DeleteRoomResponse, result2 error)

func (*FakeTypedRoomClient) Invocations 

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

func (*FakeTypedRoomClient) SendData 

func (fake *FakeTypedRoomClient) SendData(arg1 context.Context, arg2 rpc.RoomTopic, arg3 *livekit.SendDataRequest, arg4 ...psrpc.RequestOption) (*livekit.SendDataResponse, error)

func (*FakeTypedRoomClient) SendDataArgsForCall 

func (fake *FakeTypedRoomClient) SendDataArgsForCall(i int) (context.Context, rpc.RoomTopic, *livekit.SendDataRequest, []psrpc.RequestOption)

func (*FakeTypedRoomClient) SendDataCallCount 

func (fake *FakeTypedRoomClient) SendDataCallCount() int

func (*FakeTypedRoomClient) SendDataCalls 

func (fake *FakeTypedRoomClient) SendDataCalls(stub func(context.Context, rpc.RoomTopic, *livekit.SendDataRequest, ...psrpc.RequestOption) (*livekit.SendDataResponse, error))

func (*FakeTypedRoomClient) SendDataReturns 

func (fake *FakeTypedRoomClient) SendDataReturns(result1 *livekit.SendDataResponse, result2 error)

func (*FakeTypedRoomClient) SendDataReturnsOnCall 

func (fake *FakeTypedRoomClient) SendDataReturnsOnCall(i int, result1 *livekit.SendDataResponse, result2 error)

func (*FakeTypedRoomClient) UpdateRoomMetadata 

func (fake *FakeTypedRoomClient) UpdateRoomMetadata(arg1 context.Context, arg2 rpc.RoomTopic, arg3 *livekit.UpdateRoomMetadataRequest, arg4 ...psrpc.RequestOption) (*livekit.Room, error)

func (*FakeTypedRoomClient) UpdateRoomMetadataArgsForCall 

func (fake *FakeTypedRoomClient) UpdateRoomMetadataArgsForCall(i int) (context.Context, rpc.RoomTopic, *livekit.UpdateRoomMetadataRequest, []psrpc.RequestOption)

func (*FakeTypedRoomClient) UpdateRoomMetadataCallCount 

func (fake *FakeTypedRoomClient) UpdateRoomMetadataCallCount() int

func (*FakeTypedRoomClient) UpdateRoomMetadataCalls 

func (fake *FakeTypedRoomClient) UpdateRoomMetadataCalls(stub func(context.Context, rpc.RoomTopic, *livekit.UpdateRoomMetadataRequest, ...psrpc.RequestOption) (*livekit.Room, error))

func (*FakeTypedRoomClient) UpdateRoomMetadataReturns 

func (fake *FakeTypedRoomClient) UpdateRoomMetadataReturns(result1 *livekit.Room, result2 error)

func (*FakeTypedRoomClient) UpdateRoomMetadataReturnsOnCall 

func (fake *FakeTypedRoomClient) UpdateRoomMetadataReturnsOnCall(i int, result1 *livekit.Room, result2 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.