bq

Documentation

Index

• type BigQueryWriter
  • func NewBigQueryWriter(project string) *BigQueryWriter
• type BqBoard
  • func (b *BqBoard) Save() (row map[string]bigquery.Value, insertID string, err error)
• type BqExecution
  • func (e *BqExecution) Save() (row map[string]bigquery.Value, insertID string, err error)

Types

type BigQueryWriter

type BigQueryWriter struct {
	Client *bigquery.Client
	Ctx    context.Context
}

func NewBigQueryWriter

func NewBigQueryWriter(project string) *BigQueryWriter

type BqBoard

type BqBoard struct {
	Time         time.Time
	MidPrice     int
	BestAskPrice int
	BestAskSize  float64
	BestBidPrice int
	BestBidSize  float64
	Spread       int
}

func (*BqBoard) Save

func (b *BqBoard) Save() (row map[string]bigquery.Value, insertID string, err error)

type BqExecution

type BqExecution struct {
	Id                         int64     // ID
	ExecDate                   time.Time // 日時
	Price                      int       // 価格
	Size                       float64   // サイズ
	Side                       string    // 売買種別
	BuyChildOrderAcceptanceId  string    // 買い注文ID
	SellChildOrderAcceptanceId string    // 売り注文ID
	Delay                      float64   // 受信遅延時間
	ReceivedTime               time.Time
}

func (*BqExecution) Save

func (e *BqExecution) Save() (row map[string]bigquery.Value, insertID string, err error)