appsetup

Documentation

Index

• func NewKrakenOrderBookSubscriber(ctx context.Context, logger *zap.SugaredLogger, ...) (subscribers.KrakenOrderBookSubscriber, error)
• func NewKrakenTradingPairSubscriber(ctx context.Context, logger *zap.SugaredLogger, ...) (subscribers.KrakenTradingPairSubscriber, error)
• func NewSyntheticOrderConsumer(logger *zap.SugaredLogger, pulsarClient pulsar.PulsarClient, ...) (syntheticorderv1.Consumer, error)

Functions

func NewKrakenOrderBookSubscriber

func NewKrakenOrderBookSubscriber(ctx context.Context, logger *zap.SugaredLogger, pulsarClient pulsar.PulsarClient, appConfig configuration.AppConfig, venueConfig configuration2.KrakenConfig, pulsarConfig pulsar.PulsarConfig, postgresConfig postgres.PostgresConfig, topic string) (subscribers.KrakenOrderBookSubscriber, error)

func NewKrakenTradingPairSubscriber

func NewKrakenTradingPairSubscriber(ctx context.Context, logger *zap.SugaredLogger, venueConfig configuration2.KrakenConfig, jobScheduler *gocron.Scheduler, postgresConfig postgres.PostgresConfig) (subscribers.KrakenTradingPairSubscriber, error)

func NewSyntheticOrderConsumer

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