mock

Documentation

Overview

Package mock is a generated GoMock package.

Index

• type MockServer
  • func NewMockServer(ctrl *gomock.Controller) *MockServer
  • func (m *MockServer) AddDataShard(clid uint, shardKey kr.ShardKey, tsa tsa.TSA) error
  • func (m *MockServer) Cancel() error
  • func (m *MockServer) DataPending() bool
  • func (m *MockServer) Datashards() []shard.Shard
  • func (m *MockServer) EXPECT() *MockServerMockRecorder
  • func (m *MockServer) HasPrepareStatement(hash uint64, shardId uint) (bool, *prepstatement.PreparedStatementDescriptor)
  • func (m *MockServer) Name() string
  • func (m *MockServer) Receive() (pgproto3.BackendMessage, error)
  • func (m *MockServer) ReceiveShard(shardId uint) (pgproto3.BackendMessage, error)
  • func (m *MockServer) Reset() error
  • func (m *MockServer) Send(query pgproto3.FrontendMessage) error
  • func (m *MockServer) SendShard(query pgproto3.FrontendMessage, shardId uint) error
  • func (m *MockServer) SetTxStatus(status txstatus.TXStatus)
  • func (m *MockServer) StorePrepareStatement(hash uint64, shardId uint, d *prepstatement.PreparedStatementDefinition, ...) error
  • func (m *MockServer) Sync() int64
  • func (m *MockServer) TxStatus() txstatus.TXStatus
  • func (m *MockServer) UnRouteShard(sh kr.ShardKey, rule *config.FrontendRule) error
• type MockServerMockRecorder
  • func (mr *MockServerMockRecorder) AddDataShard(clid, shardKey, tsa interface{}) *gomock.Call
  • func (mr *MockServerMockRecorder) Cancel() *gomock.Call
  • func (mr *MockServerMockRecorder) DataPending() *gomock.Call
  • func (mr *MockServerMockRecorder) Datashards() *gomock.Call
  • func (mr *MockServerMockRecorder) HasPrepareStatement(hash, shardId interface{}) *gomock.Call
  • func (mr *MockServerMockRecorder) Name() *gomock.Call
  • func (mr *MockServerMockRecorder) Receive() *gomock.Call
  • func (mr *MockServerMockRecorder) ReceiveShard(shardId interface{}) *gomock.Call
  • func (mr *MockServerMockRecorder) Reset() *gomock.Call
  • func (mr *MockServerMockRecorder) Send(query interface{}) *gomock.Call
  • func (mr *MockServerMockRecorder) SendShard(query, shardId interface{}) *gomock.Call
  • func (mr *MockServerMockRecorder) SetTxStatus(status interface{}) *gomock.Call
  • func (mr *MockServerMockRecorder) StorePrepareStatement(hash, shardId, d, rd interface{}) *gomock.Call
  • func (mr *MockServerMockRecorder) Sync() *gomock.Call
  • func (mr *MockServerMockRecorder) TxStatus() *gomock.Call
  • func (mr *MockServerMockRecorder) UnRouteShard(sh, rule interface{}) *gomock.Call

Types

type MockServer

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

MockServer is a mock of Server interface.

func NewMockServer

func NewMockServer(ctrl *gomock.Controller) *MockServer

NewMockServer creates a new mock instance.

func (*MockServer) AddDataShard

func (m *MockServer) AddDataShard(clid uint, shardKey kr.ShardKey, tsa tsa.TSA) error

AddDataShard mocks base method.

func (*MockServer) Cancel

func (m *MockServer) Cancel() error

Cancel mocks base method.

func (*MockServer) DataPending

func (m *MockServer) DataPending() bool

DataPending mocks base method.

func (*MockServer) Datashards

func (m *MockServer) Datashards() []shard.Shard

Datashards mocks base method.

func (*MockServer) EXPECT

func (m *MockServer) EXPECT() *MockServerMockRecorder

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

func (*MockServer) HasPrepareStatement

func (m *MockServer) HasPrepareStatement(hash uint64, shardId uint) (bool, *prepstatement.PreparedStatementDescriptor)

HasPrepareStatement mocks base method.

func (*MockServer) Name

func (m *MockServer) Name() string

Name mocks base method.

func (*MockServer) Receive

func (m *MockServer) Receive() (pgproto3.BackendMessage, error)

