jobs

package
v0.0.0-...-4058e4e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 16, 2023 License: Unlicense Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL