Documentation ¶
Index ¶
- func NewBinanceOrderBookSubscriber(ctx context.Context, logger *zap.SugaredLogger, ...) (subscribers.BinanceOrderBookSubscriber, error)
- func NewBinanceTradingPairSubscriber(ctx context.Context, logger *zap.SugaredLogger, ...) (subscribers.BinanceTradingPairSubscriber, error)
- func NewSyntheticOrderConsumer(logger *zap.SugaredLogger, pulsarClient pulsar.PulsarClient, ...) (syntheticorderv1.Consumer, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBinanceOrderBookSubscriber ¶
func NewBinanceOrderBookSubscriber(ctx context.Context, logger *zap.SugaredLogger, pulsarClient pulsar.PulsarClient, appConfig configuration.AppConfig, binanceConfig configuration2.BinanceConfig, pairConfig configuration2.PairConfig, pulsarConfig pulsar.PulsarConfig, postgresConfig postgres.PostgresConfig, topic string) (subscribers.BinanceOrderBookSubscriber, error)
func NewBinanceTradingPairSubscriber ¶
func NewBinanceTradingPairSubscriber(ctx context.Context, logger *zap.SugaredLogger, venueConfig configuration2.BinanceConfig, jobScheduler *gocron.Scheduler, postgresConfig postgres.PostgresConfig) (subscribers.BinanceTradingPairSubscriber, error)
func NewSyntheticOrderConsumer ¶
func NewSyntheticOrderConsumer(logger *zap.SugaredLogger, pulsarClient pulsar.PulsarClient, pulsarConfig pulsar.PulsarConfig) (syntheticorderv1.Consumer, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.