Documentation ¶
Overview ¶
Package db is a generated GoMock package.
Index ¶
- Constants
- Variables
- type Adapter
- type MockAdapter
- func (m *MockAdapter) ClearAllSymbolListenersCount(ctx context.Context) error
- func (m *MockAdapter) ClearSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) error
- func (m *MockAdapter) DecrementSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)
- func (m *MockAdapter) EXPECT() *MockAdapterMockRecorder
- func (m *MockAdapter) GetSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)
- func (m *MockAdapter) IncrementSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)
- type MockAdapterMockRecorder
- func (mr *MockAdapterMockRecorder) ClearAllSymbolListenersCount(ctx interface{}) *gomock.Call
- func (mr *MockAdapterMockRecorder) ClearSymbolListenerSubscribers(ctx, exchange, pairSymbol interface{}) *gomock.Call
- func (mr *MockAdapterMockRecorder) DecrementSymbolListenerSubscribers(ctx, exchange, pairSymbol interface{}) *gomock.Call
- func (mr *MockAdapterMockRecorder) GetSymbolListenerSubscribers(ctx, exchange, pairSymbol interface{}) *gomock.Call
- func (mr *MockAdapterMockRecorder) IncrementSymbolListenerSubscribers(ctx, exchange, pairSymbol interface{}) *gomock.Call
Constants ¶
const ( Expiration = 3 * time.Second RetryDelay = 100 * time.Millisecond Tries = 20 )
Variables ¶
var ( ErrRecordNotFound = errors.New("record not found") ErrNotImplemented = errors.New("not implemented") )
Functions ¶
This section is empty.
Types ¶
type Adapter ¶
type Adapter interface { // Symbol Listener Count IncrementSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error) DecrementSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error) GetSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error) ClearSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) error ClearAllSymbolListenersCount(ctx context.Context) error }
type MockAdapter ¶
type MockAdapter struct {
// contains filtered or unexported fields
}
MockAdapter is a mock of Adapter interface.
func NewMockAdapter ¶
func NewMockAdapter(ctrl *gomock.Controller) *MockAdapter
NewMockAdapter creates a new mock instance.
func (*MockAdapter) ClearAllSymbolListenersCount ¶
func (m *MockAdapter) ClearAllSymbolListenersCount(ctx context.Context) error
ClearAllSymbolListenersCount mocks base method.
func (*MockAdapter) ClearSymbolListenerSubscribers ¶
func (m *MockAdapter) ClearSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) error
ClearSymbolListenerSubscribers mocks base method.
func (*MockAdapter) DecrementSymbolListenerSubscribers ¶
func (m *MockAdapter) DecrementSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)
DecrementSymbolListenerSubscribers mocks base method.
func (*MockAdapter) EXPECT ¶
func (m *MockAdapter) EXPECT() *MockAdapterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAdapter) GetSymbolListenerSubscribers ¶
func (m *MockAdapter) GetSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)
GetSymbolListenerSubscribers mocks base method.
func (*MockAdapter) IncrementSymbolListenerSubscribers ¶
func (m *MockAdapter) IncrementSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)
IncrementSymbolListenerSubscribers mocks base method.
type MockAdapterMockRecorder ¶
type MockAdapterMockRecorder struct {
// contains filtered or unexported fields
}
MockAdapterMockRecorder is the mock recorder for MockAdapter.
func (*MockAdapterMockRecorder) ClearAllSymbolListenersCount ¶
func (mr *MockAdapterMockRecorder) ClearAllSymbolListenersCount(ctx interface{}) *gomock.Call
ClearAllSymbolListenersCount indicates an expected call of ClearAllSymbolListenersCount.
func (*MockAdapterMockRecorder) ClearSymbolListenerSubscribers ¶
func (mr *MockAdapterMockRecorder) ClearSymbolListenerSubscribers(ctx, exchange, pairSymbol interface{}) *gomock.Call
ClearSymbolListenerSubscribers indicates an expected call of ClearSymbolListenerSubscribers.
func (*MockAdapterMockRecorder) DecrementSymbolListenerSubscribers ¶
func (mr *MockAdapterMockRecorder) DecrementSymbolListenerSubscribers(ctx, exchange, pairSymbol interface{}) *gomock.Call
DecrementSymbolListenerSubscribers indicates an expected call of DecrementSymbolListenerSubscribers.
func (*MockAdapterMockRecorder) GetSymbolListenerSubscribers ¶
func (mr *MockAdapterMockRecorder) GetSymbolListenerSubscribers(ctx, exchange, pairSymbol interface{}) *gomock.Call
GetSymbolListenerSubscribers indicates an expected call of GetSymbolListenerSubscribers.
func (*MockAdapterMockRecorder) IncrementSymbolListenerSubscribers ¶
func (mr *MockAdapterMockRecorder) IncrementSymbolListenerSubscribers(ctx, exchange, pairSymbol interface{}) *gomock.Call
IncrementSymbolListenerSubscribers indicates an expected call of IncrementSymbolListenerSubscribers.