price

Documentation

Index

• func FetchURLWithRetry(url string) ([]byte, error)
• type CoinMarketCapConfig
• type CoinMarketCapFactory
  • func (m *CoinMarketCapFactory) Config() interface{}
  • func (m *CoinMarketCapFactory) Init(margin float64) Provider
  • func (m *CoinMarketCapFactory) ValidateConfig() error
• type Factory
  • func NewFactory(t string) Factory
• type Provider
  • func NewCMCProvider(cfg *CoinMarketCapConfig, margin float64) Provider
  • func NewStaticProvider(cfg *StaticProviderConfig) Provider
• type SourceConfig
  • func (m *SourceConfig) MarshalYAML() (interface{}, error)
  • func (m *SourceConfig) UnmarshalYAML(unmarshal func(interface{}) error) error
• type StaticFactory
  • func (m *StaticFactory) Config() interface{}
  • func (m *StaticFactory) Init(Margin float64) Provider
  • func (m *StaticFactory) ValidateConfig() error
• type StaticProviderConfig
• type Updateable

Functions

func FetchURLWithRetry

func FetchURLWithRetry(url string) ([]byte, error)

Types

type CoinMarketCapConfig

type CoinMarketCapConfig struct {
	WhatToMineID int           `yaml:"what_to_mine_id" required:"true"`
	URL          string        `yaml:"url" required:"true"`
	Interval     time.Duration `yaml:"update_interval" default:"10m"`
}

type CoinMarketCapFactory

type CoinMarketCapFactory struct {
	CoinMarketCapConfig
}

func (*CoinMarketCapFactory) Config

func (m *CoinMarketCapFactory) Config() interface{}

func (*CoinMarketCapFactory) Init

func (m *CoinMarketCapFactory) Init(margin float64) Provider

func (*CoinMarketCapFactory) ValidateConfig

func (m *CoinMarketCapFactory) ValidateConfig() error

type Factory

type Factory interface {
	Config() interface{}
	ValidateConfig() error
	Init(margin float64) Provider
}

func NewFactory

func NewFactory(t string) Factory

type Provider

type Provider interface {
	// GetPrice returns last known value of token's price.
	// Note that value is ether-graded (1e18).
	GetPrice() *big.Int
}

Provider loads and calculates mining profit for specified token. The value is is USD per Second per hash.

func NewCMCProvider

func NewCMCProvider(cfg *CoinMarketCapConfig, margin float64) Provider

func NewStaticProvider

func NewStaticProvider(cfg *StaticProviderConfig) Provider

type SourceConfig

type SourceConfig struct {
	Factory
}

SourceConfig configure different sources which van be used to obtain price for orders/deals.

func (*SourceConfig) MarshalYAML

func (m *SourceConfig) MarshalYAML() (interface{}, error)

func (*SourceConfig) UnmarshalYAML

func (m *SourceConfig) UnmarshalYAML(unmarshal func(interface{}) error) error

type StaticFactory

type StaticFactory struct {
	StaticProviderConfig
}

func (*StaticFactory) Config

func (m *StaticFactory) Config() interface{}

func (*StaticFactory) Init

func (m *StaticFactory) Init(Margin float64) Provider

func (*StaticFactory) ValidateConfig

func (m *StaticFactory) ValidateConfig() error

type StaticProviderConfig

type StaticProviderConfig struct {
	Price int64 `yaml:"price" required:"true"`
}

type Updateable

type Updateable interface {
	Update(ctx context.Context) error
	Interval() time.Duration
}

Updateable provider should refresh their state with given interval.