jobs

Documentation

Index

• type Jobs
  • func New(logger *logger.Logger, binance *binance.Binance, notify *telegram.TelegramBot, ...) *Jobs
  • func (s *Jobs) Analyzing(ctx context.Context, data interface{}) error
  • func (s *Jobs) Consuming() error
  • func (s *Jobs) Crawling() error
  • func (s *Jobs) Notifying() error
  • func (s *Jobs) Producing()
  • func (s *Jobs) Retrying()

Types

type Jobs

type Jobs struct {
	// contains filtered or unexported fields
}

func New

func New(
	logger *logger.Logger,
	binance *binance.Binance,
	notify *telegram.TelegramBot,
	worker *worker.Worker,
	cache cache.Basic,
	marketCache cache.Market,
	exchangeCache cache.Exchange,
	quitChannel chan struct{},
) *Jobs

func (*Jobs) Analyzing

func (s *Jobs) Analyzing(ctx context.Context, data interface{}) error

func (*Jobs) Consuming

func (s *Jobs) Consuming() error

func (*Jobs) Crawling

func (s *Jobs) Crawling() error

func (*Jobs) Notifying

func (s *Jobs) Notifying() error

func (*Jobs) Producing

func (s *Jobs) Producing()

func (*Jobs) Retrying

func (s *Jobs) Retrying()