appsetup

Documentation

Index

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

Functions

func NewMexcTradingPairSubscriber

func NewMexcTradingPairSubscriber(ctx context.Context, logger *zap.SugaredLogger, venueConfig configuration.MexcConfig, jobScheduler *gocron.Scheduler, postgresConfig postgres.PostgresConfig) (subscribers.MexcTradingPairSubscriber, error)

func NewSyntheticOrderConsumer

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