market

Documentation

Index

• type KlinePublisher
• type Service
  • func (s *Service) Serv(ctx context.Context) error
• type Strategy
• type TickerPublisher

Types

type KlinePublisher

type KlinePublisher interface {
	Publish() chan struct{}
	Subscribe() kline.Subscriber
}

type Service

type Service struct {
	Logger          *zap.Logger
	Strategy        Strategy
	TickerPublisher TickerPublisher
	KlinePublisher  KlinePublisher
}

func (*Service) Serv

func (s *Service) Serv(ctx context.Context) error

type Strategy

type Strategy interface {
	OnTickerUpdate(*indicator.Ticker) bool
	OnKlineUpdate([]*indicator.Kline)
	OnNotice()
}

type TickerPublisher

type TickerPublisher interface {
	Publish() error
	Subscribe() ticker.Subscriber
}