order_watch

Mar 31, 2023

Changes in this version

+ type Direction string

+ type Msg struct

+ CurrentPrice float64

+ func (msg Msg) String() string

+ type OrderWatchConfig struct

+ MinAmount float64

+ func DefaultConfig() OrderWatchConfig

+ func (cfg OrderWatchConfig) IsValid() (bool, error)

+ type OrderWatchProcessor struct

+ func NewOrderWatchProcessor(cfg OrderWatchConfig, tikiClient *tiki.TikiClient, db *store.Store, ...) (*OrderWatchProcessor, error)

+ func (p *OrderWatchProcessor) Process(ctx context.Context, order *tiki.Order) error

+ func (p *OrderWatchProcessor) Queue(msg interface{})

+ func (p *OrderWatchProcessor) Start(ctx context.Context)