oracle

Documentation

Index

• type Config
  • func NewConfig(path string) (*Config, error)
• type Oracle
  • func NewOracle(ctx context.Context, log *zap.Logger, cfg *Config) (*Oracle, error)
  • func (o *Oracle) Serve(ctx context.Context) error
  • func (o *Oracle) SetPrice(ctx context.Context) error
• type PriceData
• type PriceWatcher
  • func NewPriceWatcher(parsePeriod time.Duration) *PriceWatcher
  • func (p *PriceWatcher) Start(ctx context.Context) <-chan *PriceData

Types

type Config

type Config struct {
	Oracle     oracleConfig       `yaml:"oracle"`
	Log        logging.Config     `yaml:"log"`
	Blockchain *blockchain.Config `yaml:"blockchain"`
	Eth        accounts.EthConfig `yaml:"ethereum" required:"false"`
}

func NewConfig

func NewConfig(path string) (*Config, error)

type Oracle

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

func NewOracle

func NewOracle(ctx context.Context, log *zap.Logger, cfg *Config) (*Oracle, error)

func (*Oracle) Serve

func (o *Oracle) Serve(ctx context.Context) error

func (*Oracle) SetPrice

func (o *Oracle) SetPrice(ctx context.Context) error

type PriceData

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

type PriceWatcher

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

func NewPriceWatcher

func NewPriceWatcher(parsePeriod time.Duration) *PriceWatcher

func (*PriceWatcher) Start

func (p *PriceWatcher) Start(ctx context.Context) <-chan *PriceData