state

Documentation

Index

• type Storage
  • func (s *Storage) AssetInfo(asset crypto.Digest) (*data.AssetInfo, error)
  • func (s *Storage) BlockID(height int) (proto.BlockID, error)
  • func (s *Storage) CandlesRange(amountAsset, priceAsset crypto.Digest, from, to uint32, timeFrameScale int) ([]data.Candle, error)
  • func (s *Storage) Close() error
  • func (s *Storage) DayCandle(amountAsset, priceAsset crypto.Digest) (data.Candle, error)
  • func (s *Storage) HasBlock(height int, block proto.BlockID) (bool, error)
  • func (s *Storage) Height() (int, error)
  • func (s *Storage) IssuerBalance(issuer proto.Address, asset crypto.Digest) (uint64, error)
  • func (s *Storage) Markets() (map[data.MarketID]data.Market, error)
  • func (s *Storage) Open() error
  • func (s *Storage) PutBalances(height int, block proto.BlockID, issues []data.IssueChange, ...) error
  • func (s *Storage) PutTrades(height int, block proto.BlockID, trades []data.Trade) error
  • func (s *Storage) Rollback(removeHeight int) error
  • func (s *Storage) SafeRollbackHeight(height int) (int, error)
  • func (s *Storage) Trades(amountAsset, priceAsset crypto.Digest, limit int) ([]data.Trade, error)
  • func (s *Storage) TradesByAddress(amountAsset, priceAsset crypto.Digest, address proto.Address, limit int) ([]data.Trade, error)
  • func (s *Storage) TradesRange(amountAsset, priceAsset crypto.Digest, from, to uint64) ([]data.Trade, error)

Types

type Storage

type Storage struct {
	Path   string
	Scheme byte
	// contains filtered or unexported fields
}

func (*Storage) AssetInfo

func (s *Storage) AssetInfo(asset crypto.Digest) (*data.AssetInfo, error)

func (*Storage) BlockID

func (s *Storage) BlockID(height int) (proto.BlockID, error)

func (*Storage) CandlesRange

func (s *Storage) CandlesRange(amountAsset, priceAsset crypto.Digest, from, to uint32, timeFrameScale int) ([]data.Candle, error)

func (*Storage) Close

func (s *Storage) Close() error

func (*Storage) DayCandle

func (s *Storage) DayCandle(amountAsset, priceAsset crypto.Digest) (data.Candle, error)

func (*Storage) HasBlock

func (s *Storage) HasBlock(height int, block proto.BlockID) (bool, error)

func (*Storage) Height

func (s *Storage) Height() (int, error)

func (*Storage) IssuerBalance

func (s *Storage) IssuerBalance(issuer proto.Address, asset crypto.Digest) (uint64, error)

func (*Storage) Markets

func (s *Storage) Markets() (map[data.MarketID]data.Market, error)

func (*Storage) Open

func (s *Storage) Open() error

func (*Storage) PutBalances

func (s *Storage) PutBalances(height int, block proto.BlockID, issues []data.IssueChange, assets []data.AssetChange, accounts []data.AccountChange, aliases []data.AliasBind) error

func (*Storage) PutTrades

func (s *Storage) PutTrades(height int, block proto.BlockID, trades []data.Trade) error

func (*Storage) Rollback

func (s *Storage) Rollback(removeHeight int) error

func (*Storage) SafeRollbackHeight

func (s *Storage) SafeRollbackHeight(height int) (int, error)

func (*Storage) Trades

func (s *Storage) Trades(amountAsset, priceAsset crypto.Digest, limit int) ([]data.Trade, error)

func (*Storage) TradesByAddress

func (s *Storage) TradesByAddress(amountAsset, priceAsset crypto.Digest, address proto.Address, limit int) ([]data.Trade, error)

func (*Storage) TradesRange

func (s *Storage) TradesRange(amountAsset, priceAsset crypto.Digest, from, to uint64) ([]data.Trade, error)