funds

Documentation

Index

• type CancellationConsumer
  • func NewCancellationConsumer(allPublisher channels.Publisher, changePublisher channels.Publisher, ...) CancellationConsumer
  • func (consumer *CancellationConsumer) Consume(msg channels.Delivery)
• type CancellationLookup
  • func NewDBCancellationLookup(db *gorm.DB) CancellationLookup
  • func NewMockCancellationLookup(cancelled bool) CancellationLookup
• type FillConsumer
  • func NewFillConsumer(allPublisher channels.Publisher, changePublisher channels.Publisher, ...) FillConsumer
  • func (consumer *FillConsumer) Consume(msg channels.Delivery)
• type FilledLookup
  • func NewMockFilledLookup(cancelled bool, filled string, err error) FilledLookup
  • func NewRPCFilledLookup(rpcURL string, fillBloom *fillbloom.FillBloom) (FilledLookup, error)
• type MockCancellationLookup
  • func (filled *MockCancellationLookup) GetCancelled(order *types.Order) (bool, error)
• type MockFilledLookup
  • func (filled *MockFilledLookup) GetAmountFilled(order *types.Order) (*types.Uint256, error)
  • func (filled *MockFilledLookup) GetCancelled(order *types.Order) (bool, error)
• type OrderValidator
  • func NewOrderValidator(checker balance.BalanceChecker, feeToken config.FeeToken, ...) OrderValidator
  • func NewRpcOrderValidator(rpcUrl string, feeToken config.FeeToken, tokenProxy config.TokenProxy, ...) (OrderValidator, error)

Types

type CancellationConsumer

type CancellationConsumer struct {
	// contains filtered or unexported fields
}

func NewCancellationConsumer

func NewCancellationConsumer(allPublisher channels.Publisher, changePublisher channels.Publisher, lookup CancellationLookup, concurrency int) CancellationConsumer

func (*CancellationConsumer) Consume

func (consumer *CancellationConsumer) Consume(msg channels.Delivery)

type CancellationLookup

type CancellationLookup interface {
	GetCancelled(order *types.Order) (bool, error)
}

func NewDBCancellationLookup

func NewDBCancellationLookup(db *gorm.DB) CancellationLookup

func NewMockCancellationLookup

func NewMockCancellationLookup(cancelled bool) CancellationLookup

type FillConsumer

type FillConsumer struct {
	// contains filtered or unexported fields
}

func NewFillConsumer

func NewFillConsumer(allPublisher channels.Publisher, changePublisher channels.Publisher, lookup FilledLookup, concurrency int) FillConsumer

func (*FillConsumer) Consume

func (consumer *FillConsumer) Consume(msg channels.Delivery)

type FilledLookup

type FilledLookup interface {
	GetCancelled(order *types.Order) (bool, error)
	GetAmountFilled(order *types.Order) (*types.Uint256, error)
}

func NewMockFilledLookup

func NewMockFilledLookup(cancelled bool, filled string, err error) FilledLookup

func NewRPCFilledLookup

func NewRPCFilledLookup(rpcURL string, fillBloom *fillbloom.FillBloom) (FilledLookup, error)

type MockCancellationLookup

type MockCancellationLookup struct {
	// contains filtered or unexported fields
}

func (*MockCancellationLookup) GetCancelled

func (filled *MockCancellationLookup) GetCancelled(order *types.Order) (bool, error)

type MockFilledLookup

type MockFilledLookup struct {
	// contains filtered or unexported fields
}

func (*MockFilledLookup) GetAmountFilled

func (filled *MockFilledLookup) GetAmountFilled(order *types.Order) (*types.Uint256, error)

func (*MockFilledLookup) GetCancelled

func (filled *MockFilledLookup) GetCancelled(order *types.Order) (bool, error)

type OrderValidator

type OrderValidator interface {
	ValidateOrder(order *types.Order) (bool, error)
}

func NewOrderValidator

func NewOrderValidator(checker balance.BalanceChecker, feeToken config.FeeToken, tokenProxy config.TokenProxy) OrderValidator

func NewRpcOrderValidator

func NewRpcOrderValidator(rpcUrl string, feeToken config.FeeToken, tokenProxy config.TokenProxy, invalidationChannel channels.ConsumerChannel) (OrderValidator, error)