Documentation ¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockExchange
- func (m *MockExchange) CancelOrders(arg0 context.Context, arg1 ...types.Order) error
- func (m *MockExchange) EXPECT() *MockExchangeMockRecorder
- func (m *MockExchange) Name() types.ExchangeName
- func (m *MockExchange) NewStream() types.Stream
- func (m *MockExchange) PlatformFeeCurrency() string
- func (m *MockExchange) QueryAccount(arg0 context.Context) (*types.Account, error)
- func (m *MockExchange) QueryAccountBalances(arg0 context.Context) (types.BalanceMap, error)
- func (m *MockExchange) QueryKLines(arg0 context.Context, arg1 string, arg2 types.Interval, ...) ([]types.KLine, error)
- func (m *MockExchange) QueryMarkets(arg0 context.Context) (types.MarketMap, error)
- func (m *MockExchange) QueryOpenOrders(arg0 context.Context, arg1 string) ([]types.Order, error)
- func (m *MockExchange) QueryTicker(arg0 context.Context, arg1 string) (*types.Ticker, error)
- func (m *MockExchange) QueryTickers(arg0 context.Context, arg1 ...string) (map[string]types.Ticker, error)
- func (m *MockExchange) SubmitOrder(arg0 context.Context, arg1 types.SubmitOrder) (*types.Order, error)
- type MockExchangeMockRecorder
- func (mr *MockExchangeMockRecorder) CancelOrders(arg0 any, arg1 ...any) *gomock.Call
- func (mr *MockExchangeMockRecorder) Name() *gomock.Call
- func (mr *MockExchangeMockRecorder) NewStream() *gomock.Call
- func (mr *MockExchangeMockRecorder) PlatformFeeCurrency() *gomock.Call
- func (mr *MockExchangeMockRecorder) QueryAccount(arg0 any) *gomock.Call
- func (mr *MockExchangeMockRecorder) QueryAccountBalances(arg0 any) *gomock.Call
- func (mr *MockExchangeMockRecorder) QueryKLines(arg0, arg1, arg2, arg3 any) *gomock.Call
- func (mr *MockExchangeMockRecorder) QueryMarkets(arg0 any) *gomock.Call
- func (mr *MockExchangeMockRecorder) QueryOpenOrders(arg0, arg1 any) *gomock.Call
- func (mr *MockExchangeMockRecorder) QueryTicker(arg0, arg1 any) *gomock.Call
- func (mr *MockExchangeMockRecorder) QueryTickers(arg0 any, arg1 ...any) *gomock.Call
- func (mr *MockExchangeMockRecorder) SubmitOrder(arg0, arg1 any) *gomock.Call
- type MockExchangeOrderQueryService
- func (m *MockExchangeOrderQueryService) EXPECT() *MockExchangeOrderQueryServiceMockRecorder
- func (m *MockExchangeOrderQueryService) QueryOrder(arg0 context.Context, arg1 types.OrderQuery) (*types.Order, error)
- func (m *MockExchangeOrderQueryService) QueryOrderTrades(arg0 context.Context, arg1 types.OrderQuery) ([]types.Trade, error)
- type MockExchangeOrderQueryServiceMockRecorder
- type MockExchangePublic
- func (m *MockExchangePublic) EXPECT() *MockExchangePublicMockRecorder
- func (m *MockExchangePublic) Name() types.ExchangeName
- func (m *MockExchangePublic) NewStream() types.Stream
- func (m *MockExchangePublic) PlatformFeeCurrency() string
- func (m *MockExchangePublic) QueryKLines(arg0 context.Context, arg1 string, arg2 types.Interval, ...) ([]types.KLine, error)
- func (m *MockExchangePublic) QueryMarkets(arg0 context.Context) (types.MarketMap, error)
- func (m *MockExchangePublic) QueryTicker(arg0 context.Context, arg1 string) (*types.Ticker, error)
- func (m *MockExchangePublic) QueryTickers(arg0 context.Context, arg1 ...string) (map[string]types.Ticker, error)
- type MockExchangePublicMockRecorder
- func (mr *MockExchangePublicMockRecorder) Name() *gomock.Call
- func (mr *MockExchangePublicMockRecorder) NewStream() *gomock.Call
- func (mr *MockExchangePublicMockRecorder) PlatformFeeCurrency() *gomock.Call
- func (mr *MockExchangePublicMockRecorder) QueryKLines(arg0, arg1, arg2, arg3 any) *gomock.Call
- func (mr *MockExchangePublicMockRecorder) QueryMarkets(arg0 any) *gomock.Call
- func (mr *MockExchangePublicMockRecorder) QueryTicker(arg0, arg1 any) *gomock.Call
- func (mr *MockExchangePublicMockRecorder) QueryTickers(arg0 any, arg1 ...any) *gomock.Call
- type MockExchangeTradeHistoryService
- func (m *MockExchangeTradeHistoryService) EXPECT() *MockExchangeTradeHistoryServiceMockRecorder
- func (m *MockExchangeTradeHistoryService) QueryClosedOrders(arg0 context.Context, arg1 string, arg2, arg3 time.Time, arg4 uint64) ([]types.Order, error)
- func (m *MockExchangeTradeHistoryService) QueryTrades(arg0 context.Context, arg1 string, arg2 *types.TradeQueryOptions) ([]types.Trade, error)
- type MockExchangeTradeHistoryServiceMockRecorder
- type MockStream
- func (m *MockStream) Close() error
- func (m *MockStream) Connect(arg0 context.Context) error
- func (m *MockStream) EXPECT() *MockStreamMockRecorder
- func (m *MockStream) GetPublicOnly() bool
- func (m *MockStream) GetSubscriptions() []types.Subscription
- func (m *MockStream) OnAggTrade(arg0 func(types.Trade))
- func (m *MockStream) OnAuth(arg0 func())
- func (m *MockStream) OnBalanceSnapshot(arg0 func(types.BalanceMap))
- func (m *MockStream) OnBalanceUpdate(arg0 func(types.BalanceMap))
- func (m *MockStream) OnBookSnapshot(arg0 func(types.SliceOrderBook))
- func (m *MockStream) OnBookTickerUpdate(arg0 func(types.BookTicker))
- func (m *MockStream) OnBookUpdate(arg0 func(types.SliceOrderBook))
- func (m *MockStream) OnConnect(arg0 func())
- func (m *MockStream) OnDisconnect(arg0 func())
- func (m *MockStream) OnForceOrder(arg0 func(types.LiquidationInfo))
- func (m *MockStream) OnFuturesPositionSnapshot(arg0 func(types.FuturesPositionMap))
- func (m *MockStream) OnFuturesPositionUpdate(arg0 func(types.FuturesPositionMap))
- func (m *MockStream) OnKLine(arg0 func(types.KLine))
- func (m *MockStream) OnKLineClosed(arg0 func(types.KLine))
- func (m *MockStream) OnMarketTrade(arg0 func(types.Trade))
- func (m *MockStream) OnOrderUpdate(arg0 func(types.Order))
- func (m *MockStream) OnRawMessage(arg0 func([]byte))
- func (m *MockStream) OnStart(arg0 func())
- func (m *MockStream) OnTradeUpdate(arg0 func(types.Trade))
- func (m *MockStream) Reconnect()
- func (m *MockStream) Resubscribe(arg0 func([]types.Subscription) ([]types.Subscription, error)) error
- func (m *MockStream) SetPublicOnly()
- func (m *MockStream) Subscribe(arg0 types.Channel, arg1 string, arg2 types.SubscribeOptions)
- type MockStreamMockRecorder
- func (mr *MockStreamMockRecorder) Close() *gomock.Call
- func (mr *MockStreamMockRecorder) Connect(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) GetPublicOnly() *gomock.Call
- func (mr *MockStreamMockRecorder) GetSubscriptions() *gomock.Call
- func (mr *MockStreamMockRecorder) OnAggTrade(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnAuth(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnBalanceSnapshot(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnBalanceUpdate(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnBookSnapshot(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnBookTickerUpdate(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnBookUpdate(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnConnect(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnDisconnect(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnForceOrder(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnFuturesPositionSnapshot(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnFuturesPositionUpdate(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnKLine(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnKLineClosed(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnMarketTrade(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnOrderUpdate(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnRawMessage(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnStart(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) OnTradeUpdate(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) Reconnect() *gomock.Call
- func (mr *MockStreamMockRecorder) Resubscribe(arg0 any) *gomock.Call
- func (mr *MockStreamMockRecorder) SetPublicOnly() *gomock.Call
- func (mr *MockStreamMockRecorder) Subscribe(arg0, arg1, arg2 any) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockExchange ¶
type MockExchange struct {
// contains filtered or unexported fields
}
MockExchange is a mock of Exchange interface.
func NewMockExchange ¶
func NewMockExchange(ctrl *gomock.Controller) *MockExchange
NewMockExchange creates a new mock instance.
func (*MockExchange) CancelOrders ¶
CancelOrders mocks base method.
func (*MockExchange) EXPECT ¶
func (m *MockExchange) EXPECT() *MockExchangeMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockExchange) Name ¶
func (m *MockExchange) Name() types.ExchangeName
Name mocks base method.
func (*MockExchange) NewStream ¶
func (m *MockExchange) NewStream() types.Stream
NewStream mocks base method.
func (*MockExchange) PlatformFeeCurrency ¶
func (m *MockExchange) PlatformFeeCurrency() string
PlatformFeeCurrency mocks base method.
func (*MockExchange) QueryAccount ¶
QueryAccount mocks base method.
func (*MockExchange) QueryAccountBalances ¶
func (m *MockExchange) QueryAccountBalances(arg0 context.Context) (types.BalanceMap, error)
QueryAccountBalances mocks base method.
func (*MockExchange) QueryKLines ¶
func (m *MockExchange) QueryKLines(arg0 context.Context, arg1 string, arg2 types.Interval, arg3 types.KLineQueryOptions) ([]types.KLine, error)
QueryKLines mocks base method.
func (*MockExchange) QueryMarkets ¶
QueryMarkets mocks base method.
func (*MockExchange) QueryOpenOrders ¶
QueryOpenOrders mocks base method.
func (*MockExchange) QueryTicker ¶
QueryTicker mocks base method.
func (*MockExchange) QueryTickers ¶
func (m *MockExchange) QueryTickers(arg0 context.Context, arg1 ...string) (map[string]types.Ticker, error)
QueryTickers mocks base method.
func (*MockExchange) SubmitOrder ¶ added in v1.40.3
func (m *MockExchange) SubmitOrder(arg0 context.Context, arg1 types.SubmitOrder) (*types.Order, error)
SubmitOrder mocks base method.
type MockExchangeMockRecorder ¶
type MockExchangeMockRecorder struct {
// contains filtered or unexported fields
}
MockExchangeMockRecorder is the mock recorder for MockExchange.
func (*MockExchangeMockRecorder) CancelOrders ¶
func (mr *MockExchangeMockRecorder) CancelOrders(arg0 any, arg1 ...any) *gomock.Call
CancelOrders indicates an expected call of CancelOrders.
func (*MockExchangeMockRecorder) Name ¶
func (mr *MockExchangeMockRecorder) Name() *gomock.Call
Name indicates an expected call of Name.
func (*MockExchangeMockRecorder) NewStream ¶
func (mr *MockExchangeMockRecorder) NewStream() *gomock.Call
NewStream indicates an expected call of NewStream.
func (*MockExchangeMockRecorder) PlatformFeeCurrency ¶
func (mr *MockExchangeMockRecorder) PlatformFeeCurrency() *gomock.Call
PlatformFeeCurrency indicates an expected call of PlatformFeeCurrency.
func (*MockExchangeMockRecorder) QueryAccount ¶
func (mr *MockExchangeMockRecorder) QueryAccount(arg0 any) *gomock.Call
QueryAccount indicates an expected call of QueryAccount.
func (*MockExchangeMockRecorder) QueryAccountBalances ¶
func (mr *MockExchangeMockRecorder) QueryAccountBalances(arg0 any) *gomock.Call
QueryAccountBalances indicates an expected call of QueryAccountBalances.
func (*MockExchangeMockRecorder) QueryKLines ¶
func (mr *MockExchangeMockRecorder) QueryKLines(arg0, arg1, arg2, arg3 any) *gomock.Call
QueryKLines indicates an expected call of QueryKLines.
func (*MockExchangeMockRecorder) QueryMarkets ¶
func (mr *MockExchangeMockRecorder) QueryMarkets(arg0 any) *gomock.Call
QueryMarkets indicates an expected call of QueryMarkets.
func (*MockExchangeMockRecorder) QueryOpenOrders ¶
func (mr *MockExchangeMockRecorder) QueryOpenOrders(arg0, arg1 any) *gomock.Call
QueryOpenOrders indicates an expected call of QueryOpenOrders.
func (*MockExchangeMockRecorder) QueryTicker ¶
func (mr *MockExchangeMockRecorder) QueryTicker(arg0, arg1 any) *gomock.Call
QueryTicker indicates an expected call of QueryTicker.
func (*MockExchangeMockRecorder) QueryTickers ¶
func (mr *MockExchangeMockRecorder) QueryTickers(arg0 any, arg1 ...any) *gomock.Call
QueryTickers indicates an expected call of QueryTickers.
func (*MockExchangeMockRecorder) SubmitOrder ¶ added in v1.40.3
func (mr *MockExchangeMockRecorder) SubmitOrder(arg0, arg1 any) *gomock.Call
SubmitOrder indicates an expected call of SubmitOrder.
type MockExchangeOrderQueryService ¶ added in v1.43.0
type MockExchangeOrderQueryService struct {
// contains filtered or unexported fields
}
MockExchangeOrderQueryService is a mock of ExchangeOrderQueryService interface.
func NewMockExchangeOrderQueryService ¶ added in v1.43.0
func NewMockExchangeOrderQueryService(ctrl *gomock.Controller) *MockExchangeOrderQueryService
NewMockExchangeOrderQueryService creates a new mock instance.
func (*MockExchangeOrderQueryService) EXPECT ¶ added in v1.43.0
func (m *MockExchangeOrderQueryService) EXPECT() *MockExchangeOrderQueryServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockExchangeOrderQueryService) QueryOrder ¶ added in v1.43.0
func (m *MockExchangeOrderQueryService) QueryOrder(arg0 context.Context, arg1 types.OrderQuery) (*types.Order, error)
QueryOrder mocks base method.
func (*MockExchangeOrderQueryService) QueryOrderTrades ¶ added in v1.43.0
func (m *MockExchangeOrderQueryService) QueryOrderTrades(arg0 context.Context, arg1 types.OrderQuery) ([]types.Trade, error)
QueryOrderTrades mocks base method.
type MockExchangeOrderQueryServiceMockRecorder ¶ added in v1.43.0
type MockExchangeOrderQueryServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockExchangeOrderQueryServiceMockRecorder is the mock recorder for MockExchangeOrderQueryService.
func (*MockExchangeOrderQueryServiceMockRecorder) QueryOrder ¶ added in v1.43.0
func (mr *MockExchangeOrderQueryServiceMockRecorder) QueryOrder(arg0, arg1 any) *gomock.Call
QueryOrder indicates an expected call of QueryOrder.
func (*MockExchangeOrderQueryServiceMockRecorder) QueryOrderTrades ¶ added in v1.43.0
func (mr *MockExchangeOrderQueryServiceMockRecorder) QueryOrderTrades(arg0, arg1 any) *gomock.Call
QueryOrderTrades indicates an expected call of QueryOrderTrades.
type MockExchangePublic ¶ added in v1.58.0
type MockExchangePublic struct {
// contains filtered or unexported fields
}
MockExchangePublic is a mock of ExchangePublic interface.
func NewMockExchangePublic ¶ added in v1.58.0
func NewMockExchangePublic(ctrl *gomock.Controller) *MockExchangePublic
NewMockExchangePublic creates a new mock instance.
func (*MockExchangePublic) EXPECT ¶ added in v1.58.0
func (m *MockExchangePublic) EXPECT() *MockExchangePublicMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockExchangePublic) Name ¶ added in v1.58.0
func (m *MockExchangePublic) Name() types.ExchangeName
Name mocks base method.
func (*MockExchangePublic) NewStream ¶ added in v1.58.0
func (m *MockExchangePublic) NewStream() types.Stream
NewStream mocks base method.
func (*MockExchangePublic) PlatformFeeCurrency ¶ added in v1.58.0
func (m *MockExchangePublic) PlatformFeeCurrency() string
PlatformFeeCurrency mocks base method.
func (*MockExchangePublic) QueryKLines ¶ added in v1.58.0
func (m *MockExchangePublic) QueryKLines(arg0 context.Context, arg1 string, arg2 types.Interval, arg3 types.KLineQueryOptions) ([]types.KLine, error)
QueryKLines mocks base method.
func (*MockExchangePublic) QueryMarkets ¶ added in v1.58.0
QueryMarkets mocks base method.
func (*MockExchangePublic) QueryTicker ¶ added in v1.58.0
QueryTicker mocks base method.
func (*MockExchangePublic) QueryTickers ¶ added in v1.58.0
func (m *MockExchangePublic) QueryTickers(arg0 context.Context, arg1 ...string) (map[string]types.Ticker, error)
QueryTickers mocks base method.
type MockExchangePublicMockRecorder ¶ added in v1.58.0
type MockExchangePublicMockRecorder struct {
// contains filtered or unexported fields
}
MockExchangePublicMockRecorder is the mock recorder for MockExchangePublic.
func (*MockExchangePublicMockRecorder) Name ¶ added in v1.58.0
func (mr *MockExchangePublicMockRecorder) Name() *gomock.Call
Name indicates an expected call of Name.
func (*MockExchangePublicMockRecorder) NewStream ¶ added in v1.58.0
func (mr *MockExchangePublicMockRecorder) NewStream() *gomock.Call
NewStream indicates an expected call of NewStream.
func (*MockExchangePublicMockRecorder) PlatformFeeCurrency ¶ added in v1.58.0
func (mr *MockExchangePublicMockRecorder) PlatformFeeCurrency() *gomock.Call
PlatformFeeCurrency indicates an expected call of PlatformFeeCurrency.
func (*MockExchangePublicMockRecorder) QueryKLines ¶ added in v1.58.0
func (mr *MockExchangePublicMockRecorder) QueryKLines(arg0, arg1, arg2, arg3 any) *gomock.Call
QueryKLines indicates an expected call of QueryKLines.
func (*MockExchangePublicMockRecorder) QueryMarkets ¶ added in v1.58.0
func (mr *MockExchangePublicMockRecorder) QueryMarkets(arg0 any) *gomock.Call
QueryMarkets indicates an expected call of QueryMarkets.
func (*MockExchangePublicMockRecorder) QueryTicker ¶ added in v1.58.0
func (mr *MockExchangePublicMockRecorder) QueryTicker(arg0, arg1 any) *gomock.Call
QueryTicker indicates an expected call of QueryTicker.
func (*MockExchangePublicMockRecorder) QueryTickers ¶ added in v1.58.0
func (mr *MockExchangePublicMockRecorder) QueryTickers(arg0 any, arg1 ...any) *gomock.Call
QueryTickers indicates an expected call of QueryTickers.
type MockExchangeTradeHistoryService ¶ added in v1.47.0
type MockExchangeTradeHistoryService struct {
// contains filtered or unexported fields
}
MockExchangeTradeHistoryService is a mock of ExchangeTradeHistoryService interface.
func NewMockExchangeTradeHistoryService ¶ added in v1.47.0
func NewMockExchangeTradeHistoryService(ctrl *gomock.Controller) *MockExchangeTradeHistoryService
NewMockExchangeTradeHistoryService creates a new mock instance.
func (*MockExchangeTradeHistoryService) EXPECT ¶ added in v1.47.0
func (m *MockExchangeTradeHistoryService) EXPECT() *MockExchangeTradeHistoryServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockExchangeTradeHistoryService) QueryClosedOrders ¶ added in v1.47.0
func (m *MockExchangeTradeHistoryService) QueryClosedOrders(arg0 context.Context, arg1 string, arg2, arg3 time.Time, arg4 uint64) ([]types.Order, error)
QueryClosedOrders mocks base method.
func (*MockExchangeTradeHistoryService) QueryTrades ¶ added in v1.47.0
func (m *MockExchangeTradeHistoryService) QueryTrades(arg0 context.Context, arg1 string, arg2 *types.TradeQueryOptions) ([]types.Trade, error)
QueryTrades mocks base method.
type MockExchangeTradeHistoryServiceMockRecorder ¶ added in v1.47.0
type MockExchangeTradeHistoryServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockExchangeTradeHistoryServiceMockRecorder is the mock recorder for MockExchangeTradeHistoryService.
func (*MockExchangeTradeHistoryServiceMockRecorder) QueryClosedOrders ¶ added in v1.47.0
func (mr *MockExchangeTradeHistoryServiceMockRecorder) QueryClosedOrders(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call
QueryClosedOrders indicates an expected call of QueryClosedOrders.
func (*MockExchangeTradeHistoryServiceMockRecorder) QueryTrades ¶ added in v1.47.0
func (mr *MockExchangeTradeHistoryServiceMockRecorder) QueryTrades(arg0, arg1, arg2 any) *gomock.Call
QueryTrades indicates an expected call of QueryTrades.
type MockStream ¶ added in v1.60.0
type MockStream struct {
// contains filtered or unexported fields
}
MockStream is a mock of Stream interface.
func NewMockStream ¶ added in v1.60.0
func NewMockStream(ctrl *gomock.Controller) *MockStream
NewMockStream creates a new mock instance.
func (*MockStream) Close ¶ added in v1.60.0
func (m *MockStream) Close() error
Close mocks base method.
func (*MockStream) Connect ¶ added in v1.60.0
func (m *MockStream) Connect(arg0 context.Context) error
Connect mocks base method.
func (*MockStream) EXPECT ¶ added in v1.60.0
func (m *MockStream) EXPECT() *MockStreamMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockStream) GetPublicOnly ¶ added in v1.60.0
func (m *MockStream) GetPublicOnly() bool
GetPublicOnly mocks base method.
func (*MockStream) GetSubscriptions ¶ added in v1.60.0
func (m *MockStream) GetSubscriptions() []types.Subscription
GetSubscriptions mocks base method.
func (*MockStream) OnAggTrade ¶ added in v1.60.0
func (m *MockStream) OnAggTrade(arg0 func(types.Trade))
OnAggTrade mocks base method.
func (*MockStream) OnAuth ¶ added in v1.60.0
func (m *MockStream) OnAuth(arg0 func())
OnAuth mocks base method.
func (*MockStream) OnBalanceSnapshot ¶ added in v1.60.0
func (m *MockStream) OnBalanceSnapshot(arg0 func(types.BalanceMap))
OnBalanceSnapshot mocks base method.
func (*MockStream) OnBalanceUpdate ¶ added in v1.60.0
func (m *MockStream) OnBalanceUpdate(arg0 func(types.BalanceMap))
OnBalanceUpdate mocks base method.
func (*MockStream) OnBookSnapshot ¶ added in v1.60.0
func (m *MockStream) OnBookSnapshot(arg0 func(types.SliceOrderBook))
OnBookSnapshot mocks base method.
func (*MockStream) OnBookTickerUpdate ¶ added in v1.60.0
func (m *MockStream) OnBookTickerUpdate(arg0 func(types.BookTicker))
OnBookTickerUpdate mocks base method.
func (*MockStream) OnBookUpdate ¶ added in v1.60.0
func (m *MockStream) OnBookUpdate(arg0 func(types.SliceOrderBook))
OnBookUpdate mocks base method.
func (*MockStream) OnConnect ¶ added in v1.60.0
func (m *MockStream) OnConnect(arg0 func())
OnConnect mocks base method.
func (*MockStream) OnDisconnect ¶ added in v1.60.0
func (m *MockStream) OnDisconnect(arg0 func())
OnDisconnect mocks base method.
func (*MockStream) OnForceOrder ¶ added in v1.60.0
func (m *MockStream) OnForceOrder(arg0 func(types.LiquidationInfo))
OnForceOrder mocks base method.
func (*MockStream) OnFuturesPositionSnapshot ¶ added in v1.60.0
func (m *MockStream) OnFuturesPositionSnapshot(arg0 func(types.FuturesPositionMap))
OnFuturesPositionSnapshot mocks base method.
func (*MockStream) OnFuturesPositionUpdate ¶ added in v1.60.0
func (m *MockStream) OnFuturesPositionUpdate(arg0 func(types.FuturesPositionMap))
OnFuturesPositionUpdate mocks base method.
func (*MockStream) OnKLine ¶ added in v1.60.0
func (m *MockStream) OnKLine(arg0 func(types.KLine))
OnKLine mocks base method.
func (*MockStream) OnKLineClosed ¶ added in v1.60.0
func (m *MockStream) OnKLineClosed(arg0 func(types.KLine))
OnKLineClosed mocks base method.
func (*MockStream) OnMarketTrade ¶ added in v1.60.0
func (m *MockStream) OnMarketTrade(arg0 func(types.Trade))
OnMarketTrade mocks base method.
func (*MockStream) OnOrderUpdate ¶ added in v1.60.0
func (m *MockStream) OnOrderUpdate(arg0 func(types.Order))
OnOrderUpdate mocks base method.
func (*MockStream) OnRawMessage ¶ added in v1.60.0
func (m *MockStream) OnRawMessage(arg0 func([]byte))
OnRawMessage mocks base method.
func (*MockStream) OnStart ¶ added in v1.60.0
func (m *MockStream) OnStart(arg0 func())
OnStart mocks base method.
func (*MockStream) OnTradeUpdate ¶ added in v1.60.0
func (m *MockStream) OnTradeUpdate(arg0 func(types.Trade))
OnTradeUpdate mocks base method.
func (*MockStream) Reconnect ¶ added in v1.60.0
func (m *MockStream) Reconnect()
Reconnect mocks base method.
func (*MockStream) Resubscribe ¶ added in v1.60.0
func (m *MockStream) Resubscribe(arg0 func([]types.Subscription) ([]types.Subscription, error)) error
Resubscribe mocks base method.
func (*MockStream) SetPublicOnly ¶ added in v1.60.0
func (m *MockStream) SetPublicOnly()
SetPublicOnly mocks base method.
func (*MockStream) Subscribe ¶ added in v1.60.0
func (m *MockStream) Subscribe(arg0 types.Channel, arg1 string, arg2 types.SubscribeOptions)
Subscribe mocks base method.
type MockStreamMockRecorder ¶ added in v1.60.0
type MockStreamMockRecorder struct {
// contains filtered or unexported fields
}
MockStreamMockRecorder is the mock recorder for MockStream.
func (*MockStreamMockRecorder) Close ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockStreamMockRecorder) Connect ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) Connect(arg0 any) *gomock.Call
Connect indicates an expected call of Connect.
func (*MockStreamMockRecorder) GetPublicOnly ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) GetPublicOnly() *gomock.Call
GetPublicOnly indicates an expected call of GetPublicOnly.
func (*MockStreamMockRecorder) GetSubscriptions ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) GetSubscriptions() *gomock.Call
GetSubscriptions indicates an expected call of GetSubscriptions.
func (*MockStreamMockRecorder) OnAggTrade ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnAggTrade(arg0 any) *gomock.Call
OnAggTrade indicates an expected call of OnAggTrade.
func (*MockStreamMockRecorder) OnAuth ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnAuth(arg0 any) *gomock.Call
OnAuth indicates an expected call of OnAuth.
func (*MockStreamMockRecorder) OnBalanceSnapshot ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnBalanceSnapshot(arg0 any) *gomock.Call
OnBalanceSnapshot indicates an expected call of OnBalanceSnapshot.
func (*MockStreamMockRecorder) OnBalanceUpdate ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnBalanceUpdate(arg0 any) *gomock.Call
OnBalanceUpdate indicates an expected call of OnBalanceUpdate.
func (*MockStreamMockRecorder) OnBookSnapshot ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnBookSnapshot(arg0 any) *gomock.Call
OnBookSnapshot indicates an expected call of OnBookSnapshot.
func (*MockStreamMockRecorder) OnBookTickerUpdate ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnBookTickerUpdate(arg0 any) *gomock.Call
OnBookTickerUpdate indicates an expected call of OnBookTickerUpdate.
func (*MockStreamMockRecorder) OnBookUpdate ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnBookUpdate(arg0 any) *gomock.Call
OnBookUpdate indicates an expected call of OnBookUpdate.
func (*MockStreamMockRecorder) OnConnect ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnConnect(arg0 any) *gomock.Call
OnConnect indicates an expected call of OnConnect.
func (*MockStreamMockRecorder) OnDisconnect ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnDisconnect(arg0 any) *gomock.Call
OnDisconnect indicates an expected call of OnDisconnect.
func (*MockStreamMockRecorder) OnForceOrder ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnForceOrder(arg0 any) *gomock.Call
OnForceOrder indicates an expected call of OnForceOrder.
func (*MockStreamMockRecorder) OnFuturesPositionSnapshot ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnFuturesPositionSnapshot(arg0 any) *gomock.Call
OnFuturesPositionSnapshot indicates an expected call of OnFuturesPositionSnapshot.
func (*MockStreamMockRecorder) OnFuturesPositionUpdate ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnFuturesPositionUpdate(arg0 any) *gomock.Call
OnFuturesPositionUpdate indicates an expected call of OnFuturesPositionUpdate.
func (*MockStreamMockRecorder) OnKLine ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnKLine(arg0 any) *gomock.Call
OnKLine indicates an expected call of OnKLine.
func (*MockStreamMockRecorder) OnKLineClosed ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnKLineClosed(arg0 any) *gomock.Call
OnKLineClosed indicates an expected call of OnKLineClosed.
func (*MockStreamMockRecorder) OnMarketTrade ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnMarketTrade(arg0 any) *gomock.Call
OnMarketTrade indicates an expected call of OnMarketTrade.
func (*MockStreamMockRecorder) OnOrderUpdate ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnOrderUpdate(arg0 any) *gomock.Call
OnOrderUpdate indicates an expected call of OnOrderUpdate.
func (*MockStreamMockRecorder) OnRawMessage ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnRawMessage(arg0 any) *gomock.Call
OnRawMessage indicates an expected call of OnRawMessage.
func (*MockStreamMockRecorder) OnStart ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnStart(arg0 any) *gomock.Call
OnStart indicates an expected call of OnStart.
func (*MockStreamMockRecorder) OnTradeUpdate ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) OnTradeUpdate(arg0 any) *gomock.Call
OnTradeUpdate indicates an expected call of OnTradeUpdate.
func (*MockStreamMockRecorder) Reconnect ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) Reconnect() *gomock.Call
Reconnect indicates an expected call of Reconnect.
func (*MockStreamMockRecorder) Resubscribe ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) Resubscribe(arg0 any) *gomock.Call
Resubscribe indicates an expected call of Resubscribe.
func (*MockStreamMockRecorder) SetPublicOnly ¶ added in v1.60.0
func (mr *MockStreamMockRecorder) SetPublicOnly() *gomock.Call
SetPublicOnly indicates an expected call of SetPublicOnly.