Receive mocks base method.

func (*MockServer) ReceiveShard

func (m *MockServer) ReceiveShard(shardId uint) (pgproto3.BackendMessage, error)

ReceiveShard mocks base method.

func (*MockServer) Reset

func (m *MockServer) Reset() error

Reset mocks base method.

func (*MockServer) Send

func (m *MockServer) Send(query pgproto3.FrontendMessage) error

Send mocks base method.

func (*MockServer) SendShard

func (m *MockServer) SendShard(query pgproto3.FrontendMessage, shardId uint) error

SendShard mocks base method.

func (*MockServer) SetTxStatus

func (m *MockServer) SetTxStatus(status txstatus.TXStatus)

SetTxStatus mocks base method.

func (*MockServer) StorePrepareStatement

func (m *MockServer) StorePrepareStatement(hash uint64, shardId uint, d *prepstatement.PreparedStatementDefinition, rd *prepstatement.PreparedStatementDescriptor) error

StorePrepareStatement mocks base method.

func (*MockServer) Sync

func (m *MockServer) Sync() int64

Sync mocks base method.

func (*MockServer) TxStatus

func (m *MockServer) TxStatus() txstatus.TXStatus

TxStatus mocks base method.

func (*MockServer) UnRouteShard

func (m *MockServer) UnRouteShard(sh kr.ShardKey, rule *config.FrontendRule) error

UnRouteShard mocks base method.

type MockServerMockRecorder

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

MockServerMockRecorder is the mock recorder for MockServer.

func (*MockServerMockRecorder) AddDataShard

func (mr *MockServerMockRecorder) AddDataShard(clid, shardKey, tsa interface{}) *gomock.Call

AddDataShard indicates an expected call of AddDataShard.

func (*MockServerMockRecorder) Cancel

func (mr *MockServerMockRecorder) Cancel() *gomock.Call

Cancel indicates an expected call of Cancel.

func (*MockServerMockRecorder) DataPending

func (mr *MockServerMockRecorder) DataPending() *gomock.Call

DataPending indicates an expected call of DataPending.

func (*MockServerMockRecorder) Datashards

func (mr *MockServerMockRecorder) Datashards() *gomock.Call

Datashards indicates an expected call of Datashards.

func (*MockServerMockRecorder) HasPrepareStatement

func (mr *MockServerMockRecorder) HasPrepareStatement(hash, shardId interface{}) *gomock.Call

HasPrepareStatement indicates an expected call of HasPrepareStatement.

func (*MockServerMockRecorder) Name

func (mr *MockServerMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name.

func (*MockServerMockRecorder) Receive

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

Receive indicates an expected call of Receive.

func (*MockServerMockRecorder) ReceiveShard

func (mr *MockServerMockRecorder) ReceiveShard(shardId interface{}) *gomock.Call

ReceiveShard indicates an expected call of ReceiveShard.

func (*MockServerMockRecorder) Reset

func (mr *MockServerMockRecorder) Reset() *gomock.Call

Reset indicates an expected call of Reset.

func (*MockServerMockRecorder) Send

func (mr *MockServerMockRecorder) Send(query interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockServerMockRecorder) SendShard

func (mr *MockServerMockRecorder) SendShard(query, shardId interface{}) *gomock.Call

SendShard indicates an expected call of SendShard.

func (*MockServerMockRecorder) SetTxStatus

func (mr *MockServerMockRecorder) SetTxStatus(status interface{}) *gomock.Call

SetTxStatus indicates an expected call of SetTxStatus.

func (*MockServerMockRecorder) StorePrepareStatement

func (mr *MockServerMockRecorder) StorePrepareStatement(hash, shardId, d, rd interface{}) *gomock.Call

StorePrepareStatement indicates an expected call of StorePrepareStatement.

func (*MockServerMockRecorder) Sync

func (mr *MockServerMockRecorder) Sync() *gomock.Call

Sync indicates an expected call of Sync.

func (*MockServerMockRecorder) TxStatus

func (mr *MockServerMockRecorder) TxStatus() *gomock.Call

TxStatus indicates an expected call of TxStatus.

func (*MockServerMockRecorder) UnRouteShard

func (mr *MockServerMockRecorder) UnRouteShard(sh, rule interface{}) *gomock.Call

UnRouteShard indicates an expected call of UnRouteShard.