stoporders

Documentation

Index

• Variables
• type Pool
  • func New(log *logging.Logger) *Pool
  • func NewFromProto(log *logging.Logger, p *v1.StopOrders) *Pool
  • func (p *Pool) Cancel(partyID string, orderID string) ([]*types.StopOrder, error)
  • func (p *Pool) CheckDirection(positions *positions.SnapshotEngine) []*types.StopOrder
  • func (p *Pool) CountForParty(party string) uint64
  • func (p *Pool) GetStopOrderCount() uint64
  • func (p *Pool) Insert(order *types.StopOrder)
  • func (p *Pool) PriceUpdated(newPrice *num.Uint) (triggered, cancelled []*types.StopOrder)
  • func (p *Pool) RemoveExpired(orderIDs []string) []*types.StopOrder
  • func (p *Pool) Settled() []*types.StopOrder
  • func (p *Pool) ToProto() *v1.StopOrders
• type PricedStopOrders
  • func NewPricedStopOrders() *PricedStopOrders
  • func NewPricedStopOrdersFromProto(p *v1.PricedStopOrders) *PricedStopOrders
  • func (p *PricedStopOrders) DumpFallsBelow() string
  • func (p *PricedStopOrders) DumpRisesAbove() string
  • func (p *PricedStopOrders) Insert(id string, price *num.Uint, direction types.StopOrderTriggerDirection)
  • func (p *PricedStopOrders) PriceUpdated(newPrice *num.Uint) []string
  • func (p *PricedStopOrders) Remove(id string) error
  • func (p *PricedStopOrders) ToProto() *v1.PricedStopOrders
• type TrailingStopOrders
  • func NewTrailingStopOrders() *TrailingStopOrders
  • func NewTrailingStopOrdersFromProto(p *v1.TrailingStopOrders) *TrailingStopOrders
  • func (p *TrailingStopOrders) DumpFallsBelow() string
  • func (p *TrailingStopOrders) DumpRisesAbove() string
  • func (p *TrailingStopOrders) Insert(id string, offset num.Decimal, direction types.StopOrderTriggerDirection)
  • func (p *TrailingStopOrders) PriceUpdated(newPrice *num.Uint) []string
  • func (p *TrailingStopOrders) Remove(id string) error
  • func (p *TrailingStopOrders) ToProto() *v1.TrailingStopOrders

Variables

var (
	ErrNoPriceToOffset   = errors.New("no price to offset")
	ErrStopOrderNotFound = errors.New("stop order not found")
	ErrPriceNotFound     = errors.New("price not found")
	ErrOrderNotFound     = errors.New("order not found")
)

Types

type Pool

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

func New

func New(log *logging.Logger) *Pool

func NewFromProto

func NewFromProto(log *logging.Logger, p *v1.StopOrders) *Pool

func (*Pool) Cancel

func (p *Pool) Cancel(
	partyID string,
	orderID string,
) ([]*types.StopOrder, error)

func (*Pool) CheckDirection

func (p *Pool) CheckDirection(positions *positions.SnapshotEngine) []*types.StopOrder

func (*Pool) CountForParty

func (p *Pool) CountForParty(party string) uint64

func (*Pool) GetStopOrderCount

func (p *Pool) GetStopOrderCount() uint64

func (*Pool) Insert

func (p *Pool) Insert(order *types.StopOrder)

func (*Pool) PriceUpdated

func (p *Pool) PriceUpdated(newPrice *num.Uint) (triggered, cancelled []*types.StopOrder)

func (*Pool) RemoveExpired

func (p *Pool) RemoveExpired(orderIDs []string) []*types.StopOrder

func (*Pool) Settled

func (p *Pool) Settled() []*types.StopOrder

func (*Pool) ToProto

func (p *Pool) ToProto() *v1.StopOrders

type PricedStopOrders

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

func NewPricedStopOrders

func NewPricedStopOrders() *PricedStopOrders

func NewPricedStopOrdersFromProto

func NewPricedStopOrdersFromProto(p *v1.PricedStopOrders) *PricedStopOrders

func (*PricedStopOrders) DumpFallsBelow

func (p *PricedStopOrders) DumpFallsBelow() string

func (*PricedStopOrders) DumpRisesAbove

func (p *PricedStopOrders) DumpRisesAbove() string

func (*PricedStopOrders) Insert

func (p *PricedStopOrders) Insert(
	id string, price *num.Uint, direction types.StopOrderTriggerDirection,
)

func (*PricedStopOrders) PriceUpdated

func (p *PricedStopOrders) PriceUpdated(newPrice *num.Uint) []string

func (*PricedStopOrders) Remove

func (p *PricedStopOrders) Remove(id string) error

func (*PricedStopOrders) ToProto

func (p *PricedStopOrders) ToProto() *v1.PricedStopOrders

type TrailingStopOrders

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

func NewTrailingStopOrders

func NewTrailingStopOrders() *TrailingStopOrders

func NewTrailingStopOrdersFromProto

func NewTrailingStopOrdersFromProto(p *v1.TrailingStopOrders) *TrailingStopOrders

func (*TrailingStopOrders) DumpFallsBelow

func (p *TrailingStopOrders) DumpFallsBelow() string

func (*TrailingStopOrders) DumpRisesAbove

func (p *TrailingStopOrders) DumpRisesAbove() string

func (*TrailingStopOrders) Insert

func (p *TrailingStopOrders) Insert(
	id string, offset num.Decimal, direction types.StopOrderTriggerDirection,
)

func (*TrailingStopOrders) PriceUpdated

func (p *TrailingStopOrders) PriceUpdated(newPrice *num.Uint) []string

func (*TrailingStopOrders) Remove

func (p *TrailingStopOrders) Remove(id string) error

func (*TrailingStopOrders) ToProto

func (p *TrailingStopOrders) ToProto() *v1.TrailingStopOrders