subscribers

Documentation

Index

• type CoingeckoCoinSubscriber
  • func NewCoingeckoCoinSubscriber(ctx context.Context, logger *zap.SugaredLogger, jobScheduler *gocron.Scheduler, ...) (CoingeckoCoinSubscriber, error)
• type CoingeckoExchangeSubscriber
  • func NewCoingeckoExchangeSubscriber(ctx context.Context, logger *zap.SugaredLogger, jobScheduler *gocron.Scheduler, ...) (CoingeckoExchangeSubscriber, error)

Types

type CoingeckoCoinSubscriber

type CoingeckoCoinSubscriber interface {
}

func NewCoingeckoCoinSubscriber

func NewCoingeckoCoinSubscriber(
	ctx context.Context,
	logger *zap.SugaredLogger,
	jobScheduler *gocron.Scheduler,
	coingeckoConfig configuration.CoingeckoConfig,
	exchanges map[string]configuration.Exchange,
	entgoClient entities.EntgoClient,
	currencyRepository repositories.CurrencyRepository) (CoingeckoCoinSubscriber, error)

type CoingeckoExchangeSubscriber

type CoingeckoExchangeSubscriber interface {
}

func NewCoingeckoExchangeSubscriber

func NewCoingeckoExchangeSubscriber(
	ctx context.Context,
	logger *zap.SugaredLogger,
	jobScheduler *gocron.Scheduler,
	coingeckoConfig configuration.CoingeckoConfig,
	exchanges map[string]configuration.Exchange,
	entgoClient entities.EntgoClient,
	timeHelper timeex.TimeHelper,
	venueRepository repositories.VenueRepository) (CoingeckoExchangeSubscriber, error)