strategy

package
v0.0.0-...-abc9c84 Latest Latest
Warning

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

Go to latest
Published: Apr 9, 2024 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Arbitrage

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

func NewArbitrage

func NewArbitrage(
	cfg *conf.Bot,
	storage *storage.Storage,
	conversion *service.Conversion,
	arbTSvc *arbitrage.Tg,
	wsSvc *service.WS,
	wsEventBroker *broker.Broker,
	accEventBroker *broker.Broker,
	orderSvc *service.Order,
	sessSvc *spreadSvc.Session,
	balanceSvc *service.Balance,
	logger *zerolog.Logger,
) (*Arbitrage, error)

func (*Arbitrage) GetPairsList

func (s *Arbitrage) GetPairsList() map[string]bool

func (*Arbitrage) Start

func (s *Arbitrage) Start(ctx context.Context, g *errgroup.Group) error

type Buy

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

func NewBuy

func NewBuy(
	cfg *conf.Bot,
	storage *storage.Storage,
	wsEventBroker *broker.Broker,
	accEventBroker *broker.Broker,
	conversion *service.Conversion,
	tgSvc *service.Telegram,
	wsSvc *service.WS,
	pair *storage.Pair,
	orderBook *storage.Book,
	orderSvc *service.Order,
	sessSvc *buySvc.Session,
	logger *zerolog.Logger,
) (*Buy, error)

func (*Buy) CreateSession

func (s *Buy) CreateSession(ctx context.Context, g *errgroup.Group) error

func (*Buy) Start

func (s *Buy) Start(ctx context.Context, g *errgroup.Group) error

type Spread

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

func NewSpread

func NewSpread(
	cfg *conf.Bot,
	storage *storage.Storage,
	wsEventBroker *broker.Broker,
	conversion *service.Conversion,
	wsSvc *service.WS,
	pair *storage.Pair,
	orderBook *storage.Book,
	orderSvc *service.Order,
	watchSvc *spreadSvc.Watch,
	deciderSvc *spreadSvc.Decider,
	spreadOrderSvc *spreadSvc.Order,
	tgSvc *spreadSvc.Tg,
	forceCheckBroker *broker.Broker,
	logger *zerolog.Logger,
) (*Spread, error)

func (*Spread) CreateSession

func (s *Spread) CreateSession(ctx context.Context, g *errgroup.Group) error

func (*Spread) Start

func (s *Spread) Start(ctx context.Context, g *errgroup.Group) error

Jump to

Keyboard shortcuts

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