rawtopicreadermock

Documentation

Overview

Code generated by MockGen. DO NOT EDIT. Source: github.com/ydb-platform/ydb-go-sdk/v3/internal/grpcwrapper/rawtopic/rawtopicreader (interfaces: TopicReaderStreamInterface)

Generated by this command:

mockgen -destination ../rawtopicreadermock/stream_reader_stream_interface_mock.go --typed -package rawtopicreadermock -write_package_comment=false --typed . TopicReaderStreamInterface

Index

• type MockTopicReaderStreamInterface
  • func NewMockTopicReaderStreamInterface(ctrl *gomock.Controller) *MockTopicReaderStreamInterface
  • func (m *MockTopicReaderStreamInterface) CloseSend() error
  • func (m *MockTopicReaderStreamInterface) EXPECT() *MockTopicReaderStreamInterfaceMockRecorder
  • func (m *MockTopicReaderStreamInterface) Recv() (rawtopicreader.ServerMessage, error)
  • func (m *MockTopicReaderStreamInterface) Send(arg0 rawtopicreader.ClientMessage) error
• type MockTopicReaderStreamInterfaceCloseSendCall
  • func (c *MockTopicReaderStreamInterfaceCloseSendCall) Do(f func() error) *MockTopicReaderStreamInterfaceCloseSendCall
  • func (c *MockTopicReaderStreamInterfaceCloseSendCall) DoAndReturn(f func() error) *MockTopicReaderStreamInterfaceCloseSendCall
  • func (c *MockTopicReaderStreamInterfaceCloseSendCall) Return(arg0 error) *MockTopicReaderStreamInterfaceCloseSendCall
• type MockTopicReaderStreamInterfaceMockRecorder
  • func (mr *MockTopicReaderStreamInterfaceMockRecorder) CloseSend() *MockTopicReaderStreamInterfaceCloseSendCall
  • func (mr *MockTopicReaderStreamInterfaceMockRecorder) Recv() *MockTopicReaderStreamInterfaceRecvCall
  • func (mr *MockTopicReaderStreamInterfaceMockRecorder) Send(arg0 any) *MockTopicReaderStreamInterfaceSendCall
• type MockTopicReaderStreamInterfaceRecvCall
  • func (c *MockTopicReaderStreamInterfaceRecvCall) Do(f func() (rawtopicreader.ServerMessage, error)) *MockTopicReaderStreamInterfaceRecvCall
  • func (c *MockTopicReaderStreamInterfaceRecvCall) DoAndReturn(f func() (rawtopicreader.ServerMessage, error)) *MockTopicReaderStreamInterfaceRecvCall
  • func (c *MockTopicReaderStreamInterfaceRecvCall) Return(arg0 rawtopicreader.ServerMessage, arg1 error) *MockTopicReaderStreamInterfaceRecvCall
• type MockTopicReaderStreamInterfaceSendCall
  • func (c *MockTopicReaderStreamInterfaceSendCall) Do(f func(rawtopicreader.ClientMessage) error) *MockTopicReaderStreamInterfaceSendCall
  • func (c *MockTopicReaderStreamInterfaceSendCall) DoAndReturn(f func(rawtopicreader.ClientMessage) error) *MockTopicReaderStreamInterfaceSendCall
  • func (c *MockTopicReaderStreamInterfaceSendCall) Return(arg0 error) *MockTopicReaderStreamInterfaceSendCall

Types

type MockTopicReaderStreamInterface

type MockTopicReaderStreamInterface struct {
	// contains filtered or unexported fields
}

MockTopicReaderStreamInterface is a mock of TopicReaderStreamInterface interface.

func NewMockTopicReaderStreamInterface

func NewMockTopicReaderStreamInterface(ctrl *gomock.Controller) *MockTopicReaderStreamInterface

NewMockTopicReaderStreamInterface creates a new mock instance.

func (*MockTopicReaderStreamInterface) CloseSend

func (m *MockTopicReaderStreamInterface) CloseSend() error

CloseSend mocks base method.

func (*MockTopicReaderStreamInterface) EXPECT

func (m *MockTopicReaderStreamInterface) EXPECT() *MockTopicReaderStreamInterfaceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTopicReaderStreamInterface) Recv

func (m *MockTopicReaderStreamInterface) Recv() (rawtopicreader.ServerMessage, error)

Recv mocks base method.

func (*MockTopicReaderStreamInterface) Send

