appsetup

Documentation

Index

• func NewBittrexTradingPairSubscriber(ctx context.Context, logger *zap.SugaredLogger, ...) (subscribers.BittrexTradingPairSubscriber, error)
• func NewSyntheticOrderConsumer(logger *zap.SugaredLogger, pulsarClient pulsar.PulsarClient, ...) (syntheticorderv1.Consumer, error)

Functions

func NewBittrexTradingPairSubscriber

func NewBittrexTradingPairSubscriber(ctx context.Context, logger *zap.SugaredLogger, venueConfig configuration.BittrexConfig, jobScheduler *gocron.Scheduler, postgresConfig postgres.PostgresConfig) (subscribers.BittrexTradingPairSubscriber, error)

func NewSyntheticOrderConsumer

func NewSyntheticOrderConsumer(logger *zap.SugaredLogger, pulsarClient pulsar.PulsarClient, pulsarConfig pulsar.PulsarConfig) (syntheticorderv1.Consumer, error)