Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddressSplitterConsumer ¶
type AddressSplitterConsumer struct {
// contains filtered or unexported fields
}
AddressSplitterConsumer relays orders to different channels based on the exchange specified in the order.
func NewExchangeSplitterConsumer ¶
func NewExchangeSplitterConsumer(translator channels.URITranslator, suffix string, concurrency int) *AddressSplitterConsumer
func NewMakerSplitterConsumer ¶
func NewMakerSplitterConsumer(translator channels.URITranslator, suffix string, concurrency int) *AddressSplitterConsumer
func (*AddressSplitterConsumer) Consume ¶
func (consumer *AddressSplitterConsumer) Consume(delivery channels.Delivery)
Source Files
Click to show internal directories.
Click to hide internal directories.