streaming

type AuthenticationError struct{}

type Available struct {
	Prices  ByPrice
	Reverse bool
}

type AvailableInterface interface {
	Clear()
	Sort()
	UpdatePrice(int, []float64)
	AppendPrice([]float64)
	RemovePrice(int)
	Update([][]float64)
}

type AvailablePosition struct {
	Prices  ByPosition
	Reverse bool
}

type ByPosition []PositionPriceSize

type ByPrice []PriceSize

type CachedMarkets map[string]*MarketCache

type CachedOrders map[string]*OrderBookCache

type ConnectionError struct{}

type EndpointError struct{}

type ExchangePrices struct {
	BestAvailableToBack PositionPriceSize
	BestAvailableToLay  PositionPriceSize
	AvailableToBack     PriceSize
	AvailableToLay      PriceSize
	TradedVolume        PriceSize
}

type IMarketHandler interface {
	OnSubscribe(ChangeMessage models.MarketChangeMessage)
	OnResubscribe(ChangeMessage models.MarketChangeMessage)
	OnHeartbeat(ChangeMessage models.MarketChangeMessage)
	OnUpdate(ChangeMessage models.MarketChangeMessage)
}

type IOrderHandler interface {
	OnSubscribe(ChangeMessage models.OrderChangeMessage)
	OnResubscribe(ChangeMessage models.OrderChangeMessage)
	OnHeartbeat(ChangeMessage models.OrderChangeMessage)
	OnUpdate(ChangeMessage models.OrderChangeMessage)
}

type MarketBook struct {
	PublishTime           int64
	MarketID              string
	Status                string
	BetDelay              int32
	BspReconciled         bool
	Complete              bool
	InPlay                bool
	NumberOfWinners       int32
	NumberOfRunners       int
	NumberOfActiveRunners int32
	TotalMatched          float64
	CrossMatching         bool
	RunnersVoidable       bool
	Version               int64
	Runners               []Runner
}

type MarketCache struct {
	PublishTime      *int64
	MarketID         string
	TradedVolume     *float64
	MarketDefinition *models.MarketDefinition
	Runners          map[int64]RunnerCache
}

type MarketDataFilterFlag string

type MarketSubscriptionResponse struct {
	SubscribedMarketIDs []string
}

type NoConnectionError struct{}

type OrderBookCache struct {
	MarketID        string
	LastPublishTime int64
	Runners         map[int64]*models.OrderRunnerChange
	Closed          bool
}

type PositionPriceSize struct {
	Position float64
	Price    float64
	Size     float64
}

type PriceSize struct {
	Price float64
	Size  float64
}

type Runner struct {
	SelectionID      int64
	Handicap         float64
	Status           string
	AdjustmentFactor float64
	LastPriceTraded  float64
	TotalMatched     float64
	RemovalDate      strfmt.DateTime
	EX               ExchangePrices
}

type RunnerCache struct {
	SelectionId                int64
	LastTradedPrice            *float64
	TradedVolume               *float64
	StartingPriceNear          *float64
	StartingPriceFar           *float64
	Traded                     *Available
	AvailableToBack            *Available
	AvailableToLay             *Available
	StartingPriceBack          *Available
	StartingPriceLay           *Available
	BestAvailableToBack        *AvailablePosition
	BestAvailableToLay         *AvailablePosition
	BestDisplayAvailableToBack *AvailablePosition
	BestDisplayAvailableToLay  *AvailablePosition
}

type Stream struct {
	MarketCache CachedMarkets
	OrderCache  CachedOrders
	Channels    *StreamChannels
	// contains filtered or unexported fields
}

type StreamChannels struct {

	// Incoming Responses
	Err          chan error
	MarketUpdate chan MarketBook
	OrderUpdate  chan OrderBookCache
	Status       chan models.StatusMessage
	// contains filtered or unexported fields
}