func (m *MockTopicReaderStreamInterface) Send(arg0 rawtopicreader.ClientMessage) error

Send mocks base method.

type MockTopicReaderStreamInterfaceCloseSendCall

type MockTopicReaderStreamInterfaceCloseSendCall struct {
	*gomock.Call
}

MockTopicReaderStreamInterfaceCloseSendCall wrap *gomock.Call

func (*MockTopicReaderStreamInterfaceCloseSendCall) Do

func (c *MockTopicReaderStreamInterfaceCloseSendCall) Do(f func() error) *MockTopicReaderStreamInterfaceCloseSendCall

Do rewrite *gomock.Call.Do

func (*MockTopicReaderStreamInterfaceCloseSendCall) DoAndReturn

func (c *MockTopicReaderStreamInterfaceCloseSendCall) DoAndReturn(f func() error) *MockTopicReaderStreamInterfaceCloseSendCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockTopicReaderStreamInterfaceCloseSendCall) Return

func (c *MockTopicReaderStreamInterfaceCloseSendCall) Return(arg0 error) *MockTopicReaderStreamInterfaceCloseSendCall

Return rewrite *gomock.Call.Return

type MockTopicReaderStreamInterfaceMockRecorder

type MockTopicReaderStreamInterfaceMockRecorder struct {
	// contains filtered or unexported fields
}

MockTopicReaderStreamInterfaceMockRecorder is the mock recorder for MockTopicReaderStreamInterface.

func (*MockTopicReaderStreamInterfaceMockRecorder) CloseSend

func (mr *MockTopicReaderStreamInterfaceMockRecorder) CloseSend() *MockTopicReaderStreamInterfaceCloseSendCall

CloseSend indicates an expected call of CloseSend.

func (*MockTopicReaderStreamInterfaceMockRecorder) Recv

func (mr *MockTopicReaderStreamInterfaceMockRecorder) Recv() *MockTopicReaderStreamInterfaceRecvCall

Recv indicates an expected call of Recv.

func (*MockTopicReaderStreamInterfaceMockRecorder) Send

func (mr *MockTopicReaderStreamInterfaceMockRecorder) Send(arg0 any) *MockTopicReaderStreamInterfaceSendCall

Send indicates an expected call of Send.

type MockTopicReaderStreamInterfaceRecvCall

type MockTopicReaderStreamInterfaceRecvCall struct {
	*gomock.Call
}

MockTopicReaderStreamInterfaceRecvCall wrap *gomock.Call

func (*MockTopicReaderStreamInterfaceRecvCall) Do

func (c *MockTopicReaderStreamInterfaceRecvCall) Do(f func() (rawtopicreader.ServerMessage, error)) *MockTopicReaderStreamInterfaceRecvCall

Do rewrite *gomock.Call.Do

func (*MockTopicReaderStreamInterfaceRecvCall) DoAndReturn

func (c *MockTopicReaderStreamInterfaceRecvCall) DoAndReturn(f func() (rawtopicreader.ServerMessage, error)) *MockTopicReaderStreamInterfaceRecvCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockTopicReaderStreamInterfaceRecvCall) Return

func (c *MockTopicReaderStreamInterfaceRecvCall) Return(arg0 rawtopicreader.ServerMessage, arg1 error) *MockTopicReaderStreamInterfaceRecvCall

Return rewrite *gomock.Call.Return

type MockTopicReaderStreamInterfaceSendCall

type MockTopicReaderStreamInterfaceSendCall struct {
	*gomock.Call
}

MockTopicReaderStreamInterfaceSendCall wrap *gomock.Call

func (*MockTopicReaderStreamInterfaceSendCall) Do

func (c *MockTopicReaderStreamInterfaceSendCall) Do(f func(rawtopicreader.ClientMessage) error) *MockTopicReaderStreamInterfaceSendCall

Do rewrite *gomock.Call.Do

func (*MockTopicReaderStreamInterfaceSendCall) DoAndReturn

func (c *MockTopicReaderStreamInterfaceSendCall) DoAndReturn(f func(rawtopicreader.ClientMessage) error) *MockTopicReaderStreamInterfaceSendCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockTopicReaderStreamInterfaceSendCall) Return

func (c *MockTopicReaderStreamInterfaceSendCall) Return(arg0 error) *MockTopicReaderStreamInterfaceSendCall

Return rewrite *gomock.Call.Return