redistest

Documentation

Index

• type MockClient
  • func NewMockClient(ctrl *gomock.Controller) *MockClient
  • func (_m *MockClient) BRPopLPush(_param0 string, _param1 string, _param2 time.Duration) ([]byte, error)
  • func (_m *MockClient) ConnectionState() string
  • func (_m *MockClient) EXPECT() *MockClientMockRecorder
  • func (_m *MockClient) Endpoint() string
  • func (_m *MockClient) IsRunning() bool
  • func (_m *MockClient) LPush(_param0 string, _param1 []byte) error
  • func (_m *MockClient) LRem(_param0 string, _param1 []byte) error
  • func (_m *MockClient) Start() error
  • func (_m *MockClient) Stop() error
• type MockClientMockRecorder
  • func (_mr *MockClientMockRecorder) BRPopLPush(arg0, arg1, arg2 interface{}) *gomock.Call
  • func (_mr *MockClientMockRecorder) ConnectionState() *gomock.Call
  • func (_mr *MockClientMockRecorder) Endpoint() *gomock.Call
  • func (_mr *MockClientMockRecorder) IsRunning() *gomock.Call
  • func (_mr *MockClientMockRecorder) LPush(arg0, arg1 interface{}) *gomock.Call
  • func (_mr *MockClientMockRecorder) LRem(arg0, arg1 interface{}) *gomock.Call
  • func (_mr *MockClientMockRecorder) Start() *gomock.Call
  • func (_mr *MockClientMockRecorder) Stop() *gomock.Call

Types

type MockClient

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

MockClient is a mock of Client interface

func NewMockClient

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance

func (*MockClient) BRPopLPush

func (_m *MockClient) BRPopLPush(_param0 string, _param1 string, _param2 time.Duration) ([]byte, error)

BRPopLPush mocks base method

func (*MockClient) ConnectionState

func (_m *MockClient) ConnectionState() string

ConnectionState mocks base method

func (*MockClient) EXPECT

func (_m *MockClient) EXPECT() *MockClientMockRecorder

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

func (*MockClient) Endpoint

func (_m *MockClient) Endpoint() string

Endpoint mocks base method

func (*MockClient) IsRunning

func (_m *MockClient) IsRunning() bool

IsRunning mocks base method

func (*MockClient) LPush

func (_m *MockClient) LPush(_param0 string, _param1 []byte) error

LPush mocks base method

func (*MockClient) LRem

func (_m *MockClient) LRem(_param0 string, _param1 []byte) error

LRem mocks base method

func (*MockClient) Start

func (_m *MockClient) Start() error

Start mocks base method

func (*MockClient) Stop

func (_m *MockClient) Stop() error

Stop mocks base method

type MockClientMockRecorder

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

MockClientMockRecorder is the mock recorder for MockClient

func (*MockClientMockRecorder) BRPopLPush

func (_mr *MockClientMockRecorder) BRPopLPush(arg0, arg1, arg2 interface{}) *gomock.Call

BRPopLPush indicates an expected call of BRPopLPush

func (*MockClientMockRecorder) ConnectionState

func (_mr *MockClientMockRecorder) ConnectionState() *gomock.Call

ConnectionState indicates an expected call of ConnectionState

func (*MockClientMockRecorder) Endpoint

func (_mr *MockClientMockRecorder) Endpoint() *gomock.Call

Endpoint indicates an expected call of Endpoint

func (*MockClientMockRecorder) IsRunning

func (_mr *MockClientMockRecorder) IsRunning() *gomock.Call

IsRunning indicates an expected call of IsRunning

func (*MockClientMockRecorder) LPush

func (_mr *MockClientMockRecorder) LPush(arg0, arg1 interface{}) *gomock.Call

LPush indicates an expected call of LPush

func (*MockClientMockRecorder) LRem

func (_mr *MockClientMockRecorder) LRem(arg0, arg1 interface{}) *gomock.Call

LRem indicates an expected call of LRem

func (*MockClientMockRecorder) Start

func (_mr *MockClientMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

func (*MockClientMockRecorder) Stop

func (_mr *MockClientMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop