ticker

README

GoCryptoTrader package Ticker

This ticker package is part of the GoCryptoTrader codebase.

This is still in active development

You can track ideas, planned features and what's in progress on this Trello board: https://trello.com/b/ZAhMhpOy/gocryptotrader.

Join our slack to discuss all things related to GoCryptoTrader! GoCryptoTrader Slack

Current Features for ticker

• This services the exchanges package by ticker functions.

• This package facilitates ticker generation.

• Attaches methods to an ticker

  • Returns a string of a value

• Gets a loaded ticker by exchange, asset type and currency pair.

• This package is primarily used in conjunction with but not limited to the exchange interface system set by exchange wrapper orderbook functions in "exchange"_wrapper.go.

Examples below:

tick, err := yobitExchange.FetchTicker()
if err != nil {
  // Handle error
}

// Converts ticker value to string
tickerValString := tick.PriceToString(...)

• or if you have a routine setting an exchange orderbook you can access it via the package itself.

tick, err := ticker.GetTicker(...)
if err != nil {
  // Handle error
}

Please click GoDocs chevron above to view current GoDoc information for this package

Contribution

Please feel free to submit any pull requests or suggest any desired features to be added.

When submitting a PR, please abide by our coding guidelines:

• Code must adhere to the official Go formatting guidelines (i.e. uses gofmt).
• Code must be documented adhering to the official Go commentary guidelines.
• Code must adhere to our coding style.
• Pull requests need to be based on and opened against the master branch.

Donations

If this framework helped you in any way, or you would like to support the developers working on it, please donate Bitcoin to:

bc1qk0jareu4jytc0cfrhr5wgshsq8282awpavfahc

Documentation

Index

• func ProcessTicker(exchangeName string, tickerNew *Price, assetType asset.Item) error
• func SubscribeTicker(exchange string, p currency.Pair, a asset.Item) (dispatch.Pipe, error)
• func SubscribeToExchangeTickers(exchange string) (dispatch.Pipe, error)
• type Price
  • func GetTicker(exchange string, p currency.Pair, tickerType asset.Item) (*Price, error)
• type Service
  • func (s *Service) GetAssociations(p *Price) ([]uuid.UUID, error)
  • func (s *Service) SetItemID(p *Price) error
  • func (s *Service) Update(p *Price) error
• type Ticker

Functions

func ProcessTicker

func ProcessTicker(exchangeName string, tickerNew *Price, assetType asset.Item) error

ProcessTicker processes incoming tickers, creating or updating the Tickers list

func SubscribeTicker

func SubscribeTicker(exchange string, p currency.Pair, a asset.Item) (dispatch.Pipe, error)

SubscribeTicker subcribes to a ticker and returns a communication channel to stream new ticker updates

func SubscribeToExchangeTickers

func SubscribeToExchangeTickers(exchange string) (dispatch.Pipe, error)

SubscribeToExchangeTickers subcribes to all tickers on an exchange

Types

type Price

type Price struct {
	Last         float64       `json:"Last"`
	High         float64       `json:"High"`
	Low          float64       `json:"Low"`
	Bid          float64       `json:"Bid"`
	Ask          float64       `json:"Ask"`
	Volume       float64       `json:"Volume"`
	QuoteVolume  float64       `json:"QuoteVolume"`
	PriceATH     float64       `json:"PriceATH"`
	Open         float64       `json:"Open"`
	Close        float64       `json:"Close"`
	Pair         currency.Pair `json:"Pair"`
	ExchangeName string        `json:"exchangeName"`
	AssetType    asset.Item    `json:"assetType"`
	LastUpdated  time.Time
}

Price struct stores the currency pair and pricing information

func GetTicker

func GetTicker(exchange string, p currency.Pair, tickerType asset.Item) (*Price, error)

GetTicker checks and returns a requested ticker if it exists

type Service

type Service struct {
	Tickers  map[string]map[*currency.Item]map[*currency.Item]map[asset.Item]*Ticker
	Exchange map[string]uuid.UUID

	sync.RWMutex
	// contains filtered or unexported fields
}

Service holds ticker information for each individual exchange

func (*Service) GetAssociations

func (s *Service) GetAssociations(p *Price) ([]uuid.UUID, error)

GetAssociations links a singular book with it's dispatch associations

func (*Service) SetItemID

func (s *Service) SetItemID(p *Price) error

SetItemID retrieves and sets dispatch mux publish IDs

func (*Service) Update

func (s *Service) Update(p *Price) error

Update updates ticker price

type Ticker

type Ticker struct {
	Price
	Main  uuid.UUID
	Assoc []uuid.UUID
}

Ticker struct holds the ticker information for a currency pair and type