storage

Documentation

Overview

Copyright (c) 2020 The JaxNetwork developers Use of this source code is governed by an ISC license that can be found in the LICENSE file.

Index

• type CSVStorage
  • func NewCSVStorage(path string) *CSVStorage
  • func (storage *CSVStorage) Close()
  • func (storage *CSVStorage) FetchData() (txmodels.UTXORows, error)
  • func (storage *CSVStorage) SaveRows(rows []txmodels.UTXO) error
• type UTXORepo
  • func NewUTXORepo(dataDir string, additionalKeys ...string) UTXORepo
  • func (collector *UTXORepo) Balance(shardId uint32, addresses ...string) (int64, error)
  • func (collector *UTXORepo) CollectFromRPC(rpcClient *rpcclient.Client, shardID uint32, filter map[string]bool) error
  • func (collector *UTXORepo) Index() *txmodels.UTXOIndex
  • func (collector *UTXORepo) ListUTXOs(skip, take int64, flags map[string]string) (int64, txmodels.UTXORows, error)
  • func (collector *UTXORepo) ReadIndex() error
  • func (collector *UTXORepo) RedeemScript(address string) (script string)
  • func (collector *UTXORepo) ResetUsedFlag()
  • func (collector *UTXORepo) SaveIndex() error
  • func (collector *UTXORepo) SelectForAmount(amount int64, shardID uint32, addresses ...string) (txmodels.UTXORows, error)
  • func (collector *UTXORepo) SetIndex(index *txmodels.UTXOIndex)

Types

type CSVStorage

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

func NewCSVStorage

func NewCSVStorage(path string) *CSVStorage

func (*CSVStorage) Close

func (storage *CSVStorage) Close()

func (*CSVStorage) FetchData

func (storage *CSVStorage) FetchData() (txmodels.UTXORows, error)

func (*CSVStorage) SaveRows

func (storage *CSVStorage) SaveRows(rows []txmodels.UTXO) error

type UTXORepo

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

func NewUTXORepo

func NewUTXORepo(dataDir string, additionalKeys ...string) UTXORepo

func (*UTXORepo) Balance

func (collector *UTXORepo) Balance(shardId uint32, addresses ...string) (int64, error)

func (*UTXORepo) CollectFromRPC

func (collector *UTXORepo) CollectFromRPC(rpcClient *rpcclient.Client, shardID uint32, filter map[string]bool) error

func (*UTXORepo) Index

func (collector *UTXORepo) Index() *txmodels.UTXOIndex

func (*UTXORepo) ListUTXOs

func (collector *UTXORepo) ListUTXOs(skip, take int64, flags map[string]string) (int64, txmodels.UTXORows, error)

func (*UTXORepo) ReadIndex

func (collector *UTXORepo) ReadIndex() error

func (*UTXORepo) RedeemScript

func (collector *UTXORepo) RedeemScript(address string) (script string)

func (*UTXORepo) ResetUsedFlag

func (collector *UTXORepo) ResetUsedFlag()

func (*UTXORepo) SaveIndex

func (collector *UTXORepo) SaveIndex() error

func (*UTXORepo) SelectForAmount

func (collector *UTXORepo) SelectForAmount(amount int64, shardID uint32, addresses ...string) (txmodels.UTXORows, error)

func (*UTXORepo) SetIndex

func (collector *UTXORepo) SetIndex(index *txmodels.UTXOIndex)