dataproviders

Documentation

Index

• type Data
  • func GetEmptyData(from string, to string) *Data
• type DataPipe
• type DataProvider
• type Display
• type DisplayData
• type Response
• type Worker
  • func (w *Worker) GetDone() chan interface{}
  • func (w *Worker) Shutdown()
  • func (w *Worker) Work(dp *DataProvider)
• type Workers
  • func NewWorkersControl(dp DataProvider) *Workers
  • func (wc *Workers) Add(worker *Worker) *Worker
  • func (wc *Workers) AddWorker(from string, to string) *Worker
  • func (wc *Workers) GetDataProvider() *DataProvider
  • func (wc *Workers) GetPipe() chan *DataPipe
  • func (wc *Workers) GetWorker(from string, to string) *Worker
  • func (wc *Workers) GetWorkers() *map[*Worker]bool
  • func (wc *Workers) NewWorker(from string, to string) *Worker
  • func (wc *Workers) RemoveWorker(from string, to string)
  • func (wc *Workers) Run()

Types

type Data

type Data struct {
	Raw     map[string]map[string]*Response `json:"RAW"`
	Display map[string]map[string]*Display  `json:"DISPLAY"`
}

func GetEmptyData

func GetEmptyData(from string, to string) *Data

type DataPipe

type DataPipe struct {
	From string
	To   string
	Data *Data
}

type DataProvider

type DataProvider interface {
	GetSerializable() *Data
	GetData(from string, to string) (*Data, error)
}

type Display

type Display struct {
	Change24Hour    string `json:"CHANGE24HOUR"`
	Changepct24Hour string `json:"CHANGEPCT24HOUR"`
	Open24Hour      string `json:"OPEN24HOUR"`
	Volume24Hour    string `json:"VOLUME24HOUR"`
	Volume24Hourto  string `json:"VOLUME24HOURTO"`
	High24Hour      string `json:"HIGH24HOUR"`
	Price           string `json:"PRICE"`
	FromSymbol      string `json:"FROMSYMBOL"`
	ToSymbol        string `json:"TOSYMBOL"`
	Lastupdate      string `json:"LASTUPDATE"`
	Supply          string `json:"SUPPLY"`
	Mktcap          string `json:"MKTCAP"`
}

type DisplayData

type DisplayData struct {
}

type Response

type Response struct {
	Change24Hour    float64 `json:"CHANGE24HOUR"`
	Changepct24Hour float64 `json:"CHANGEPCT24HOUR"`
	Open24Hour      float64 `json:"OPEN24HOUR"`
	Volume24Hour    float64 `json:"VOLUME24HOUR"`
	Volume24Hourto  float64 `json:"VOLUME24HOURTO"`
	Low24Hour       float64 `json:"LOW24HOUR"`
	High24Hour      float64 `json:"HIGH24HOUR"`
	Price           float64 `json:"PRICE"`
	Supply          float64 `json:"SUPPLY"`
	Mktcap          float64 `json:"MKTCAP"`
	Lastupdate      int64   `json:"LASTUPDATE"`
}

type Worker

type Worker struct {
	Pipe chan *DataPipe `json:"-"`

	From     string `json:"from"`
	To       string `json:"to"`
	Interval int    `json:"interval"`
	// contains filtered or unexported fields
}

func (*Worker) GetDone

func (w *Worker) GetDone() chan interface{}

func (*Worker) Shutdown

func (w *Worker) Shutdown()

func (*Worker) Work

func (w *Worker) Work(dp *DataProvider)

type Workers

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

func NewWorkersControl

func NewWorkersControl(dp DataProvider) *Workers

func (*Workers) Add

func (wc *Workers) Add(worker *Worker) *Worker

func (*Workers) AddWorker

func (wc *Workers) AddWorker(from string, to string) *Worker

func (*Workers) GetDataProvider

func (wc *Workers) GetDataProvider() *DataProvider

func (*Workers) GetPipe

func (wc *Workers) GetPipe() chan *DataPipe

func (*Workers) GetWorker

func (wc *Workers) GetWorker(from string, to string) *Worker

func (*Workers) GetWorkers

func (wc *Workers) GetWorkers() *map[*Worker]bool

func (*Workers) NewWorker

func (wc *Workers) NewWorker(from string, to string) *Worker

func (*Workers) RemoveWorker

func (wc *Workers) RemoveWorker(from string, to string)

func (*Workers) Run

func (wc *Workers) Run()