tiki_exchange

Documentation

Index

• func NewProcessors(cfg TikiProcessorConfig, tikiClient *tiki.TikiClient, db *store.Store, ...) ([]processorCommon.Processor, error)
• type TikiProcessorConfig
  • func DefaultConfig() TikiProcessorConfig
  • func (cfg TikiProcessorConfig) IsValid() (bool, error)

Functions

func NewProcessors

func NewProcessors(cfg TikiProcessorConfig,
	tikiClient *tiki.TikiClient,
	db *store.Store,
	log logger.Logger,
) ([]processorCommon.Processor, error)

Types

type TikiProcessorConfig

type TikiProcessorConfig struct {
	OrderWatch  order_watch.OrderWatchConfig   `json:"OrderWatch"`
	VolumeWatch volume_watch.VolumeWatchConfig `json:"VolumeWatch"`
}

func DefaultConfig

func DefaultConfig() TikiProcessorConfig

func (TikiProcessorConfig) IsValid

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