pricing

Documentation

Index

• type Checker
  • func NewChecker(notifier notifying.Service, feed Feed, triggers []*notifying.Trigger) *Checker
  • func (p *Checker) Run()
  • func (n *Checker) Stop() error
• type Feed
  • func NewCoinbaseFeed(currency string, symbols ...string) (Feed, error)
• type JSON
• type Message
• type MessageChannel

Types

type Checker

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

func NewChecker

func NewChecker(notifier notifying.Service, feed Feed, triggers []*notifying.Trigger) *Checker

TODO: pass Storage interface instead of triggers.

func (*Checker) Run

func (p *Checker) Run()

Run starts the Checker, it pulls the latest prices, checks them against active Triggers. Send alert when case is met. Disable Trigger, and remove from list.

func (*Checker) Stop

func (n *Checker) Stop() error

Close closes the feed, then sends a chan error to the closing channel, and waits to return the last error, if any.

type Feed

type Feed interface {
	Updates() <-chan Message
	Close() error
}

Feed delivers Messages over a channel, Close cancels the feed, closes the Updates channel, and returns the last error, if any.

func NewCoinbaseFeed

func NewCoinbaseFeed(currency string, symbols ...string) (Feed, error)

NewCoinbaseFeed creates a new CoinBase WebSocket feed for the given currency and cryptos.

type JSON

type JSON map[string]interface{}

type Message

type Message struct {
	Type      string           `json:"type"`
	ProductId string           `json:"product_id"`
	Channels  []MessageChannel `json:"channels"`
	Price     string           `json:"price"`
}

type MessageChannel

type MessageChannel struct {
	Name       string   `json:"name"`
	ProductIds []string `json:"product_ids"`
}