appsetup

Documentation

Index

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

Functions

func NewDextradeTradingPairSubscriber

func NewDextradeTradingPairSubscriber(ctx context.Context, logger *zap.SugaredLogger, venueConfig configuration.DextradeConfig, jobScheduler *gocron.Scheduler, postgresConfig postgres.PostgresConfig) (subscribers.DextradeTradingPairSubscriber, error)

func NewSyntheticOrderConsumer

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