splitter

Documentation

Index

• type AddressSplitterConsumer
  • func NewExchangeSplitterConsumer(exchanges map[types.Address]channels.Publisher, ...) *AddressSplitterConsumer
  • func NewMakerSplitterConsumer(exchanges map[types.Address]channels.Publisher, ...) *AddressSplitterConsumer
  • func (consumer *AddressSplitterConsumer) Consume(delivery channels.Delivery)

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(exchanges map[types.Address]channels.Publisher, defaultPublisher channels.Publisher, concurrency int) *AddressSplitterConsumer

func NewMakerSplitterConsumer

func NewMakerSplitterConsumer(exchanges map[types.Address]channels.Publisher, defaultPublisher channels.Publisher, concurrency int) *AddressSplitterConsumer

func (*AddressSplitterConsumer) Consume

func (consumer *AddressSplitterConsumer) Consume(delivery channels.Delivery)