subscribers

Documentation

Index

• func NewSyntheticOrderSubscriber(logger *zap.SugaredLogger) (syntheticorderv1.Subscriber, error)
• type BinanceOrderBookSubscriber
  • func NewBinanceOrderBookSubscriber(ctx context.Context, logger *zap.SugaredLogger, ...) (BinanceOrderBookSubscriber, error)
• type BinanceTradingPairSubscriber
  • func NewBinanceTradingPairSubscriber(ctx context.Context, logger *zap.SugaredLogger, ...) (BinanceTradingPairSubscriber, error)

Functions

func NewSyntheticOrderSubscriber

func NewSyntheticOrderSubscriber(logger *zap.SugaredLogger) (syntheticorderv1.Subscriber, error)

Types

type BinanceOrderBookSubscriber

type BinanceOrderBookSubscriber interface {
	Close()
}

func NewBinanceOrderBookSubscriber

func NewBinanceOrderBookSubscriber(
	ctx context.Context,
	logger *zap.SugaredLogger,
	pairConfig configuration.PairConfig,
	orderBookPublisher publishers.OrderBookPublisher,
	coinHelper services.CurrencyHelper) (BinanceOrderBookSubscriber, error)

type BinanceTradingPairSubscriber

type BinanceTradingPairSubscriber interface {
}

func NewBinanceTradingPairSubscriber

func NewBinanceTradingPairSubscriber(
	ctx context.Context,
	logger *zap.SugaredLogger,
	venueConfig configuration.BinanceConfig,
	jobScheduler *gocron.Scheduler,
	tradingPairRepository repositories.TradingPairRepository) (BinanceTradingPairSubscriber, error)