worker

Documentation

Index

• type Message
• type ResultData
• type Symbols
• type WorkerHandle
  • func NewWorkerHandle(db *database.DB, wConf *WorkerHandleConfig, shutdown context.CancelCauseFunc) (*WorkerHandle, error)
  • func (sh *WorkerHandle) Close() error
  • func (sh *WorkerHandle) Start() error
• type WorkerHandleConfig

Types

type Message

type Message struct {
	BaseAsset      string    `json:"base_asset"`
	Exchange       string    `json:"exchange"`
	Price          float64   `json:"price"`
	PriceChange24H float64   `json:"price_change_24h"`
	Volume24H      float64   `json:"volume_24h"`
	Timestamp      time.Time `json:"timestamp"`
}

type ResultData

type ResultData struct {
	Ok     bool    `json:"ok"`
	Code   int     `json:"code"`
	Result Message `json:"result"`
}

type Symbols

type Symbols struct {
	Name    string
	Decimal uint8
}

type WorkerHandle

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

func NewWorkerHandle

func NewWorkerHandle(db *database.DB, wConf *WorkerHandleConfig, shutdown context.CancelCauseFunc) (*WorkerHandle, error)

func (*WorkerHandle) Close

func (sh *WorkerHandle) Close() error

func (*WorkerHandle) Start

func (sh *WorkerHandle) Start() error

type WorkerHandleConfig

type WorkerHandleConfig struct {
	BaseUrl      string
	LoopInterval time.Duration
	SymbolList   []Symbols
}