ledger

Documentation

Index

• Variables
• type Account
  • func NewAccount(structure *Structure) *Account
  • func (account *Account) BalanceAt(timestamp uint32) uint64
  • func (account *Account) DecreaseBalance(amount uint64, timestamp uint32) bool
  • func (account *Account) IncreaseBalance(amount uint64, timestamp uint32)
  • func (account *Account) SetInterestRate(interest uint16, timestamp uint32)
  • func (account *Account) SetType(accountType umi.AccountType)
  • func (account *Account) UpdateBalance(timestamp uint32)
• type Confirmer
  • func (confirmer *Confirmer) Account(address umi.Address) (account *Account, ok bool)
  • func (confirmer *Confirmer) AppendBlock(block []byte) error
  • func (confirmer *Confirmer) AvailableBalance(address umi.Address, account *Account) uint64
  • func (confirmer *Confirmer) Commit() error
  • func (confirmer *Confirmer) ProcessBlock(blockRaw []byte) error
  • func (confirmer *Confirmer) ResetState()
  • func (confirmer *Confirmer) SetBlockchain(blockchain iBlockchain)
  • func (confirmer *Confirmer) Structure(prefix umi.Prefix) (structure *Structure, ok bool)
• type ConfirmerLegacy
  • func NewConfirmerLegacy(ledger *Ledger) *ConfirmerLegacy
  • func (confirmer *ConfirmerLegacy) AppendBlockLegacy(blockLegacyRaw []byte) error
  • func (confirmer *ConfirmerLegacy) ProcessActivateTransitLegacy(transaction umi.Transaction) (umi.Transaction, error)
  • func (confirmer *ConfirmerLegacy) ProcessBlockLegacy(blockLegacyRaw []byte) (umi.Block, error)
  • func (confirmer *ConfirmerLegacy) ProcessBurnLegacy(transaction umi.Transaction) (umi.Transaction, error)
  • func (confirmer *ConfirmerLegacy) ProcessChangeFeeAddressLegacy(transaction umi.Transaction) (umi.Transaction, error)
  • func (confirmer *ConfirmerLegacy) ProcessChangeProfitAddrLegacy(transaction umi.Transaction) (umi.Transaction, error)
  • func (confirmer *ConfirmerLegacy) ProcessCreateStructureLegacy(transaction umi.Transaction) (umi.Transaction, error)
  • func (confirmer *ConfirmerLegacy) ProcessCreateSubstructLegacy(transaction umi.Transaction) (umi.Transaction, error)
  • func (confirmer *ConfirmerLegacy) ProcessDeactivateTransitLegacy(transaction umi.Transaction) (umi.Transaction, error)
  • func (confirmer *ConfirmerLegacy) ProcessSendLegacy(transaction umi.Transaction) (umi.Transaction, error)
  • func (confirmer *ConfirmerLegacy) ProcessUpdateStructureLegacy(transaction umi.Transaction) (umi.Transaction, error)
• type Ledger
  • func NewLedger(conf *config.Config) *Ledger
  • func (ledger *Ledger) Account(address umi.Address) (account *Account, ok bool)
  • func (ledger *Ledger) HasTransaction(hash umi.Hash) bool
  • func (ledger *Ledger) Structure(prefix umi.Prefix) (structure *Structure, ok bool)
  • func (ledger *Ledger) Structures() (structures []*Structure)
• type Structure
  • func NewStructure(network string, prefix umi.Prefix, masterAddr umi.Address) *Structure
  • func (structure *Structure) BalanceAt(timestamp uint32) uint64
  • func (structure *Structure) DecreaseBalance(amount uint64, timestamp uint32)
  • func (structure *Structure) IncreaseBalance(amount uint64, timestamp uint32)
  • func (structure *Structure) InterestRate(accountType umi.AccountType) uint16
  • func (structure *Structure) IsOwner(addr umi.Address) bool
  • func (structure *Structure) MarshalJSON() ([]byte, error)

Variables

var (
	ErrTxConfirmed = errors.New("transaction confirmed")
)

Types

type Account

type Account struct {
	Balance               uint64
	TransactionCount      uint64
	UpdatedAt             uint32
	LastWithdrawTimestamp uint32

	InterestRate uint16

	Type umi.AccountType
	// contains filtered or unexported fields
}

func NewAccount

func NewAccount(structure *Structure) *Account

func (*Account) BalanceAt

func (account *Account) BalanceAt(timestamp uint32) uint64

func (*Account) DecreaseBalance

func (account *Account) DecreaseBalance(amount uint64, timestamp uint32) bool

func (*Account) IncreaseBalance

func (account *Account) IncreaseBalance(amount uint64, timestamp uint32)

func (*Account) SetInterestRate

func (account *Account) SetInterestRate(interest uint16, timestamp uint32)

func (*Account) SetType

func (account *Account) SetType(accountType umi.AccountType)

func (*Account) UpdateBalance

func (account *Account) UpdateBalance(timestamp uint32)

type Confirmer

type Confirmer struct {
	sync.RWMutex

	// Абсолютная высота транзакции в блокчейне. Удобно использовать для синхронизации.
	TransactionHeight uint64
	// Время создания блока. По этой временной метке считаются балансы.
	BlockTimestamp uint32
	// Высота блока в блокчейне.
	BlockHeight uint32
	// Хэш обрабатываемого блока. После коммита это будет LastBlockHash.
	BlockHash umi.Hash
	// Хэш последнего обработанного леджером блока. На случай если во время обаботки данные поменяются.
	PrevBlockHash umi.Hash
	// contains filtered or unexported fields
}

