order_watch

Documentation

Index

• type Direction
• type Msg
  • func (msg Msg) String() string
• type OrderWatchConfig
  • func DefaultConfig() OrderWatchConfig
  • func (cfg OrderWatchConfig) IsValid() (bool, error)
• type OrderWatchProcessor
  • 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)

Types

type Direction

type Direction string

type Msg

type Msg struct {
	tiki.Order
	CurrentPrice float64
}

func (Msg) String

func (msg Msg) String() string

type OrderWatchConfig

type OrderWatchConfig struct {
	common.BaseConfig
	MinAmount float64
}

func DefaultConfig

func DefaultConfig() OrderWatchConfig

func (OrderWatchConfig) IsValid

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

type OrderWatchProcessor

type OrderWatchProcessor struct {
	*processorCommon.BaseProcessor
	*tiki.TikiClient
	// contains filtered or unexported fields
}

func NewOrderWatchProcessor

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

func (*OrderWatchProcessor) Process

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

func (*OrderWatchProcessor) Queue

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

func (*OrderWatchProcessor) Start

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