Documentation ¶
Index ¶
- func NewCoingeckoCoinSubscriber(ctx context.Context, logger *zap.SugaredLogger, jobScheduler *gocron.Scheduler, ...) (subscribers.CoingeckoCoinSubscriber, error)
- func NewCoingeckoExchangeSubscriber(ctx context.Context, logger *zap.SugaredLogger, jobScheduler *gocron.Scheduler, ...) (subscribers.CoingeckoExchangeSubscriber, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCoingeckoCoinSubscriber ¶
func NewCoingeckoCoinSubscriber(ctx context.Context, logger *zap.SugaredLogger, jobScheduler *gocron.Scheduler, coingeckoConfig configuration.CoingeckoConfig, exchanges map[string]configuration.Exchange, postgresConfig postgres.PostgresConfig) (subscribers.CoingeckoCoinSubscriber, error)
func NewCoingeckoExchangeSubscriber ¶
func NewCoingeckoExchangeSubscriber(ctx context.Context, logger *zap.SugaredLogger, jobScheduler *gocron.Scheduler, coingeckoConfig configuration.CoingeckoConfig, exchanges map[string]configuration.Exchange, postgresConfig postgres.PostgresConfig) (subscribers.CoingeckoExchangeSubscriber, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.