streams

Documentation

Index

• func PromptDS(args []string) (core.Queue[string], string)
• func Read(c core.Queue[string], rid int, wg *sync.WaitGroup, s *State, ds string)
• func WriteData(c core.Queue[string], td TickerData, wg *sync.WaitGroup)
• type State
  • func (s *State) GetValue() bool
  • func (s *State) SetValue(value bool)
• type TickerData

Functions

func PromptDS

func PromptDS(args []string) (core.Queue[string], string)

func Read

func Read(c core.Queue[string], rid int, wg *sync.WaitGroup, s *State, ds string)

func WriteData

func WriteData(c core.Queue[string], td TickerData, wg *sync.WaitGroup)

Types

type State

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

func (*State) GetValue

func (s *State) GetValue() bool

func (*State) SetValue

func (s *State) SetValue(value bool)

type TickerData

type TickerData struct {
	Symbol             string  `json:"symbol"`
	PriceChange        float64 `json:"priceChange,string"`
	PriceChangePercent float64 `json:"priceChangePercent,string"`
	WeightedAvgPrice   float64 `json:"weightedAvgPrice,string"`
	PrevClosePrice     float64 `json:"prevClosePrice,string"`
	LastPrice          float64 `json:"lastPrice,string"`
	LastQty            float64 `json:"lastQty,string"`
	BidPrice           float64 `json:"bidPrice,string"`
	BidQty             float64 `json:"bidQty,string"`
	AskPrice           float64 `json:"askPrice,string"`
	AskQty             float64 `json:"askQty,string"`
	Volume             float64 `json:"volume,string"`
	OpenPrice          float64 `json:"openPrice,string"`
	HighPrice          float64 `json:"highPrice,string"`
	LowPrice           float64 `json:"lowPrice,string"`
	QuoteVolume        float64 `json:"quoteVolume,string"`
	OpenTime           int64   `json:"openTime"`
	CloseTime          int64   `json:"closeTime"`
	FirstId            int64   `json:"firstId"`
	LastId             int64   `json:"lastId"`
	Count              int64   `json:"count"`
}