func (*Confirmer) Account

func (confirmer *Confirmer) Account(address umi.Address) (account *Account, ok bool)

func (*Confirmer) AppendBlock

func (confirmer *Confirmer) AppendBlock(block []byte) error

func (*Confirmer) AvailableBalance

func (confirmer *Confirmer) AvailableBalance(address umi.Address, account *Account) uint64

func (*Confirmer) Commit

func (confirmer *Confirmer) Commit() error

func (*Confirmer) ProcessBlock

func (confirmer *Confirmer) ProcessBlock(blockRaw []byte) error

func (*Confirmer) ResetState

func (confirmer *Confirmer) ResetState()

func (*Confirmer) SetBlockchain

func (confirmer *Confirmer) SetBlockchain(blockchain iBlockchain)

func (*Confirmer) Structure

func (confirmer *Confirmer) Structure(prefix umi.Prefix) (structure *Structure, ok bool)

type ConfirmerLegacy

type ConfirmerLegacy struct {
	Confirmer
}

func NewConfirmerLegacy

func NewConfirmerLegacy(ledger *Ledger) *ConfirmerLegacy

func (*ConfirmerLegacy) AppendBlockLegacy

func (confirmer *ConfirmerLegacy) AppendBlockLegacy(blockLegacyRaw []byte) error

func (*ConfirmerLegacy) ProcessActivateTransitLegacy

func (confirmer *ConfirmerLegacy) ProcessActivateTransitLegacy(transaction umi.Transaction) (umi.Transaction, error)

func (*ConfirmerLegacy) ProcessBlockLegacy

func (confirmer *ConfirmerLegacy) ProcessBlockLegacy(blockLegacyRaw []byte) (umi.Block, error)

func (*ConfirmerLegacy) ProcessBurnLegacy

func (confirmer *ConfirmerLegacy) ProcessBurnLegacy(transaction umi.Transaction) (umi.Transaction, error)

func (*ConfirmerLegacy) ProcessChangeFeeAddressLegacy

func (confirmer *ConfirmerLegacy) ProcessChangeFeeAddressLegacy(transaction umi.Transaction) (umi.Transaction, error)

func (*ConfirmerLegacy) ProcessChangeProfitAddrLegacy

func (confirmer *ConfirmerLegacy) ProcessChangeProfitAddrLegacy(transaction umi.Transaction) (umi.Transaction, error)

func (*ConfirmerLegacy) ProcessCreateStructureLegacy

func (confirmer *ConfirmerLegacy) ProcessCreateStructureLegacy(transaction umi.Transaction) (umi.Transaction, error)

func (*ConfirmerLegacy) ProcessCreateSubstructLegacy

func (confirmer *ConfirmerLegacy) ProcessCreateSubstructLegacy(transaction umi.Transaction) (umi.Transaction, error)

func (*ConfirmerLegacy) ProcessDeactivateTransitLegacy

func (confirmer *ConfirmerLegacy) ProcessDeactivateTransitLegacy(transaction umi.Transaction) (umi.Transaction, error)

func (*ConfirmerLegacy) ProcessSendLegacy

func (confirmer *ConfirmerLegacy) ProcessSendLegacy(transaction umi.Transaction) (umi.Transaction, error)

func (*ConfirmerLegacy) ProcessUpdateStructureLegacy

func (confirmer *ConfirmerLegacy) ProcessUpdateStructureLegacy(transaction umi.Transaction) (umi.Transaction, error)

type Ledger

type Ledger struct {
	sync.RWMutex

	LastBlockTimestamp    uint32
	LastBlockHeight       uint32
	LastBlockHash         umi.Hash
	LastTransactionHeight uint64
	// contains filtered or unexported fields
}

func NewLedger

func NewLedger(conf *config.Config) *Ledger

func (*Ledger) Account

func (ledger *Ledger) Account(address umi.Address) (account *Account, ok bool)

func (*Ledger) HasTransaction

func (ledger *Ledger) HasTransaction(hash umi.Hash) bool

func (*Ledger) Structure

func (ledger *Ledger) Structure(prefix umi.Prefix) (structure *Structure, ok bool)

func (*Ledger) Structures

func (ledger *Ledger) Structures() (structures []*Structure)

type Structure

type Structure struct {
	CreatedAt uint32

	Prefix        umi.Prefix
	Description   string
	ProfitPercent uint16
	FeePercent    uint16

	MasterAddress  umi.Address
	FeeAddress     umi.Address
	ProfitAddress  umi.Address
	DevAddress     umi.Address
	RoyaltyAddress umi.Address

	AddressCount int

	Balance   uint64
	UpdatedAt uint32

	Level             uint8
	LevelInterestRate uint16
	// contains filtered or unexported fields
}

func NewStructure

func NewStructure(network string, prefix umi.Prefix, masterAddr umi.Address) *Structure

func (*Structure) BalanceAt

func (structure *Structure) BalanceAt(timestamp uint32) uint64

func (*Structure) DecreaseBalance

func (structure *Structure) DecreaseBalance(amount uint64, timestamp uint32)

func (*Structure) IncreaseBalance

func (structure *Structure) IncreaseBalance(amount uint64, timestamp uint32)

func (*Structure) InterestRate

func (structure *Structure) InterestRate(accountType umi.AccountType) uint16

func (*Structure) IsOwner

func (structure *Structure) IsOwner(addr umi.Address) bool

func (*Structure) MarshalJSON

func (structure *Structure) MarshalJSON() ([]byte, error)