rpcfakes

package
v0.0.2 Latest Latest
Warning

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

 Go to latest Published: Dec 29, 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 FakeKeepalivePubSub 

type FakeKeepalivePubSub struct {
	CloseStub func()

	KillStub func()

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

	ShutdownStub func()

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

func (*FakeKeepalivePubSub) Close 

func (fake *FakeKeepalivePubSub) Close()

func (*FakeKeepalivePubSub) CloseCallCount 

func (fake *FakeKeepalivePubSub) CloseCallCount() int

func (*FakeKeepalivePubSub) CloseCalls 

func (fake *FakeKeepalivePubSub) CloseCalls(stub func())

func (*FakeKeepalivePubSub) Invocations 

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

func (*FakeKeepalivePubSub) Kill 

func (fake *FakeKeepalivePubSub) Kill()

func (*FakeKeepalivePubSub) KillCallCount 

func (fake *FakeKeepalivePubSub) KillCallCount() int

func (*FakeKeepalivePubSub) KillCalls 

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

func (*FakeKeepalivePubSub) PublishPing 

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

func (*FakeKeepalivePubSub) PublishPingArgsForCall 

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

func (*FakeKeepalivePubSub) PublishPingCallCount 

func (fake *FakeKeepalivePubSub) PublishPingCallCount() int

func (*FakeKeepalivePubSub) PublishPingCalls 

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

func (*FakeKeepalivePubSub) PublishPingReturns 

func (fake *FakeKeepalivePubSub) PublishPingReturns(result1 error)

func (*FakeKeepalivePubSub) PublishPingReturnsOnCall 

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

func (*FakeKeepalivePubSub) Shutdown 

func (fake *FakeKeepalivePubSub) Shutdown()

func (*FakeKeepalivePubSub) ShutdownCallCount 

func (fake *FakeKeepalivePubSub) ShutdownCallCount() int

func (*FakeKeepalivePubSub) ShutdownCalls 

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

func (*FakeKeepalivePubSub) SubscribePing 

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

func (*FakeKeepalivePubSub) SubscribePingArgsForCall 

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

func (*FakeKeepalivePubSub) SubscribePingCallCount 

func (fake *FakeKeepalivePubSub) SubscribePingCallCount() int

func (*FakeKeepalivePubSub) SubscribePingCalls 

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

func (*FakeKeepalivePubSub) SubscribePingReturns 

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

func (*FakeKeepalivePubSub) SubscribePingReturnsOnCall 

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

type FakeTypedAgentDispatchInternalClient 

type FakeTypedAgentDispatchInternalClient struct {
	CloseStub func()

	CreateDispatchStub func(context.Context, rpc.RoomTopic, *wirtual.AgentDispatch, ...psrpc.RequestOption) (*wirtual.AgentDispatch, error)

	DeleteDispatchStub func(context.Context, rpc.RoomTopic, *wirtual.DeleteAgentDispatchRequest, ...psrpc.RequestOption) (*wirtual.AgentDispatch, error)

	ListDispatchStub func(context.Context, rpc.RoomTopic, *wirtual.ListAgentDispatchRequest, ...psrpc.RequestOption) (*wirtual.ListAgentDispatchResponse, error)
	// contains filtered or unexported fields
}

func (*FakeTypedAgentDispatchInternalClient) Close 

func (fake *FakeTypedAgentDispatchInternalClient) Close()

func (*FakeTypedAgentDispatchInternalClient) CloseCallCount 

func (fake *FakeTypedAgentDispatchInternalClient) CloseCallCount() int

func (*FakeTypedAgentDispatchInternalClient) CloseCalls 

func (fake *FakeTypedAgentDispatchInternalClient) CloseCalls(stub func())

func (*FakeTypedAgentDispatchInternalClient) CreateDispatch 

func (fake *FakeTypedAgentDispatchInternalClient) CreateDispatch(arg1 context.Context, arg2 rpc.RoomTopic, arg3 *wirtual.AgentDispatch, arg4 ...psrpc.RequestOption) (*wirtual.AgentDispatch, error)

func (*FakeTypedAgentDispatchInternalClient) CreateDispatchArgsForCall 

func (fake *FakeTypedAgentDispatchInternalClient) CreateDispatchArgsForCall(i int) (context.Context, rpc.RoomTopic, *wirtual.AgentDispatch, []psrpc.RequestOption)

func (*FakeTypedAgentDispatchInternalClient) CreateDispatchCallCount 

func (fake *FakeTypedAgentDispatchInternalClient) CreateDispatchCallCount() int

func (*FakeTypedAgentDispatchInternalClient) CreateDispatchCalls 

func (fake *FakeTypedAgentDispatchInternalClient) CreateDispatchCalls(stub func(context.Context, rpc.RoomTopic, *wirtual.AgentDispatch, ...psrpc.RequestOption) (*wirtual.AgentDispatch, error))

func (*FakeTypedAgentDispatchInternalClient) CreateDispatchReturns 

func (fake *FakeTypedAgentDispatchInternalClient) CreateDispatchReturns(result1 *wirtual.AgentDispatch, result2 error)

func (*FakeTypedAgentDispatchInternalClient) CreateDispatchReturnsOnCall 

func (fake *FakeTypedAgentDispatchInternalClient) CreateDispatchReturnsOnCall(i int, result1 *wirtual.AgentDispatch, result2 error)

func (*FakeTypedAgentDispatchInternalClient) DeleteDispatch 

func (fake *FakeTypedAgentDispatchInternalClient) DeleteDispatch(arg1 context.Context, arg2 rpc.RoomTopic, arg3 *wirtual.DeleteAgentDispatchRequest, arg4 ...psrpc.RequestOption) (*wirtual.AgentDispatch, error)

func (*FakeTypedAgentDispatchInternalClient) DeleteDispatchArgsForCall 

func (fake *FakeTypedAgentDispatchInternalClient) DeleteDispatchArgsForCall(i int) (context.Context, rpc.RoomTopic, *wirtual.DeleteAgentDispatchRequest, []psrpc.RequestOption)

func (*FakeTypedAgentDispatchInternalClient) DeleteDispatchCallCount 

func (fake *FakeTypedAgentDispatchInternalClient) DeleteDispatchCallCount() int

func (*FakeTypedAgentDispatchInternalClient) DeleteDispatchCalls 

func (fake *FakeTypedAgentDispatchInternalClient) DeleteDispatchCalls(stub func(context.Context, rpc.RoomTopic, *wirtual.DeleteAgentDispatchRequest, ...psrpc.RequestOption) (*wirtual.AgentDispatch, error))

func (*FakeTypedAgentDispatchInternalClient) DeleteDispatchReturns 

func (fake *FakeTypedAgentDispatchInternalClient) DeleteDispatchReturns(result1 *wirtual.AgentDispatch, result2 error)

func (*FakeTypedAgentDispatchInternalClient) DeleteDispatchReturnsOnCall 

func (fake *FakeTypedAgentDispatchInternalClient) DeleteDispatchReturnsOnCall(i int, result1 *wirtual.AgentDispatch, result2 error)

func (*FakeTypedAgentDispatchInternalClient) Invocations 

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

func (*FakeTypedAgentDispatchInternalClient) ListDispatch 

func (fake *FakeTypedAgentDispatchInternalClient) ListDispatch(arg1 context.Context, arg2 rpc.RoomTopic, arg3 *wirtual.ListAgentDispatchRequest, arg4 ...psrpc.RequestOption) (*wirtual.ListAgentDispatchResponse, error)

func (*FakeTypedAgentDispatchInternalClient) ListDispatchArgsForCall 

func (fake *FakeTypedAgentDispatchInternalClient) ListDispatchArgsForCall(i int) (context.Context, rpc.RoomTopic, *wirtual.ListAgentDispatchRequest, []psrpc.RequestOption)

func (*FakeTypedAgentDispatchInternalClient) ListDispatchCallCount 

func (fake *FakeTypedAgentDispatchInternalClient) ListDispatchCallCount() int

func (*FakeTypedAgentDispatchInternalClient) ListDispatchCalls 

func (fake *FakeTypedAgentDispatchInternalClient) ListDispatchCalls(stub func(context.Context, rpc.RoomTopic, *wirtual.ListAgentDispatchRequest, ...psrpc.RequestOption) (*wirtual.ListAgentDispatchResponse, error))

func (*FakeTypedAgentDispatchInternalClient) ListDispatchReturns 

func (fake *FakeTypedAgentDispatchInternalClient) ListDispatchReturns(result1 *wirtual.ListAgentDispatchResponse, result2 error)

func (*FakeTypedAgentDispatchInternalClient) ListDispatchReturnsOnCall 

func (fake *FakeTypedAgentDispatchInternalClient) ListDispatchReturnsOnCall(i int, result1 *wirtual.ListAgentDispatchResponse, result2 error)

type FakeTypedParticipantClient 

type FakeTypedParticipantClient struct {
	CloseStub func()

	MutePublishedTrackStub func(context.Context, rpc.ParticipantTopic, *wirtual.MuteRoomTrackRequest, ...psrpc.RequestOption) (*wirtual.MuteRoomTrackResponse, error)

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

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

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

func (*FakeTypedParticipantClient) Close 

func (fake *FakeTypedParticipantClient) Close()

func (*FakeTypedParticipantClient) CloseCallCount 

func (fake *FakeTypedParticipantClient) CloseCallCount() int

func (*FakeTypedParticipantClient) CloseCalls 

func (fake *FakeTypedParticipantClient) CloseCalls(stub func())

func (*FakeTypedParticipantClient) Invocations 

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

func (*FakeTypedParticipantClient) MutePublishedTrack 

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

func (*FakeTypedParticipantClient) MutePublishedTrackArgsForCall 

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

func (*FakeTypedParticipantClient) MutePublishedTrackCallCount 

func (fake *FakeTypedParticipantClient) MutePublishedTrackCallCount() int

func (*FakeTypedParticipantClient) MutePublishedTrackCalls 

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

func (*FakeTypedParticipantClient) MutePublishedTrackReturns 

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

func (*FakeTypedParticipantClient) MutePublishedTrackReturnsOnCall 

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

func (*FakeTypedParticipantClient) RemoveParticipant 

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

func (*FakeTypedParticipantClient) RemoveParticipantArgsForCall 

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

func (*FakeTypedParticipantClient) RemoveParticipantCallCount 

func (fake *FakeTypedParticipantClient) RemoveParticipantCallCount() int

func (*FakeTypedParticipantClient) RemoveParticipantCalls 

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

func (*FakeTypedParticipantClient) RemoveParticipantReturns 

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

func (*FakeTypedParticipantClient) RemoveParticipantReturnsOnCall 

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

func (*FakeTypedParticipantClient) UpdateParticipant 

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

func (*FakeTypedParticipantClient) UpdateParticipantArgsForCall 

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

func (*FakeTypedParticipantClient) UpdateParticipantCallCount 

func (fake *FakeTypedParticipantClient) UpdateParticipantCallCount() int

func (*FakeTypedParticipantClient) UpdateParticipantCalls 

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

func (*FakeTypedParticipantClient) UpdateParticipantReturns 

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

func (*FakeTypedParticipantClient) UpdateParticipantReturnsOnCall 

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

func (*FakeTypedParticipantClient) UpdateSubscriptions 

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

func (*FakeTypedParticipantClient) UpdateSubscriptionsArgsForCall 

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

func (*FakeTypedParticipantClient) UpdateSubscriptionsCallCount 

func (fake *FakeTypedParticipantClient) UpdateSubscriptionsCallCount() int

func (*FakeTypedParticipantClient) UpdateSubscriptionsCalls 

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

func (*FakeTypedParticipantClient) UpdateSubscriptionsReturns 

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

func (*FakeTypedParticipantClient) UpdateSubscriptionsReturnsOnCall 

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

type FakeTypedRoomClient 

type FakeTypedRoomClient struct {
	CloseStub func()

	DeleteRoomStub func(context.Context, rpc.RoomTopic, *wirtual.DeleteRoomRequest, ...psrpc.RequestOption) (*wirtual.DeleteRoomResponse, error)

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

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

func (*FakeTypedRoomClient) Close 

func (fake *FakeTypedRoomClient) Close()

func (*FakeTypedRoomClient) CloseCallCount 

func (fake *FakeTypedRoomClient) CloseCallCount() int

func (*FakeTypedRoomClient) CloseCalls 

func (fake *FakeTypedRoomClient) CloseCalls(stub func())

func (*FakeTypedRoomClient) DeleteRoom 

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

func (*FakeTypedRoomClient) DeleteRoomArgsForCall 

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

func (*FakeTypedRoomClient) DeleteRoomCallCount 

func (fake *FakeTypedRoomClient) DeleteRoomCallCount() int

func (*FakeTypedRoomClient) DeleteRoomCalls 

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

func (*FakeTypedRoomClient) DeleteRoomReturns 

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

func (*FakeTypedRoomClient) DeleteRoomReturnsOnCall 

func (fake *FakeTypedRoomClient) DeleteRoomReturnsOnCall(i int, result1 *wirtual.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 *wirtual.SendDataRequest, arg4 ...psrpc.RequestOption) (*wirtual.SendDataResponse, error)

func (*FakeTypedRoomClient) SendDataArgsForCall 

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

func (*FakeTypedRoomClient) SendDataCallCount 

func (fake *FakeTypedRoomClient) SendDataCallCount() int

func (*FakeTypedRoomClient) SendDataCalls 

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

func (*FakeTypedRoomClient) SendDataReturns 

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

func (*FakeTypedRoomClient) SendDataReturnsOnCall 

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

func (*FakeTypedRoomClient) UpdateRoomMetadata 

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

func (*FakeTypedRoomClient) UpdateRoomMetadataArgsForCall 

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

func (*FakeTypedRoomClient) UpdateRoomMetadataCallCount 

func (fake *FakeTypedRoomClient) UpdateRoomMetadataCallCount() int

func (*FakeTypedRoomClient) UpdateRoomMetadataCalls 

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

func (*FakeTypedRoomClient) UpdateRoomMetadataReturns 

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

func (*FakeTypedRoomClient) UpdateRoomMetadataReturnsOnCall 

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