bitflyerspider

Documentation

Index

• func ExecutionToCsv(e *bitflyergo.Execution) string
• func ExecutionToJson(e *bitflyergo.Execution) string
• func ExecutionToTsv(e *bitflyergo.Execution) string
• func WriteExecutionsToFile(executions *[]bitflyergo.Execution, fileType string, headerOn bool, ...)
• type BoardCollector
  • func NewCollector() *BoardCollector
  • func (c *BoardCollector) Agg()
  • func (c *BoardCollector) BestAskPrice() float64
  • func (c *BoardCollector) BestBidPrice() float64
  • func (c *BoardCollector) MidPrice() float64
  • func (c *BoardCollector) Spread() float64
  • func (c *BoardCollector) UpdateBoard(newBoard *bitflyergo.Board, refresh bool)

Functions

func ExecutionToCsv

func ExecutionToCsv(e *bitflyergo.Execution) string

約定履歴のCSV出力用文字列を返します

func ExecutionToJson

func ExecutionToJson(e *bitflyergo.Execution) string

約定履歴のJSON出力用文字列を返します

func ExecutionToTsv

func ExecutionToTsv(e *bitflyergo.Execution) string

約定履歴のTSV出力用文字列を返します

func WriteExecutionsToFile

func WriteExecutionsToFile(executions *[]bitflyergo.Execution, fileType string, headerOn bool, bufferSize int)

Types

type BoardCollector

type BoardCollector struct {
	Asks          map[float64]float64
	Bids          map[float64]float64
	AskPrices     []float64
	BidPrices     []float64
	BoardMutex    *sync.Mutex
	SummaryPerSec []*bq.BqBoard
	AggInterval   time.Duration
}

func NewCollector

func NewCollector() *BoardCollector

func (*BoardCollector) Agg

func (c *BoardCollector) Agg()

func (*BoardCollector) BestAskPrice

func (c *BoardCollector) BestAskPrice() float64

func (*BoardCollector) BestBidPrice

func (c *BoardCollector) BestBidPrice() float64

func (*BoardCollector) MidPrice

func (c *BoardCollector) MidPrice() float64

func (*BoardCollector) Spread

func (c *BoardCollector) Spread() float64

func (*BoardCollector) UpdateBoard

func (c *BoardCollector) UpdateBoard(newBoard *bitflyergo.Board, refresh bool)

Update board