mock_morpc

Documentation

Overview

Package mock_morpc is a generated GoMock package.

Index

• type MockClientSession
  • func NewMockClientSession(ctrl *gomock.Controller) *MockClientSession
  • func (m *MockClientSession) AsyncWrite(response morpc.Message) error
  • func (m *MockClientSession) Close() error
  • func (m *MockClientSession) CreateCache(ctx context.Context, cacheID uint64) (morpc.MessageCache, error)
  • func (m *MockClientSession) DeleteCache(cacheID uint64)
  • func (m *MockClientSession) EXPECT() *MockClientSessionMockRecorder
  • func (m *MockClientSession) GetCache(cacheID uint64) (morpc.MessageCache, error)
  • func (m *MockClientSession) RemoteAddress() string
  • func (m *MockClientSession) SessionCtx() context.Context
  • func (m *MockClientSession) Write(ctx context.Context, response morpc.Message) error
• type MockClientSessionMockRecorder
  • func (mr *MockClientSessionMockRecorder) AsyncWrite(response interface{}) *gomock.Call
  • func (mr *MockClientSessionMockRecorder) Close() *gomock.Call
  • func (mr *MockClientSessionMockRecorder) CreateCache(ctx, cacheID interface{}) *gomock.Call
  • func (mr *MockClientSessionMockRecorder) DeleteCache(cacheID interface{}) *gomock.Call
  • func (mr *MockClientSessionMockRecorder) GetCache(cacheID interface{}) *gomock.Call
  • func (mr *MockClientSessionMockRecorder) RemoteAddress() *gomock.Call
  • func (mr *MockClientSessionMockRecorder) SessionCtx() *gomock.Call
  • func (mr *MockClientSessionMockRecorder) Write(ctx, response interface{}) *gomock.Call
• type MockStream
  • func NewMockStream(ctrl *gomock.Controller) *MockStream
  • func (m *MockStream) Close(closeConn bool) error
  • func (m *MockStream) EXPECT() *MockStreamMockRecorder
  • func (m *MockStream) ID() uint64
  • func (m *MockStream) Receive() (chan morpc.Message, error)
  • func (m *MockStream) Send(ctx context.Context, request morpc.Message) error
• type MockStreamMockRecorder
  • func (mr *MockStreamMockRecorder) Close(closeConn interface{}) *gomock.Call
  • func (mr *MockStreamMockRecorder) ID() *gomock.Call
  • func (mr *MockStreamMockRecorder) Receive() *gomock.Call
  • func (mr *MockStreamMockRecorder) Send(ctx, request interface{}) *gomock.Call

Types

type MockClientSession

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

MockClientSession is a mock of ClientSession interface.

func NewMockClientSession

func NewMockClientSession(ctrl *gomock.Controller) *MockClientSession

NewMockClientSession creates a new mock instance.

func (*MockClientSession) AsyncWrite

func (m *MockClientSession) AsyncWrite(response morpc.Message) error

AsyncWrite mocks base method.

func (*MockClientSession) Close

func (m *MockClientSession) Close() error

Close mocks base method.

func (*MockClientSession) CreateCache

func (m *MockClientSession) CreateCache(ctx context.Context, cacheID uint64) (morpc.MessageCache, error)

CreateCache mocks base method.

func (*MockClientSession) DeleteCache

func (m *MockClientSession) DeleteCache(cacheID uint64)

DeleteCache mocks base method.

func (*MockClientSession) EXPECT

func (m *MockClientSession) EXPECT() *MockClientSessionMockRecorder

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

func (*MockClientSession) GetCache

func (m *MockClientSession) GetCache(cacheID uint64) (morpc.MessageCache, error)

GetCache mocks base method.

func (*MockClientSession) RemoteAddress

func (m *MockClientSession) RemoteAddress() string

RemoteAddress mocks base method.

func (*MockClientSession) SessionCtx

func (m *MockClientSession) SessionCtx() context.Context

SessionCtx mocks base method.

func (*MockClientSession) Write

func (m *MockClientSession) Write(ctx context.Context, response morpc.Message) error

Write mocks base method.

type MockClientSessionMockRecorder

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

MockClientSessionMockRecorder is the mock recorder for MockClientSession.

func (*MockClientSessionMockRecorder) AsyncWrite

func (mr *MockClientSessionMockRecorder) AsyncWrite(response interface{}) *gomock.Call

AsyncWrite indicates an expected call of AsyncWrite.

func (*MockClientSessionMockRecorder) Close

func (mr *MockClientSessionMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockClientSessionMockRecorder) CreateCache

func (mr *MockClientSessionMockRecorder) CreateCache(ctx, cacheID interface{}) *gomock.Call

CreateCache indicates an expected call of CreateCache.

func (*MockClientSessionMockRecorder) DeleteCache

func (mr *MockClientSessionMockRecorder) DeleteCache(cacheID interface{}) *gomock.Call

DeleteCache indicates an expected call of DeleteCache.

func (*MockClientSessionMockRecorder) GetCache

func (mr *MockClientSessionMockRecorder) GetCache(cacheID interface{}) *gomock.Call

GetCache indicates an expected call of GetCache.

func (*MockClientSessionMockRecorder) RemoteAddress

func (mr *MockClientSessionMockRecorder) RemoteAddress() *gomock.Call

RemoteAddress indicates an expected call of RemoteAddress.

func (*MockClientSessionMockRecorder) SessionCtx

func (mr *MockClientSessionMockRecorder) SessionCtx() *gomock.Call

SessionCtx indicates an expected call of SessionCtx.

func (*MockClientSessionMockRecorder) Write

func (mr *MockClientSessionMockRecorder) Write(ctx, response interface{}) *gomock.Call

Write indicates an expected call of Write.

type MockStream

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

MockStream is a mock of Stream interface.

func NewMockStream

func NewMockStream(ctrl *gomock.Controller) *MockStream

NewMockStream creates a new mock instance.

func (*MockStream) Close

func (m *MockStream) Close(closeConn bool) error

Close mocks base method.

func (*MockStream) EXPECT

func (m *MockStream) EXPECT() *MockStreamMockRecorder

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

func (*MockStream) ID

func (m *MockStream) ID() uint64

ID mocks base method.

func (*MockStream) Receive

func (m *MockStream) Receive() (chan morpc.Message, error)

Receive mocks base method.

func (*MockStream) Send

func (m *MockStream) Send(ctx context.Context, request morpc.Message) error

Send mocks base method.

type MockStreamMockRecorder

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

MockStreamMockRecorder is the mock recorder for MockStream.

func (*MockStreamMockRecorder) Close

func (mr *MockStreamMockRecorder) Close(closeConn interface{}) *gomock.Call

Close indicates an expected call of Close.

func (*MockStreamMockRecorder) ID

func (mr *MockStreamMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*MockStreamMockRecorder) Receive

func (mr *MockStreamMockRecorder) Receive() *gomock.Call

Receive indicates an expected call of Receive.

func (*MockStreamMockRecorder) Send

func (mr *MockStreamMockRecorder) Send(ctx, request interface{}) *gomock.Call

Send indicates an expected call of Send.