Documentation
¶
Index ¶
- func Initialize(brokers []string)
- func NotifyAccountBalanceUpdate(event *libTypes.BalanceUpdateEvent) error
- func NotifyCutoff(evt *libTypes.CutoffEvent) error
- func NotifyCutoffPair(evt *libTypes.CutoffPairEvent) error
- func NotifyOrderFilled(f *dao.FillEvent) error
- func NotifyOrderUpdate(o *libTypes.OrderState) error
- func NotifyRingMined(event *libTypes.RingMinedEvent) error
- func NotifyTransactionView(tx *types.TransactionView) error
- func ProducerNormalMessage(topic string, data interface{}) error
- func ProducerSocketIOMessage(eventKey string, data interface{}) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Initialize ¶
func Initialize(brokers []string)
func NotifyAccountBalanceUpdate ¶
func NotifyAccountBalanceUpdate(event *libTypes.BalanceUpdateEvent) error
func NotifyCutoff ¶
func NotifyCutoff(evt *libTypes.CutoffEvent) error
func NotifyCutoffPair ¶
func NotifyCutoffPair(evt *libTypes.CutoffPairEvent) error
func NotifyOrderFilled ¶
func NotifyOrderUpdate ¶
func NotifyOrderUpdate(o *libTypes.OrderState) error
func NotifyRingMined ¶
func NotifyRingMined(event *libTypes.RingMinedEvent) error
func NotifyTransactionView ¶
func NotifyTransactionView(tx *types.TransactionView) error
func ProducerNormalMessage ¶
func ProducerSocketIOMessage ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.