Documentation ¶
Index ¶
- type MockServerStreamingClient
- func (_m *MockServerStreamingClient[Res]) CloseSend() error
- func (_m *MockServerStreamingClient[Res]) Context() context.Context
- func (_m *MockServerStreamingClient[Res]) EXPECT() *MockServerStreamingClient_Expecter[Res]
- func (_m *MockServerStreamingClient[Res]) Header() (metadata.MD, error)
- func (_m *MockServerStreamingClient[Res]) Recv() (*testproto.Msg, error)
- func (_m *MockServerStreamingClient[Res]) RecvMsg(m interface{}) error
- func (_m *MockServerStreamingClient[Res]) SendMsg(m interface{}) error
- func (_m *MockServerStreamingClient[Res]) Trailer() metadata.MD
- type MockServerStreamingClient_CloseSend_Call
- func (_c *MockServerStreamingClient_CloseSend_Call[Res]) Return(_a0 error) *MockServerStreamingClient_CloseSend_Call[Res]
- func (_c *MockServerStreamingClient_CloseSend_Call[Res]) Run(run func()) *MockServerStreamingClient_CloseSend_Call[Res]
- func (_c *MockServerStreamingClient_CloseSend_Call[Res]) RunAndReturn(run func() error) *MockServerStreamingClient_CloseSend_Call[Res]
- type MockServerStreamingClient_Context_Call
- func (_c *MockServerStreamingClient_Context_Call[Res]) Return(_a0 context.Context) *MockServerStreamingClient_Context_Call[Res]
- func (_c *MockServerStreamingClient_Context_Call[Res]) Run(run func()) *MockServerStreamingClient_Context_Call[Res]
- func (_c *MockServerStreamingClient_Context_Call[Res]) RunAndReturn(run func() context.Context) *MockServerStreamingClient_Context_Call[Res]
- type MockServerStreamingClient_Expecter
- func (_e *MockServerStreamingClient_Expecter[Res]) CloseSend() *MockServerStreamingClient_CloseSend_Call[Res]
- func (_e *MockServerStreamingClient_Expecter[Res]) Context() *MockServerStreamingClient_Context_Call[Res]
- func (_e *MockServerStreamingClient_Expecter[Res]) Header() *MockServerStreamingClient_Header_Call[Res]
- func (_e *MockServerStreamingClient_Expecter[Res]) Recv() *MockServerStreamingClient_Recv_Call[Res]
- func (_e *MockServerStreamingClient_Expecter[Res]) RecvMsg(m interface{}) *MockServerStreamingClient_RecvMsg_Call[Res]
- func (_e *MockServerStreamingClient_Expecter[Res]) SendMsg(m interface{}) *MockServerStreamingClient_SendMsg_Call[Res]
- func (_e *MockServerStreamingClient_Expecter[Res]) Trailer() *MockServerStreamingClient_Trailer_Call[Res]
- type MockServerStreamingClient_Header_Call
- func (_c *MockServerStreamingClient_Header_Call[Res]) Return(_a0 metadata.MD, _a1 error) *MockServerStreamingClient_Header_Call[Res]
- func (_c *MockServerStreamingClient_Header_Call[Res]) Run(run func()) *MockServerStreamingClient_Header_Call[Res]
- func (_c *MockServerStreamingClient_Header_Call[Res]) RunAndReturn(run func() (metadata.MD, error)) *MockServerStreamingClient_Header_Call[Res]
- type MockServerStreamingClient_RecvMsg_Call
- func (_c *MockServerStreamingClient_RecvMsg_Call[Res]) Return(_a0 error) *MockServerStreamingClient_RecvMsg_Call[Res]
- func (_c *MockServerStreamingClient_RecvMsg_Call[Res]) Run(run func(m interface{})) *MockServerStreamingClient_RecvMsg_Call[Res]
- func (_c *MockServerStreamingClient_RecvMsg_Call[Res]) RunAndReturn(run func(interface{}) error) *MockServerStreamingClient_RecvMsg_Call[Res]
- type MockServerStreamingClient_Recv_Call
- func (_c *MockServerStreamingClient_Recv_Call[Res]) Return(_a0 *testproto.Msg, _a1 error) *MockServerStreamingClient_Recv_Call[Res]
- func (_c *MockServerStreamingClient_Recv_Call[Res]) Run(run func()) *MockServerStreamingClient_Recv_Call[Res]
- func (_c *MockServerStreamingClient_Recv_Call[Res]) RunAndReturn(run func() (*testproto.Msg, error)) *MockServerStreamingClient_Recv_Call[Res]
- type MockServerStreamingClient_SendMsg_Call
- func (_c *MockServerStreamingClient_SendMsg_Call[Res]) Return(_a0 error) *MockServerStreamingClient_SendMsg_Call[Res]
- func (_c *MockServerStreamingClient_SendMsg_Call[Res]) Run(run func(m interface{})) *MockServerStreamingClient_SendMsg_Call[Res]
- func (_c *MockServerStreamingClient_SendMsg_Call[Res]) RunAndReturn(run func(interface{}) error) *MockServerStreamingClient_SendMsg_Call[Res]
- type MockServerStreamingClient_Trailer_Call
- func (_c *MockServerStreamingClient_Trailer_Call[Res]) Return(_a0 metadata.MD) *MockServerStreamingClient_Trailer_Call[Res]
- func (_c *MockServerStreamingClient_Trailer_Call[Res]) Run(run func()) *MockServerStreamingClient_Trailer_Call[Res]
- func (_c *MockServerStreamingClient_Trailer_Call[Res]) RunAndReturn(run func() metadata.MD) *MockServerStreamingClient_Trailer_Call[Res]
- type MockServerStreamingServer
- func (_m *MockServerStreamingServer[Res]) Context() context.Context
- func (_m *MockServerStreamingServer[Res]) EXPECT() *MockServerStreamingServer_Expecter[Res]
- func (_m *MockServerStreamingServer[Res]) RecvMsg(m interface{}) error
- func (_m *MockServerStreamingServer[Res]) Send(_a0 *testproto.Msg) error
- func (_m *MockServerStreamingServer[Res]) SendHeader(_a0 metadata.MD) error
- func (_m *MockServerStreamingServer[Res]) SendMsg(m interface{}) error
- func (_m *MockServerStreamingServer[Res]) SetHeader(_a0 metadata.MD) error
- func (_m *MockServerStreamingServer[Res]) SetTrailer(_a0 metadata.MD)
- type MockServerStreamingServer_Context_Call
- func (_c *MockServerStreamingServer_Context_Call[Res]) Return(_a0 context.Context) *MockServerStreamingServer_Context_Call[Res]
- func (_c *MockServerStreamingServer_Context_Call[Res]) Run(run func()) *MockServerStreamingServer_Context_Call[Res]
- func (_c *MockServerStreamingServer_Context_Call[Res]) RunAndReturn(run func() context.Context) *MockServerStreamingServer_Context_Call[Res]
- type MockServerStreamingServer_Expecter
- func (_e *MockServerStreamingServer_Expecter[Res]) Context() *MockServerStreamingServer_Context_Call[Res]
- func (_e *MockServerStreamingServer_Expecter[Res]) RecvMsg(m interface{}) *MockServerStreamingServer_RecvMsg_Call[Res]
- func (_e *MockServerStreamingServer_Expecter[Res]) Send(_a0 interface{}) *MockServerStreamingServer_Send_Call[Res]
- func (_e *MockServerStreamingServer_Expecter[Res]) SendHeader(_a0 interface{}) *MockServerStreamingServer_SendHeader_Call[Res]
- func (_e *MockServerStreamingServer_Expecter[Res]) SendMsg(m interface{}) *MockServerStreamingServer_SendMsg_Call[Res]
- func (_e *MockServerStreamingServer_Expecter[Res]) SetHeader(_a0 interface{}) *MockServerStreamingServer_SetHeader_Call[Res]
- func (_e *MockServerStreamingServer_Expecter[Res]) SetTrailer(_a0 interface{}) *MockServerStreamingServer_SetTrailer_Call[Res]
- type MockServerStreamingServer_RecvMsg_Call
- func (_c *MockServerStreamingServer_RecvMsg_Call[Res]) Return(_a0 error) *MockServerStreamingServer_RecvMsg_Call[Res]
- func (_c *MockServerStreamingServer_RecvMsg_Call[Res]) Run(run func(m interface{})) *MockServerStreamingServer_RecvMsg_Call[Res]
- func (_c *MockServerStreamingServer_RecvMsg_Call[Res]) RunAndReturn(run func(interface{}) error) *MockServerStreamingServer_RecvMsg_Call[Res]
- type MockServerStreamingServer_SendHeader_Call
- func (_c *MockServerStreamingServer_SendHeader_Call[Res]) Return(_a0 error) *MockServerStreamingServer_SendHeader_Call[Res]
- func (_c *MockServerStreamingServer_SendHeader_Call[Res]) Run(run func(_a0 metadata.MD)) *MockServerStreamingServer_SendHeader_Call[Res]
- func (_c *MockServerStreamingServer_SendHeader_Call[Res]) RunAndReturn(run func(metadata.MD) error) *MockServerStreamingServer_SendHeader_Call[Res]
- type MockServerStreamingServer_SendMsg_Call
- func (_c *MockServerStreamingServer_SendMsg_Call[Res]) Return(_a0 error) *MockServerStreamingServer_SendMsg_Call[Res]
- func (_c *MockServerStreamingServer_SendMsg_Call[Res]) Run(run func(m interface{})) *MockServerStreamingServer_SendMsg_Call[Res]
- func (_c *MockServerStreamingServer_SendMsg_Call[Res]) RunAndReturn(run func(interface{}) error) *MockServerStreamingServer_SendMsg_Call[Res]
- type MockServerStreamingServer_Send_Call
- func (_c *MockServerStreamingServer_Send_Call[Res]) Return(_a0 error) *MockServerStreamingServer_Send_Call[Res]
- func (_c *MockServerStreamingServer_Send_Call[Res]) Run(run func(_a0 *testproto.Msg)) *MockServerStreamingServer_Send_Call[Res]
- func (_c *MockServerStreamingServer_Send_Call[Res]) RunAndReturn(run func(*testproto.Msg) error) *MockServerStreamingServer_Send_Call[Res]
- type MockServerStreamingServer_SetHeader_Call
- func (_c *MockServerStreamingServer_SetHeader_Call[Res]) Return(_a0 error) *MockServerStreamingServer_SetHeader_Call[Res]
- func (_c *MockServerStreamingServer_SetHeader_Call[Res]) Run(run func(_a0 metadata.MD)) *MockServerStreamingServer_SetHeader_Call[Res]
- func (_c *MockServerStreamingServer_SetHeader_Call[Res]) RunAndReturn(run func(metadata.MD) error) *MockServerStreamingServer_SetHeader_Call[Res]
- type MockServerStreamingServer_SetTrailer_Call
- func (_c *MockServerStreamingServer_SetTrailer_Call[Res]) Return() *MockServerStreamingServer_SetTrailer_Call[Res]
- func (_c *MockServerStreamingServer_SetTrailer_Call[Res]) Run(run func(_a0 metadata.MD)) *MockServerStreamingServer_SetTrailer_Call[Res]
- func (_c *MockServerStreamingServer_SetTrailer_Call[Res]) RunAndReturn(run func(metadata.MD)) *MockServerStreamingServer_SetTrailer_Call[Res]
- type MockTestServiceClient
- func (_m *MockTestServiceClient) BidiStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[testproto.Msg, testproto.Msg], error)
- func (_m *MockTestServiceClient) ClientStream(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[testproto.Msg, testproto.Msg], error)
- func (_m *MockTestServiceClient) EXPECT() *MockTestServiceClient_Expecter
- func (_m *MockTestServiceClient) ServerStream(ctx context.Context, in *testproto.Msg, opts ...grpc.CallOption) (grpc.ServerStreamingClient[testproto.Msg], error)
- func (_m *MockTestServiceClient) ServerStreamThatSleeps(ctx context.Context, in *testproto.Msg, opts ...grpc.CallOption) (grpc.ServerStreamingClient[testproto.Msg], error)
- func (_m *MockTestServiceClient) Unary(ctx context.Context, in *testproto.Msg, opts ...grpc.CallOption) (*testproto.Msg, error)
- type MockTestServiceClient_BidiStream_Call
- func (_c *MockTestServiceClient_BidiStream_Call) Return(_a0 grpc.BidiStreamingClient[testproto.Msg, testproto.Msg], _a1 error) *MockTestServiceClient_BidiStream_Call
- func (_c *MockTestServiceClient_BidiStream_Call) Run(run func(ctx context.Context, opts ...grpc.CallOption)) *MockTestServiceClient_BidiStream_Call
- func (_c *MockTestServiceClient_BidiStream_Call) RunAndReturn(...) *MockTestServiceClient_BidiStream_Call
- type MockTestServiceClient_ClientStream_Call
- func (_c *MockTestServiceClient_ClientStream_Call) Return(_a0 grpc.ClientStreamingClient[testproto.Msg, testproto.Msg], _a1 error) *MockTestServiceClient_ClientStream_Call
- func (_c *MockTestServiceClient_ClientStream_Call) Run(run func(ctx context.Context, opts ...grpc.CallOption)) *MockTestServiceClient_ClientStream_Call
- func (_c *MockTestServiceClient_ClientStream_Call) RunAndReturn(...) *MockTestServiceClient_ClientStream_Call
- type MockTestServiceClient_Expecter
- func (_e *MockTestServiceClient_Expecter) BidiStream(ctx interface{}, opts ...interface{}) *MockTestServiceClient_BidiStream_Call
- func (_e *MockTestServiceClient_Expecter) ClientStream(ctx interface{}, opts ...interface{}) *MockTestServiceClient_ClientStream_Call
- func (_e *MockTestServiceClient_Expecter) ServerStream(ctx interface{}, in interface{}, opts ...interface{}) *MockTestServiceClient_ServerStream_Call
- func (_e *MockTestServiceClient_Expecter) ServerStreamThatSleeps(ctx interface{}, in interface{}, opts ...interface{}) *MockTestServiceClient_ServerStreamThatSleeps_Call
- func (_e *MockTestServiceClient_Expecter) Unary(ctx interface{}, in interface{}, opts ...interface{}) *MockTestServiceClient_Unary_Call
- type MockTestServiceClient_ServerStreamThatSleeps_Call
- func (_c *MockTestServiceClient_ServerStreamThatSleeps_Call) Return(_a0 grpc.ServerStreamingClient[testproto.Msg], _a1 error) *MockTestServiceClient_ServerStreamThatSleeps_Call
- func (_c *MockTestServiceClient_ServerStreamThatSleeps_Call) Run(run func(ctx context.Context, in *testproto.Msg, opts ...grpc.CallOption)) *MockTestServiceClient_ServerStreamThatSleeps_Call
- func (_c *MockTestServiceClient_ServerStreamThatSleeps_Call) RunAndReturn(...) *MockTestServiceClient_ServerStreamThatSleeps_Call
- type MockTestServiceClient_ServerStream_Call
- func (_c *MockTestServiceClient_ServerStream_Call) Return(_a0 grpc.ServerStreamingClient[testproto.Msg], _a1 error) *MockTestServiceClient_ServerStream_Call
- func (_c *MockTestServiceClient_ServerStream_Call) Run(run func(ctx context.Context, in *testproto.Msg, opts ...grpc.CallOption)) *MockTestServiceClient_ServerStream_Call
- func (_c *MockTestServiceClient_ServerStream_Call) RunAndReturn(...) *MockTestServiceClient_ServerStream_Call
- type MockTestServiceClient_Unary_Call
- func (_c *MockTestServiceClient_Unary_Call) Return(_a0 *testproto.Msg, _a1 error) *MockTestServiceClient_Unary_Call
- func (_c *MockTestServiceClient_Unary_Call) Run(run func(ctx context.Context, in *testproto.Msg, opts ...grpc.CallOption)) *MockTestServiceClient_Unary_Call
- func (_c *MockTestServiceClient_Unary_Call) RunAndReturn(...) *MockTestServiceClient_Unary_Call
- type MockTestServiceServer
- func (_m *MockTestServiceServer) BidiStream(_a0 grpc.BidiStreamingServer[testproto.Msg, testproto.Msg]) error
- func (_m *MockTestServiceServer) ClientStream(_a0 grpc.ClientStreamingServer[testproto.Msg, testproto.Msg]) error
- func (_m *MockTestServiceServer) EXPECT() *MockTestServiceServer_Expecter
- func (_m *MockTestServiceServer) ServerStream(_a0 *testproto.Msg, _a1 grpc.ServerStreamingServer[testproto.Msg]) error
- func (_m *MockTestServiceServer) ServerStreamThatSleeps(_a0 *testproto.Msg, _a1 grpc.ServerStreamingServer[testproto.Msg]) error
- func (_m *MockTestServiceServer) Unary(_a0 context.Context, _a1 *testproto.Msg) (*testproto.Msg, error)
- type MockTestServiceServer_BidiStream_Call
- func (_c *MockTestServiceServer_BidiStream_Call) Return(_a0 error) *MockTestServiceServer_BidiStream_Call
- func (_c *MockTestServiceServer_BidiStream_Call) Run(run func(_a0 grpc.BidiStreamingServer[testproto.Msg, testproto.Msg])) *MockTestServiceServer_BidiStream_Call
- func (_c *MockTestServiceServer_BidiStream_Call) RunAndReturn(run func(grpc.BidiStreamingServer[testproto.Msg, testproto.Msg]) error) *MockTestServiceServer_BidiStream_Call
- type MockTestServiceServer_ClientStream_Call
- func (_c *MockTestServiceServer_ClientStream_Call) Return(_a0 error) *MockTestServiceServer_ClientStream_Call
- func (_c *MockTestServiceServer_ClientStream_Call) Run(run func(_a0 grpc.ClientStreamingServer[testproto.Msg, testproto.Msg])) *MockTestServiceServer_ClientStream_Call
- func (_c *MockTestServiceServer_ClientStream_Call) RunAndReturn(run func(grpc.ClientStreamingServer[testproto.Msg, testproto.Msg]) error) *MockTestServiceServer_ClientStream_Call
- type MockTestServiceServer_Expecter
- func (_e *MockTestServiceServer_Expecter) BidiStream(_a0 interface{}) *MockTestServiceServer_BidiStream_Call
- func (_e *MockTestServiceServer_Expecter) ClientStream(_a0 interface{}) *MockTestServiceServer_ClientStream_Call
- func (_e *MockTestServiceServer_Expecter) ServerStream(_a0 interface{}, _a1 interface{}) *MockTestServiceServer_ServerStream_Call
- func (_e *MockTestServiceServer_Expecter) ServerStreamThatSleeps(_a0 interface{}, _a1 interface{}) *MockTestServiceServer_ServerStreamThatSleeps_Call
- func (_e *MockTestServiceServer_Expecter) Unary(_a0 interface{}, _a1 interface{}) *MockTestServiceServer_Unary_Call
- type MockTestServiceServer_ServerStreamThatSleeps_Call
- func (_c *MockTestServiceServer_ServerStreamThatSleeps_Call) Return(_a0 error) *MockTestServiceServer_ServerStreamThatSleeps_Call
- func (_c *MockTestServiceServer_ServerStreamThatSleeps_Call) Run(run func(_a0 *testproto.Msg, _a1 grpc.ServerStreamingServer[testproto.Msg])) *MockTestServiceServer_ServerStreamThatSleeps_Call
- func (_c *MockTestServiceServer_ServerStreamThatSleeps_Call) RunAndReturn(run func(*testproto.Msg, grpc.ServerStreamingServer[testproto.Msg]) error) *MockTestServiceServer_ServerStreamThatSleeps_Call
- type MockTestServiceServer_ServerStream_Call
- func (_c *MockTestServiceServer_ServerStream_Call) Return(_a0 error) *MockTestServiceServer_ServerStream_Call
- func (_c *MockTestServiceServer_ServerStream_Call) Run(run func(_a0 *testproto.Msg, _a1 grpc.ServerStreamingServer[testproto.Msg])) *MockTestServiceServer_ServerStream_Call
- func (_c *MockTestServiceServer_ServerStream_Call) RunAndReturn(run func(*testproto.Msg, grpc.ServerStreamingServer[testproto.Msg]) error) *MockTestServiceServer_ServerStream_Call
- type MockTestServiceServer_Unary_Call
- func (_c *MockTestServiceServer_Unary_Call) Return(_a0 *testproto.Msg, _a1 error) *MockTestServiceServer_Unary_Call
- func (_c *MockTestServiceServer_Unary_Call) Run(run func(_a0 context.Context, _a1 *testproto.Msg)) *MockTestServiceServer_Unary_Call
- func (_c *MockTestServiceServer_Unary_Call) RunAndReturn(run func(context.Context, *testproto.Msg) (*testproto.Msg, error)) *MockTestServiceServer_Unary_Call
- type MockUnsafeTestServiceServer
- type MockUnsafeTestServiceServer_Expecter
- type MockUnsafeTestServiceServer_mustEmbedUnimplementedTestServiceServer_Call
- func (_c *MockUnsafeTestServiceServer_mustEmbedUnimplementedTestServiceServer_Call) Return() *MockUnsafeTestServiceServer_mustEmbedUnimplementedTestServiceServer_Call
- func (_c *MockUnsafeTestServiceServer_mustEmbedUnimplementedTestServiceServer_Call) Run(run func()) *MockUnsafeTestServiceServer_mustEmbedUnimplementedTestServiceServer_Call
- func (_c *MockUnsafeTestServiceServer_mustEmbedUnimplementedTestServiceServer_Call) RunAndReturn(run func()) *MockUnsafeTestServiceServer_mustEmbedUnimplementedTestServiceServer_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockServerStreamingClient ¶ added in v0.1.8
MockServerStreamingClient is an autogenerated mock type for the ServerStreamingClient type
func NewMockServerStreamingClient ¶ added in v0.1.8
func NewMockServerStreamingClient[Res interface{}](t interface { mock.TestingT Cleanup(func()) }) *MockServerStreamingClient[Res]
NewMockServerStreamingClient creates a new instance of MockServerStreamingClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockServerStreamingClient[Res]) CloseSend ¶ added in v0.1.8
func (_m *MockServerStreamingClient[Res]) CloseSend() error
CloseSend provides a mock function with given fields:
func (*MockServerStreamingClient[Res]) Context ¶ added in v0.1.8
func (_m *MockServerStreamingClient[Res]) Context() context.Context
Context provides a mock function with given fields:
func (*MockServerStreamingClient[Res]) EXPECT ¶ added in v0.1.8
func (_m *MockServerStreamingClient[Res]) EXPECT() *MockServerStreamingClient_Expecter[Res]
func (*MockServerStreamingClient[Res]) Header ¶ added in v0.1.8
func (_m *MockServerStreamingClient[Res]) Header() (metadata.MD, error)
Header provides a mock function with given fields:
func (*MockServerStreamingClient[Res]) Recv ¶ added in v0.1.8
func (_m *MockServerStreamingClient[Res]) Recv() (*testproto.Msg, error)
Recv provides a mock function with given fields:
func (*MockServerStreamingClient[Res]) RecvMsg ¶ added in v0.1.8
func (_m *MockServerStreamingClient[Res]) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*MockServerStreamingClient[Res]) SendMsg ¶ added in v0.1.8
func (_m *MockServerStreamingClient[Res]) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*MockServerStreamingClient[Res]) Trailer ¶ added in v0.1.8
func (_m *MockServerStreamingClient[Res]) Trailer() metadata.MD
Trailer provides a mock function with given fields:
type MockServerStreamingClient_CloseSend_Call ¶ added in v0.1.8
MockServerStreamingClient_CloseSend_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CloseSend'
func (*MockServerStreamingClient_CloseSend_Call[Res]) Return ¶ added in v0.1.8
func (_c *MockServerStreamingClient_CloseSend_Call[Res]) Return(_a0 error) *MockServerStreamingClient_CloseSend_Call[Res]
func (*MockServerStreamingClient_CloseSend_Call[Res]) Run ¶ added in v0.1.8
func (_c *MockServerStreamingClient_CloseSend_Call[Res]) Run(run func()) *MockServerStreamingClient_CloseSend_Call[Res]
func (*MockServerStreamingClient_CloseSend_Call[Res]) RunAndReturn ¶ added in v0.1.8
func (_c *MockServerStreamingClient_CloseSend_Call[Res]) RunAndReturn(run func() error) *MockServerStreamingClient_CloseSend_Call[Res]
type MockServerStreamingClient_Context_Call ¶ added in v0.1.8
MockServerStreamingClient_Context_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Context'
func (*MockServerStreamingClient_Context_Call[Res]) Return ¶ added in v0.1.8
func (_c *MockServerStreamingClient_Context_Call[Res]) Return(_a0 context.Context) *MockServerStreamingClient_Context_Call[Res]
func (*MockServerStreamingClient_Context_Call[Res]) Run ¶ added in v0.1.8
func (_c *MockServerStreamingClient_Context_Call[Res]) Run(run func()) *MockServerStreamingClient_Context_Call[Res]
func (*MockServerStreamingClient_Context_Call[Res]) RunAndReturn ¶ added in v0.1.8
func (_c *MockServerStreamingClient_Context_Call[Res]) RunAndReturn(run func() context.Context) *MockServerStreamingClient_Context_Call[Res]
type MockServerStreamingClient_Expecter ¶ added in v0.1.8
type MockServerStreamingClient_Expecter[Res interface{}] struct {
// contains filtered or unexported fields
}
func (*MockServerStreamingClient_Expecter[Res]) CloseSend ¶ added in v0.1.8
func (_e *MockServerStreamingClient_Expecter[Res]) CloseSend() *MockServerStreamingClient_CloseSend_Call[Res]
CloseSend is a helper method to define mock.On call
func (*MockServerStreamingClient_Expecter[Res]) Context ¶ added in v0.1.8
func (_e *MockServerStreamingClient_Expecter[Res]) Context() *MockServerStreamingClient_Context_Call[Res]
Context is a helper method to define mock.On call
func (*MockServerStreamingClient_Expecter[Res]) Header ¶ added in v0.1.8
func (_e *MockServerStreamingClient_Expecter[Res]) Header() *MockServerStreamingClient_Header_Call[Res]
Header is a helper method to define mock.On call
func (*MockServerStreamingClient_Expecter[Res]) Recv ¶ added in v0.1.8
func (_e *MockServerStreamingClient_Expecter[Res]) Recv() *MockServerStreamingClient_Recv_Call[Res]
Recv is a helper method to define mock.On call
func (*MockServerStreamingClient_Expecter[Res]) RecvMsg ¶ added in v0.1.8
func (_e *MockServerStreamingClient_Expecter[Res]) RecvMsg(m interface{}) *MockServerStreamingClient_RecvMsg_Call[Res]
RecvMsg is a helper method to define mock.On call
- m interface{}
func (*MockServerStreamingClient_Expecter[Res]) SendMsg ¶ added in v0.1.8
func (_e *MockServerStreamingClient_Expecter[Res]) SendMsg(m interface{}) *MockServerStreamingClient_SendMsg_Call[Res]
SendMsg is a helper method to define mock.On call
- m interface{}
func (*MockServerStreamingClient_Expecter[Res]) Trailer ¶ added in v0.1.8
func (_e *MockServerStreamingClient_Expecter[Res]) Trailer() *MockServerStreamingClient_Trailer_Call[Res]
Trailer is a helper method to define mock.On call
type MockServerStreamingClient_Header_Call ¶ added in v0.1.8
MockServerStreamingClient_Header_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Header'
func (*MockServerStreamingClient_Header_Call[Res]) Return ¶ added in v0.1.8
func (_c *MockServerStreamingClient_Header_Call[Res]) Return(_a0 metadata.MD, _a1 error) *MockServerStreamingClient_Header_Call[Res]
func (*MockServerStreamingClient_Header_Call[Res]) Run ¶ added in v0.1.8
func (_c *MockServerStreamingClient_Header_Call[Res]) Run(run func()) *MockServerStreamingClient_Header_Call[Res]
func (*MockServerStreamingClient_Header_Call[Res]) RunAndReturn ¶ added in v0.1.8
func (_c *MockServerStreamingClient_Header_Call[Res]) RunAndReturn(run func() (metadata.MD, error)) *MockServerStreamingClient_Header_Call[Res]
type MockServerStreamingClient_RecvMsg_Call ¶ added in v0.1.8
MockServerStreamingClient_RecvMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecvMsg'
func (*MockServerStreamingClient_RecvMsg_Call[Res]) Return ¶ added in v0.1.8
func (_c *MockServerStreamingClient_RecvMsg_Call[Res]) Return(_a0 error) *MockServerStreamingClient_RecvMsg_Call[Res]
func (*MockServerStreamingClient_RecvMsg_Call[Res]) Run ¶ added in v0.1.8
func (_c *MockServerStreamingClient_RecvMsg_Call[Res]) Run(run func(m interface{})) *MockServerStreamingClient_RecvMsg_Call[Res]
func (*MockServerStreamingClient_RecvMsg_Call[Res]) RunAndReturn ¶ added in v0.1.8
func (_c *MockServerStreamingClient_RecvMsg_Call[Res]) RunAndReturn(run func(interface{}) error) *MockServerStreamingClient_RecvMsg_Call[Res]
type MockServerStreamingClient_Recv_Call ¶ added in v0.1.8
MockServerStreamingClient_Recv_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Recv'
func (*MockServerStreamingClient_Recv_Call[Res]) Return ¶ added in v0.1.8
func (_c *MockServerStreamingClient_Recv_Call[Res]) Return(_a0 *testproto.Msg, _a1 error) *MockServerStreamingClient_Recv_Call[Res]
func (*MockServerStreamingClient_Recv_Call[Res]) Run ¶ added in v0.1.8
func (_c *MockServerStreamingClient_Recv_Call[Res]) Run(run func()) *MockServerStreamingClient_Recv_Call[Res]
func (*MockServerStreamingClient_Recv_Call[Res]) RunAndReturn ¶ added in v0.1.8
func (_c *MockServerStreamingClient_Recv_Call[Res]) RunAndReturn(run func() (*testproto.Msg, error)) *MockServerStreamingClient_Recv_Call[Res]
type MockServerStreamingClient_SendMsg_Call ¶ added in v0.1.8
MockServerStreamingClient_SendMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendMsg'
func (*MockServerStreamingClient_SendMsg_Call[Res]) Return ¶ added in v0.1.8
func (_c *MockServerStreamingClient_SendMsg_Call[Res]) Return(_a0 error) *MockServerStreamingClient_SendMsg_Call[Res]
func (*MockServerStreamingClient_SendMsg_Call[Res]) Run ¶ added in v0.1.8
func (_c *MockServerStreamingClient_SendMsg_Call[Res]) Run(run func(m interface{})) *MockServerStreamingClient_SendMsg_Call[Res]
func (*MockServerStreamingClient_SendMsg_Call[Res]) RunAndReturn ¶ added in v0.1.8
func (_c *MockServerStreamingClient_SendMsg_Call[Res]) RunAndReturn(run func(interface{}) error) *MockServerStreamingClient_SendMsg_Call[Res]
type MockServerStreamingClient_Trailer_Call ¶ added in v0.1.8
MockServerStreamingClient_Trailer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Trailer'
func (*MockServerStreamingClient_Trailer_Call[Res]) Return ¶ added in v0.1.8
func (_c *MockServerStreamingClient_Trailer_Call[Res]) Return(_a0 metadata.MD) *MockServerStreamingClient_Trailer_Call[Res]
func (*MockServerStreamingClient_Trailer_Call[Res]) Run ¶ added in v0.1.8
func (_c *MockServerStreamingClient_Trailer_Call[Res]) Run(run func()) *MockServerStreamingClient_Trailer_Call[Res]
func (*MockServerStreamingClient_Trailer_Call[Res]) RunAndReturn ¶ added in v0.1.8
func (_c *MockServerStreamingClient_Trailer_Call[Res]) RunAndReturn(run func() metadata.MD) *MockServerStreamingClient_Trailer_Call[Res]
type MockServerStreamingServer ¶ added in v0.1.8
MockServerStreamingServer is an autogenerated mock type for the ServerStreamingServer type
func NewMockServerStreamingServer ¶ added in v0.1.8
func NewMockServerStreamingServer[Res interface{}](t interface { mock.TestingT Cleanup(func()) }) *MockServerStreamingServer[Res]
NewMockServerStreamingServer creates a new instance of MockServerStreamingServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockServerStreamingServer[Res]) Context ¶ added in v0.1.8
func (_m *MockServerStreamingServer[Res]) Context() context.Context
Context provides a mock function with given fields:
func (*MockServerStreamingServer[Res]) EXPECT ¶ added in v0.1.8
func (_m *MockServerStreamingServer[Res]) EXPECT() *MockServerStreamingServer_Expecter[Res]
func (*MockServerStreamingServer[Res]) RecvMsg ¶ added in v0.1.8
func (_m *MockServerStreamingServer[Res]) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*MockServerStreamingServer[Res]) Send ¶ added in v0.1.8
func (_m *MockServerStreamingServer[Res]) Send(_a0 *testproto.Msg) error
Send provides a mock function with given fields: _a0
func (*MockServerStreamingServer[Res]) SendHeader ¶ added in v0.1.8
func (_m *MockServerStreamingServer[Res]) SendHeader(_a0 metadata.MD) error
SendHeader provides a mock function with given fields: _a0
func (*MockServerStreamingServer[Res]) SendMsg ¶ added in v0.1.8
func (_m *MockServerStreamingServer[Res]) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*MockServerStreamingServer[Res]) SetHeader ¶ added in v0.1.8
func (_m *MockServerStreamingServer[Res]) SetHeader(_a0 metadata.MD) error
SetHeader provides a mock function with given fields: _a0
func (*MockServerStreamingServer[Res]) SetTrailer ¶ added in v0.1.8
func (_m *MockServerStreamingServer[Res]) SetTrailer(_a0 metadata.MD)
SetTrailer provides a mock function with given fields: _a0
type MockServerStreamingServer_Context_Call ¶ added in v0.1.8
MockServerStreamingServer_Context_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Context'
func (*MockServerStreamingServer_Context_Call[Res]) Return ¶ added in v0.1.8
func (_c *MockServerStreamingServer_Context_Call[Res]) Return(_a0 context.Context) *MockServerStreamingServer_Context_Call[Res]
func (*MockServerStreamingServer_Context_Call[Res]) Run ¶ added in v0.1.8
func (_c *MockServerStreamingServer_Context_Call[Res]) Run(run func()) *MockServerStreamingServer_Context_Call[Res]
func (*MockServerStreamingServer_Context_Call[Res]) RunAndReturn ¶ added in v0.1.8
func (_c *MockServerStreamingServer_Context_Call[Res]) RunAndReturn(run func() context.Context) *MockServerStreamingServer_Context_Call[Res]
type MockServerStreamingServer_Expecter ¶ added in v0.1.8
type MockServerStreamingServer_Expecter[Res interface{}] struct {
// contains filtered or unexported fields
}
func (*MockServerStreamingServer_Expecter[Res]) Context ¶ added in v0.1.8
func (_e *MockServerStreamingServer_Expecter[Res]) Context() *MockServerStreamingServer_Context_Call[Res]
Context is a helper method to define mock.On call
func (*MockServerStreamingServer_Expecter[Res]) RecvMsg ¶ added in v0.1.8
func (_e *MockServerStreamingServer_Expecter[Res]) RecvMsg(m interface{}) *MockServerStreamingServer_RecvMsg_Call[Res]
RecvMsg is a helper method to define mock.On call
- m interface{}
func (*MockServerStreamingServer_Expecter[Res]) Send ¶ added in v0.1.8
func (_e *MockServerStreamingServer_Expecter[Res]) Send(_a0 interface{}) *MockServerStreamingServer_Send_Call[Res]
Send is a helper method to define mock.On call
- _a0 *testproto.Msg
func (*MockServerStreamingServer_Expecter[Res]) SendHeader ¶ added in v0.1.8
func (_e *MockServerStreamingServer_Expecter[Res]) SendHeader(_a0 interface{}) *MockServerStreamingServer_SendHeader_Call[Res]
SendHeader is a helper method to define mock.On call
- _a0 metadata.MD
func (*MockServerStreamingServer_Expecter[Res]) SendMsg ¶ added in v0.1.8
func (_e *MockServerStreamingServer_Expecter[Res]) SendMsg(m interface{}) *MockServerStreamingServer_SendMsg_Call[Res]
SendMsg is a helper method to define mock.On call
- m interface{}
func (*MockServerStreamingServer_Expecter[Res]) SetHeader ¶ added in v0.1.8
func (_e *MockServerStreamingServer_Expecter[Res]) SetHeader(_a0 interface{}) *MockServerStreamingServer_SetHeader_Call[Res]
SetHeader is a helper method to define mock.On call
- _a0 metadata.MD
func (*MockServerStreamingServer_Expecter[Res]) SetTrailer ¶ added in v0.1.8
func (_e *MockServerStreamingServer_Expecter[Res]) SetTrailer(_a0 interface{}) *MockServerStreamingServer_SetTrailer_Call[Res]
SetTrailer is a helper method to define mock.On call
- _a0 metadata.MD
type MockServerStreamingServer_RecvMsg_Call ¶ added in v0.1.8
MockServerStreamingServer_RecvMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecvMsg'
func (*MockServerStreamingServer_RecvMsg_Call[Res]) Return ¶ added in v0.1.8
func (_c *MockServerStreamingServer_RecvMsg_Call[Res]) Return(_a0 error) *MockServerStreamingServer_RecvMsg_Call[Res]
func (*MockServerStreamingServer_RecvMsg_Call[Res]) Run ¶ added in v0.1.8
func (_c *MockServerStreamingServer_RecvMsg_Call[Res]) Run(run func(m interface{})) *MockServerStreamingServer_RecvMsg_Call[Res]
func (*MockServerStreamingServer_RecvMsg_Call[Res]) RunAndReturn ¶ added in v0.1.8
func (_c *MockServerStreamingServer_RecvMsg_Call[Res]) RunAndReturn(run func(interface{}) error) *MockServerStreamingServer_RecvMsg_Call[Res]
type MockServerStreamingServer_SendHeader_Call ¶ added in v0.1.8
MockServerStreamingServer_SendHeader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendHeader'
func (*MockServerStreamingServer_SendHeader_Call[Res]) Return ¶ added in v0.1.8
func (_c *MockServerStreamingServer_SendHeader_Call[Res]) Return(_a0 error) *MockServerStreamingServer_SendHeader_Call[Res]
func (*MockServerStreamingServer_SendHeader_Call[Res]) Run ¶ added in v0.1.8
func (_c *MockServerStreamingServer_SendHeader_Call[Res]) Run(run func(_a0 metadata.MD)) *MockServerStreamingServer_SendHeader_Call[Res]
func (*MockServerStreamingServer_SendHeader_Call[Res]) RunAndReturn ¶ added in v0.1.8
func (_c *MockServerStreamingServer_SendHeader_Call[Res]) RunAndReturn(run func(metadata.MD) error) *MockServerStreamingServer_SendHeader_Call[Res]
type MockServerStreamingServer_SendMsg_Call ¶ added in v0.1.8
MockServerStreamingServer_SendMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendMsg'
func (*MockServerStreamingServer_SendMsg_Call[Res]) Return ¶ added in v0.1.8
func (_c *MockServerStreamingServer_SendMsg_Call[Res]) Return(_a0 error) *MockServerStreamingServer_SendMsg_Call[Res]
func (*MockServerStreamingServer_SendMsg_Call[Res]) Run ¶ added in v0.1.8
func (_c *MockServerStreamingServer_SendMsg_Call[Res]) Run(run func(m interface{})) *MockServerStreamingServer_SendMsg_Call[Res]
func (*MockServerStreamingServer_SendMsg_Call[Res]) RunAndReturn ¶ added in v0.1.8
func (_c *MockServerStreamingServer_SendMsg_Call[Res]) RunAndReturn(run func(interface{}) error) *MockServerStreamingServer_SendMsg_Call[Res]
type MockServerStreamingServer_Send_Call ¶ added in v0.1.8
MockServerStreamingServer_Send_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Send'
func (*MockServerStreamingServer_Send_Call[Res]) Return ¶ added in v0.1.8
func (_c *MockServerStreamingServer_Send_Call[Res]) Return(_a0 error) *MockServerStreamingServer_Send_Call[Res]
func (*MockServerStreamingServer_Send_Call[Res]) Run ¶ added in v0.1.8
func (_c *MockServerStreamingServer_Send_Call[Res]) Run(run func(_a0 *testproto.Msg)) *MockServerStreamingServer_Send_Call[Res]
func (*MockServerStreamingServer_Send_Call[Res]) RunAndReturn ¶ added in v0.1.8
func (_c *MockServerStreamingServer_Send_Call[Res]) RunAndReturn(run func(*testproto.Msg) error) *MockServerStreamingServer_Send_Call[Res]
type MockServerStreamingServer_SetHeader_Call ¶ added in v0.1.8
MockServerStreamingServer_SetHeader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetHeader'
func (*MockServerStreamingServer_SetHeader_Call[Res]) Return ¶ added in v0.1.8
func (_c *MockServerStreamingServer_SetHeader_Call[Res]) Return(_a0 error) *MockServerStreamingServer_SetHeader_Call[Res]
func (*MockServerStreamingServer_SetHeader_Call[Res]) Run ¶ added in v0.1.8
func (_c *MockServerStreamingServer_SetHeader_Call[Res]) Run(run func(_a0 metadata.MD)) *MockServerStreamingServer_SetHeader_Call[Res]
func (*MockServerStreamingServer_SetHeader_Call[Res]) RunAndReturn ¶ added in v0.1.8
func (_c *MockServerStreamingServer_SetHeader_Call[Res]) RunAndReturn(run func(metadata.MD) error) *MockServerStreamingServer_SetHeader_Call[Res]
type MockServerStreamingServer_SetTrailer_Call ¶ added in v0.1.8
MockServerStreamingServer_SetTrailer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetTrailer'
func (*MockServerStreamingServer_SetTrailer_Call[Res]) Return ¶ added in v0.1.8
func (_c *MockServerStreamingServer_SetTrailer_Call[Res]) Return() *MockServerStreamingServer_SetTrailer_Call[Res]
func (*MockServerStreamingServer_SetTrailer_Call[Res]) Run ¶ added in v0.1.8
func (_c *MockServerStreamingServer_SetTrailer_Call[Res]) Run(run func(_a0 metadata.MD)) *MockServerStreamingServer_SetTrailer_Call[Res]
func (*MockServerStreamingServer_SetTrailer_Call[Res]) RunAndReturn ¶ added in v0.1.8
func (_c *MockServerStreamingServer_SetTrailer_Call[Res]) RunAndReturn(run func(metadata.MD)) *MockServerStreamingServer_SetTrailer_Call[Res]
type MockTestServiceClient ¶
MockTestServiceClient is an autogenerated mock type for the TestServiceClient type
func NewMockTestServiceClient ¶
func NewMockTestServiceClient(t interface { mock.TestingT Cleanup(func()) }) *MockTestServiceClient
NewMockTestServiceClient creates a new instance of MockTestServiceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockTestServiceClient) BidiStream ¶
func (_m *MockTestServiceClient) BidiStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[testproto.Msg, testproto.Msg], error)
BidiStream provides a mock function with given fields: ctx, opts
func (*MockTestServiceClient) ClientStream ¶
func (_m *MockTestServiceClient) ClientStream(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[testproto.Msg, testproto.Msg], error)
ClientStream provides a mock function with given fields: ctx, opts
func (*MockTestServiceClient) EXPECT ¶
func (_m *MockTestServiceClient) EXPECT() *MockTestServiceClient_Expecter
func (*MockTestServiceClient) ServerStream ¶
func (_m *MockTestServiceClient) ServerStream(ctx context.Context, in *testproto.Msg, opts ...grpc.CallOption) (grpc.ServerStreamingClient[testproto.Msg], error)
ServerStream provides a mock function with given fields: ctx, in, opts
func (*MockTestServiceClient) ServerStreamThatSleeps ¶ added in v0.1.3
func (_m *MockTestServiceClient) ServerStreamThatSleeps(ctx context.Context, in *testproto.Msg, opts ...grpc.CallOption) (grpc.ServerStreamingClient[testproto.Msg], error)
ServerStreamThatSleeps provides a mock function with given fields: ctx, in, opts
type MockTestServiceClient_BidiStream_Call ¶
MockTestServiceClient_BidiStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BidiStream'
func (*MockTestServiceClient_BidiStream_Call) Return ¶
func (_c *MockTestServiceClient_BidiStream_Call) Return(_a0 grpc.BidiStreamingClient[testproto.Msg, testproto.Msg], _a1 error) *MockTestServiceClient_BidiStream_Call
func (*MockTestServiceClient_BidiStream_Call) Run ¶
func (_c *MockTestServiceClient_BidiStream_Call) Run(run func(ctx context.Context, opts ...grpc.CallOption)) *MockTestServiceClient_BidiStream_Call
func (*MockTestServiceClient_BidiStream_Call) RunAndReturn ¶
func (_c *MockTestServiceClient_BidiStream_Call) RunAndReturn(run func(context.Context, ...grpc.CallOption) (grpc.BidiStreamingClient[testproto.Msg, testproto.Msg], error)) *MockTestServiceClient_BidiStream_Call
type MockTestServiceClient_ClientStream_Call ¶
MockTestServiceClient_ClientStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ClientStream'
func (*MockTestServiceClient_ClientStream_Call) Return ¶
func (_c *MockTestServiceClient_ClientStream_Call) Return(_a0 grpc.ClientStreamingClient[testproto.Msg, testproto.Msg], _a1 error) *MockTestServiceClient_ClientStream_Call
func (*MockTestServiceClient_ClientStream_Call) Run ¶
func (_c *MockTestServiceClient_ClientStream_Call) Run(run func(ctx context.Context, opts ...grpc.CallOption)) *MockTestServiceClient_ClientStream_Call
func (*MockTestServiceClient_ClientStream_Call) RunAndReturn ¶
func (_c *MockTestServiceClient_ClientStream_Call) RunAndReturn(run func(context.Context, ...grpc.CallOption) (grpc.ClientStreamingClient[testproto.Msg, testproto.Msg], error)) *MockTestServiceClient_ClientStream_Call
type MockTestServiceClient_Expecter ¶
type MockTestServiceClient_Expecter struct {
// contains filtered or unexported fields
}
func (*MockTestServiceClient_Expecter) BidiStream ¶
func (_e *MockTestServiceClient_Expecter) BidiStream(ctx interface{}, opts ...interface{}) *MockTestServiceClient_BidiStream_Call
BidiStream is a helper method to define mock.On call
- ctx context.Context
- opts ...grpc.CallOption
func (*MockTestServiceClient_Expecter) ClientStream ¶
func (_e *MockTestServiceClient_Expecter) ClientStream(ctx interface{}, opts ...interface{}) *MockTestServiceClient_ClientStream_Call
ClientStream is a helper method to define mock.On call
- ctx context.Context
- opts ...grpc.CallOption
func (*MockTestServiceClient_Expecter) ServerStream ¶
func (_e *MockTestServiceClient_Expecter) ServerStream(ctx interface{}, in interface{}, opts ...interface{}) *MockTestServiceClient_ServerStream_Call
ServerStream is a helper method to define mock.On call
- ctx context.Context
- in *testproto.Msg
- opts ...grpc.CallOption
func (*MockTestServiceClient_Expecter) ServerStreamThatSleeps ¶ added in v0.1.3
func (_e *MockTestServiceClient_Expecter) ServerStreamThatSleeps(ctx interface{}, in interface{}, opts ...interface{}) *MockTestServiceClient_ServerStreamThatSleeps_Call
ServerStreamThatSleeps is a helper method to define mock.On call
- ctx context.Context
- in *testproto.Msg
- opts ...grpc.CallOption
func (*MockTestServiceClient_Expecter) Unary ¶
func (_e *MockTestServiceClient_Expecter) Unary(ctx interface{}, in interface{}, opts ...interface{}) *MockTestServiceClient_Unary_Call
Unary is a helper method to define mock.On call
- ctx context.Context
- in *testproto.Msg
- opts ...grpc.CallOption
type MockTestServiceClient_ServerStreamThatSleeps_Call ¶ added in v0.1.3
MockTestServiceClient_ServerStreamThatSleeps_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ServerStreamThatSleeps'
func (*MockTestServiceClient_ServerStreamThatSleeps_Call) Return ¶ added in v0.1.3
func (_c *MockTestServiceClient_ServerStreamThatSleeps_Call) Return(_a0 grpc.ServerStreamingClient[testproto.Msg], _a1 error) *MockTestServiceClient_ServerStreamThatSleeps_Call
func (*MockTestServiceClient_ServerStreamThatSleeps_Call) Run ¶ added in v0.1.3
func (_c *MockTestServiceClient_ServerStreamThatSleeps_Call) Run(run func(ctx context.Context, in *testproto.Msg, opts ...grpc.CallOption)) *MockTestServiceClient_ServerStreamThatSleeps_Call
func (*MockTestServiceClient_ServerStreamThatSleeps_Call) RunAndReturn ¶ added in v0.1.3
func (_c *MockTestServiceClient_ServerStreamThatSleeps_Call) RunAndReturn(run func(context.Context, *testproto.Msg, ...grpc.CallOption) (grpc.ServerStreamingClient[testproto.Msg], error)) *MockTestServiceClient_ServerStreamThatSleeps_Call
type MockTestServiceClient_ServerStream_Call ¶
MockTestServiceClient_ServerStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ServerStream'
func (*MockTestServiceClient_ServerStream_Call) Return ¶
func (_c *MockTestServiceClient_ServerStream_Call) Return(_a0 grpc.ServerStreamingClient[testproto.Msg], _a1 error) *MockTestServiceClient_ServerStream_Call
func (*MockTestServiceClient_ServerStream_Call) Run ¶
func (_c *MockTestServiceClient_ServerStream_Call) Run(run func(ctx context.Context, in *testproto.Msg, opts ...grpc.CallOption)) *MockTestServiceClient_ServerStream_Call
func (*MockTestServiceClient_ServerStream_Call) RunAndReturn ¶
func (_c *MockTestServiceClient_ServerStream_Call) RunAndReturn(run func(context.Context, *testproto.Msg, ...grpc.CallOption) (grpc.ServerStreamingClient[testproto.Msg], error)) *MockTestServiceClient_ServerStream_Call
type MockTestServiceClient_Unary_Call ¶
MockTestServiceClient_Unary_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Unary'
func (*MockTestServiceClient_Unary_Call) Return ¶
func (_c *MockTestServiceClient_Unary_Call) Return(_a0 *testproto.Msg, _a1 error) *MockTestServiceClient_Unary_Call
func (*MockTestServiceClient_Unary_Call) Run ¶
func (_c *MockTestServiceClient_Unary_Call) Run(run func(ctx context.Context, in *testproto.Msg, opts ...grpc.CallOption)) *MockTestServiceClient_Unary_Call
func (*MockTestServiceClient_Unary_Call) RunAndReturn ¶
func (_c *MockTestServiceClient_Unary_Call) RunAndReturn(run func(context.Context, *testproto.Msg, ...grpc.CallOption) (*testproto.Msg, error)) *MockTestServiceClient_Unary_Call
type MockTestServiceServer ¶
MockTestServiceServer is an autogenerated mock type for the TestServiceServer type
func NewMockTestServiceServer ¶
func NewMockTestServiceServer(t interface { mock.TestingT Cleanup(func()) }) *MockTestServiceServer
NewMockTestServiceServer creates a new instance of MockTestServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockTestServiceServer) BidiStream ¶
func (_m *MockTestServiceServer) BidiStream(_a0 grpc.BidiStreamingServer[testproto.Msg, testproto.Msg]) error
BidiStream provides a mock function with given fields: _a0
func (*MockTestServiceServer) ClientStream ¶
func (_m *MockTestServiceServer) ClientStream(_a0 grpc.ClientStreamingServer[testproto.Msg, testproto.Msg]) error
ClientStream provides a mock function with given fields: _a0
func (*MockTestServiceServer) EXPECT ¶
func (_m *MockTestServiceServer) EXPECT() *MockTestServiceServer_Expecter
func (*MockTestServiceServer) ServerStream ¶
func (_m *MockTestServiceServer) ServerStream(_a0 *testproto.Msg, _a1 grpc.ServerStreamingServer[testproto.Msg]) error
ServerStream provides a mock function with given fields: _a0, _a1
func (*MockTestServiceServer) ServerStreamThatSleeps ¶ added in v0.1.3
func (_m *MockTestServiceServer) ServerStreamThatSleeps(_a0 *testproto.Msg, _a1 grpc.ServerStreamingServer[testproto.Msg]) error
ServerStreamThatSleeps provides a mock function with given fields: _a0, _a1
type MockTestServiceServer_BidiStream_Call ¶
MockTestServiceServer_BidiStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BidiStream'
func (*MockTestServiceServer_BidiStream_Call) Return ¶
func (_c *MockTestServiceServer_BidiStream_Call) Return(_a0 error) *MockTestServiceServer_BidiStream_Call
func (*MockTestServiceServer_BidiStream_Call) Run ¶
func (_c *MockTestServiceServer_BidiStream_Call) Run(run func(_a0 grpc.BidiStreamingServer[testproto.Msg, testproto.Msg])) *MockTestServiceServer_BidiStream_Call
func (*MockTestServiceServer_BidiStream_Call) RunAndReturn ¶
func (_c *MockTestServiceServer_BidiStream_Call) RunAndReturn(run func(grpc.BidiStreamingServer[testproto.Msg, testproto.Msg]) error) *MockTestServiceServer_BidiStream_Call
type MockTestServiceServer_ClientStream_Call ¶
MockTestServiceServer_ClientStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ClientStream'
func (*MockTestServiceServer_ClientStream_Call) Return ¶
func (_c *MockTestServiceServer_ClientStream_Call) Return(_a0 error) *MockTestServiceServer_ClientStream_Call
func (*MockTestServiceServer_ClientStream_Call) Run ¶
func (_c *MockTestServiceServer_ClientStream_Call) Run(run func(_a0 grpc.ClientStreamingServer[testproto.Msg, testproto.Msg])) *MockTestServiceServer_ClientStream_Call
func (*MockTestServiceServer_ClientStream_Call) RunAndReturn ¶
func (_c *MockTestServiceServer_ClientStream_Call) RunAndReturn(run func(grpc.ClientStreamingServer[testproto.Msg, testproto.Msg]) error) *MockTestServiceServer_ClientStream_Call
type MockTestServiceServer_Expecter ¶
type MockTestServiceServer_Expecter struct {
// contains filtered or unexported fields
}
func (*MockTestServiceServer_Expecter) BidiStream ¶
func (_e *MockTestServiceServer_Expecter) BidiStream(_a0 interface{}) *MockTestServiceServer_BidiStream_Call
BidiStream is a helper method to define mock.On call
- _a0 grpc.BidiStreamingServer[testproto.Msg,testproto.Msg]
func (*MockTestServiceServer_Expecter) ClientStream ¶
func (_e *MockTestServiceServer_Expecter) ClientStream(_a0 interface{}) *MockTestServiceServer_ClientStream_Call
ClientStream is a helper method to define mock.On call
- _a0 grpc.ClientStreamingServer[testproto.Msg,testproto.Msg]
func (*MockTestServiceServer_Expecter) ServerStream ¶
func (_e *MockTestServiceServer_Expecter) ServerStream(_a0 interface{}, _a1 interface{}) *MockTestServiceServer_ServerStream_Call
ServerStream is a helper method to define mock.On call
- _a0 *testproto.Msg
- _a1 grpc.ServerStreamingServer[testproto.Msg]
func (*MockTestServiceServer_Expecter) ServerStreamThatSleeps ¶ added in v0.1.3
func (_e *MockTestServiceServer_Expecter) ServerStreamThatSleeps(_a0 interface{}, _a1 interface{}) *MockTestServiceServer_ServerStreamThatSleeps_Call
ServerStreamThatSleeps is a helper method to define mock.On call
- _a0 *testproto.Msg
- _a1 grpc.ServerStreamingServer[testproto.Msg]
func (*MockTestServiceServer_Expecter) Unary ¶
func (_e *MockTestServiceServer_Expecter) Unary(_a0 interface{}, _a1 interface{}) *MockTestServiceServer_Unary_Call
Unary is a helper method to define mock.On call
- _a0 context.Context
- _a1 *testproto.Msg
type MockTestServiceServer_ServerStreamThatSleeps_Call ¶ added in v0.1.3
MockTestServiceServer_ServerStreamThatSleeps_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ServerStreamThatSleeps'
func (*MockTestServiceServer_ServerStreamThatSleeps_Call) Return ¶ added in v0.1.3
func (_c *MockTestServiceServer_ServerStreamThatSleeps_Call) Return(_a0 error) *MockTestServiceServer_ServerStreamThatSleeps_Call
func (*MockTestServiceServer_ServerStreamThatSleeps_Call) Run ¶ added in v0.1.3
func (_c *MockTestServiceServer_ServerStreamThatSleeps_Call) Run(run func(_a0 *testproto.Msg, _a1 grpc.ServerStreamingServer[testproto.Msg])) *MockTestServiceServer_ServerStreamThatSleeps_Call
func (*MockTestServiceServer_ServerStreamThatSleeps_Call) RunAndReturn ¶ added in v0.1.3
func (_c *MockTestServiceServer_ServerStreamThatSleeps_Call) RunAndReturn(run func(*testproto.Msg, grpc.ServerStreamingServer[testproto.Msg]) error) *MockTestServiceServer_ServerStreamThatSleeps_Call
type MockTestServiceServer_ServerStream_Call ¶
MockTestServiceServer_ServerStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ServerStream'
func (*MockTestServiceServer_ServerStream_Call) Return ¶
func (_c *MockTestServiceServer_ServerStream_Call) Return(_a0 error) *MockTestServiceServer_ServerStream_Call
func (*MockTestServiceServer_ServerStream_Call) Run ¶
func (_c *MockTestServiceServer_ServerStream_Call) Run(run func(_a0 *testproto.Msg, _a1 grpc.ServerStreamingServer[testproto.Msg])) *MockTestServiceServer_ServerStream_Call
func (*MockTestServiceServer_ServerStream_Call) RunAndReturn ¶
func (_c *MockTestServiceServer_ServerStream_Call) RunAndReturn(run func(*testproto.Msg, grpc.ServerStreamingServer[testproto.Msg]) error) *MockTestServiceServer_ServerStream_Call
type MockTestServiceServer_Unary_Call ¶
MockTestServiceServer_Unary_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Unary'
func (*MockTestServiceServer_Unary_Call) Return ¶
func (_c *MockTestServiceServer_Unary_Call) Return(_a0 *testproto.Msg, _a1 error) *MockTestServiceServer_Unary_Call
func (*MockTestServiceServer_Unary_Call) Run ¶
func (_c *MockTestServiceServer_Unary_Call) Run(run func(_a0 context.Context, _a1 *testproto.Msg)) *MockTestServiceServer_Unary_Call
func (*MockTestServiceServer_Unary_Call) RunAndReturn ¶
func (_c *MockTestServiceServer_Unary_Call) RunAndReturn(run func(context.Context, *testproto.Msg) (*testproto.Msg, error)) *MockTestServiceServer_Unary_Call
type MockUnsafeTestServiceServer ¶
MockUnsafeTestServiceServer is an autogenerated mock type for the UnsafeTestServiceServer type
func NewMockUnsafeTestServiceServer ¶
func NewMockUnsafeTestServiceServer(t interface { mock.TestingT Cleanup(func()) }) *MockUnsafeTestServiceServer
NewMockUnsafeTestServiceServer creates a new instance of MockUnsafeTestServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MockUnsafeTestServiceServer) EXPECT ¶
func (_m *MockUnsafeTestServiceServer) EXPECT() *MockUnsafeTestServiceServer_Expecter
type MockUnsafeTestServiceServer_Expecter ¶
type MockUnsafeTestServiceServer_Expecter struct {
// contains filtered or unexported fields
}
type MockUnsafeTestServiceServer_mustEmbedUnimplementedTestServiceServer_Call ¶
MockUnsafeTestServiceServer_mustEmbedUnimplementedTestServiceServer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'mustEmbedUnimplementedTestServiceServer'
func (*MockUnsafeTestServiceServer_mustEmbedUnimplementedTestServiceServer_Call) RunAndReturn ¶
func (_c *MockUnsafeTestServiceServer_mustEmbedUnimplementedTestServiceServer_Call) RunAndReturn(run func()) *MockUnsafeTestServiceServer_mustEmbedUnimplementedTestServiceServer_Call