database

Sep 30, 2024

Changes in this version

type Batch

+ func (b *Batch) UpdateBPT() error

type Chain2

+ func (c *Chain2) EntryAs(height int64, value encoding.BinaryUnmarshaler) error

+ func (c *Chain2) Receipt(from, to uint64) (*merkle.Receipt, error)

+ func (c *Chain2) State(height int64) (*merkle.State, error)

type CollectOptions

+ KeepMessage func(messaging.Message) (bool, error)

type Database

+ func OpenLevelDB(filepath string, logger log.Logger) (*Database, error)

Mar 4, 2024

Changes in this version

type Account

+ func (c *Account) BptChain() *Chain2

Dec 6, 2023

Changes in this version

+ func Restore(db Beginner, file ioutil.SectionReader, opts *RestoreOptions) error

type Batch

+ func (batch *Batch) Collect(file io.WriteSeeker, partition *url.URL, opts *CollectOptions) error

type Chain2

+ func (c *Chain2) Anchor() ([]byte, error)

type CollectOptions

+ DidWriteHeader func(*snapshot.Writer) error

Aug 30, 2023

Changes in this version

type Batch

+ func (b *Batch) GetBptRootHash() ([32]byte, error)

Aug 24, 2023

Changes in this version

type Account

+ func (r *Account) MarkDirty() error

Aug 4, 2023

Changes in this version

type Account

+ func (c *Account) Events() *AccountEvents

+ type AccountEvents struct

+ func (c *AccountEvents) BPT() *bpt.BPT

+ func (c *AccountEvents) Backlog() *AccountEventsBacklog

+ func (c *AccountEvents) Commit() error

+ func (c *AccountEvents) IsDirty() bool

+ func (c *AccountEvents) Key() *record.Key

+ func (c *AccountEvents) Major() *AccountEventsMajor

+ func (c *AccountEvents) Minor() *AccountEventsMinor

+ func (c *AccountEvents) Resolve(key *record.Key) (record.Record, *record.Key, error)

+ func (c *AccountEvents) Walk(opts record.WalkOptions, fn record.WalkFunc) error

+ type AccountEventsBacklog struct

+ func (c *AccountEventsBacklog) Commit() error

+ func (c *AccountEventsBacklog) Expired() values.Set[*url.TxID]

+ func (c *AccountEventsBacklog) IsDirty() bool

+ func (c *AccountEventsBacklog) Key() *record.Key

+ func (c *AccountEventsBacklog) Resolve(key *record.Key) (record.Record, *record.Key, error)

+ func (c *AccountEventsBacklog) Walk(opts record.WalkOptions, fn record.WalkFunc) error

+ type AccountEventsMajor struct

+ func (c *AccountEventsMajor) Blocks() values.Set[uint64]

+ func (c *AccountEventsMajor) Commit() error

+ func (c *AccountEventsMajor) IsDirty() bool

+ func (c *AccountEventsMajor) Key() *record.Key

+ func (c *AccountEventsMajor) Pending(block uint64) values.Set[*url.TxID]

+ func (c *AccountEventsMajor) Resolve(key *record.Key) (record.Record, *record.Key, error)

+ func (c *AccountEventsMajor) Walk(opts record.WalkOptions, fn record.WalkFunc) error

+ type AccountEventsMinor struct

+ func (c *AccountEventsMinor) Blocks() values.Set[uint64]

+ func (c *AccountEventsMinor) Commit() error

+ func (c *AccountEventsMinor) IsDirty() bool

+ func (c *AccountEventsMinor) Key() *record.Key

+ func (c *AccountEventsMinor) Resolve(key *record.Key) (record.Record, *record.Key, error)

+ func (c *AccountEventsMinor) Votes(block uint64) values.Set[*protocol.AuthoritySignature]

+ func (c *AccountEventsMinor) Walk(opts record.WalkOptions, fn record.WalkFunc) error

type AccountIterator

+ func (it *AccountIterator) Value() *Account

+ type CollectMetrics struct

+ Messages struct{ ... }

type CollectOptions

+ BuildIndex bool

+ Metrics *CollectMetrics

+ Predicate func(database.Record) (bool, error)

+ type RestoreMetrics struct

+ Records struct{ ... }

type RestoreOptions

+ Metrics *RestoreMetrics

+ Predicate func(*snapshot.RecordEntry, database.Value) (bool, error)

+ SkipHashCheck bool

May 19, 2023

retracted

Changes in this version

type Account

+ func (c *Account) Key() *record.Key

+ func (c *Account) Walk(opts record.WalkOptions, fn record.WalkFunc) error

type AccountAnchorChain

+ func (c *AccountAnchorChain) Key() *record.Key

+ func (c *AccountAnchorChain) Walk(opts record.WalkOptions, fn record.WalkFunc) error

type AccountData

+ func (c *AccountData) Key() *record.Key

+ func (c *AccountData) Walk(opts record.WalkOptions, fn record.WalkFunc) error

+ type AccountIterator struct

+ func (it *AccountIterator) Err() error

+ func (it *AccountIterator) Next() (*Account, bool)

type AccountTransaction

+ func (c *AccountTransaction) Key() *record.Key

+ func (c *AccountTransaction) Walk(opts record.WalkOptions, fn record.WalkFunc) error

type Batch

+ func (b *Batch) IterateAccounts() *AccountIterator

+ func (c *Batch) BPT() *bpt.BPT

+ func (c *Batch) Key() *record.Key

+ func (c *Batch) Walk(opts record.WalkOptions, fn record.WalkFunc) error

type Chain2

+ func (c *Chain2) Walk(opts database.WalkOptions, fn database.WalkFunc) error

+ type CollectOptions struct

+ PreserveAll bool

type Database

+ func (d *Database) Store() (keyvalue.Beginner, error)

+ func (db *Database) Collect(file io.WriteSeeker, partition *url.URL, opts *CollectOptions) error

+ func (db *Database) Restore(file ioutil.SectionReader, opts *RestoreOptions) error

type MerkleManager

+ func (c *MerkleManager) Key() *record.Key

+ func (c *MerkleManager) Walk(opts record.WalkOptions, fn record.WalkFunc) error

type Message

+ func (c *Message) Key() *record.Key

+ func (c *Message) Walk(opts record.WalkOptions, fn record.WalkFunc) error

+ type RestoreOptions struct

+ BatchRecordLimit int

type SystemData

+ func (c *SystemData) Key() *record.Key

+ func (c *SystemData) Walk(opts record.WalkOptions, fn record.WalkFunc) error

type Transaction

+ func (c *Transaction) Key() *record.Key

+ func (c *Transaction) Walk(opts record.WalkOptions, fn record.WalkFunc) error

Apr 25, 2023

retracted

Changes in this version

+ func GetReceipt(manager *MerkleManager, element Hash, anchor Hash) (r *merkle.Receipt, err error)

+ func GetSha256() func(data []byte) Hash

type Account

+ func (a *Account) Hash() ([32]byte, error)

+ func (c *Account) Transaction(hash [32]byte) *AccountTransaction

+ func (c *Account) WalkChanges(fn record.WalkFunc) error

type AccountAnchorChain

+ func (c *AccountAnchorChain) WalkChanges(fn record.WalkFunc) error

type AccountData

+ func (c *AccountData) WalkChanges(fn record.WalkFunc) error

+ type AccountTransaction struct

+ func (c *AccountTransaction) Commit() error

+ func (c *AccountTransaction) History() record.Set[uint64]

+ func (c *AccountTransaction) IsDirty() bool

+ func (c *AccountTransaction) Payments() record.Set[[32]byte]

+ func (c *AccountTransaction) RecordHistory(msg messaging.Message) error

+ func (c *AccountTransaction) Resolve(key record.Key) (record.Record, record.Key, error)

+ func (c *AccountTransaction) Signatures() record.Set[*SignatureSetEntry]

+ func (c *AccountTransaction) ValidatorSignatures() record.Set[protocol.KeySignature]

+ func (c *AccountTransaction) Votes() record.Set[*VoteEntry]

+ func (c *AccountTransaction) WalkChanges(fn record.WalkFunc) error

type Batch

+ func NewBatch(id string, store storage.KeyValueTxn, writable bool, logger log.Logger) *Batch

+ func (b *Batch) AccountTransaction(id *url.TxID) *AccountTransaction

+ func (b *Batch) ForEachAccount(fn func(account *Account, hash [32]byte) error) error

+ func (b *Batch) Message2(hash []byte) *Message

+ func (b *Batch) SetObserver(observer Observer)

+ func (b *Batch) Transaction2(id [32]byte) *Transaction

+ func (c *Batch) Message(hash [32]byte) *Message

+ func (c *Batch) WalkChanges(fn record.WalkFunc) error

type Beginner

+ SetObserver func(Observer)

type Chain2

+ func (c *Chain2) Entry(height int64) ([]byte, error)

+ func (c *Chain2) Head() record.Value[*MerkleState]

+ func (c *Chain2) IndexOf(hash []byte) (int64, error)

+ func (c *Chain2) WalkChanges(fn record.WalkFunc) error

type Database

+ func (d *Database) SetObserver(observer Observer)

+ type Hash []byte

+ func Sha256(b []byte) Hash

+ func (h *Hash) UnmarhsalBinary(b []byte) error

+ func (h Hash) BinarySize() int

+ func (h Hash) Bytes() []byte

+ func (h Hash) Bytes32() [32]byte

+ func (h Hash) Combine(hf HashFunc, right Hash) Hash

+ func (h Hash) Copy() Hash

+ func (h Hash) Equal(g Hash) bool

+ func (h Hash) MarshalBinary() ([]byte, error)

+ type HashFunc func([]byte) Hash

+ type HashList [][]byte

+ func (l *HashList) UnmarhsalBinary(b []byte) error

+ func (l HashList) BinarySize() int

+ func (l HashList) MarshalBinary() ([]byte, error)

+ type MerkleManager struct

+ func NewChain(logger log.Logger, store record.Store, key record.Key, markPower int64, ...) *MerkleManager

+ func (c *MerkleManager) Commit() error

+ func (c *MerkleManager) Element(index uint64) record.Value[[]byte]

+ func (c *MerkleManager) ElementIndex(hash []byte) record.Value[uint64]

+ func (c *MerkleManager) Head() record.Value[*MerkleState]

+ func (c *MerkleManager) IsDirty() bool

+ func (c *MerkleManager) MarkFreq() int64

+ func (c *MerkleManager) MarkMask() int64

+ func (c *MerkleManager) MarkPower() int64

+ func (c *MerkleManager) Name() string

+ func (c *MerkleManager) Resolve(key record.Key) (record.Record, record.Key, error)

+ func (c *MerkleManager) States(index uint64) record.Value[*MerkleState]

+ func (c *MerkleManager) Type() merkle.ChainType

+ func (c *MerkleManager) WalkChanges(fn record.WalkFunc) error

+ func (m *MerkleManager) AddHash(hash Hash, unique bool) error

+ func (m *MerkleManager) BuildReceipt(r *merkle.Receipt) error

+ func (m *MerkleManager) Get(element int64) (Hash, error)

+ func (m *MerkleManager) GetAnyState(element int64) (ms *MerkleState, err error)

+ func (m *MerkleManager) GetElementIndex(hash []byte) (int64, error)

+ func (m *MerkleManager) GetIntermediate(element, height int64) (Left, Right Hash, err error)

+ func (m *MerkleManager) GetRange(begin, end int64) ([][]byte, error)

+ func (m *MerkleManager) GetState(element int64) *MerkleState

+ type MerkleState struct

+ func (m *MerkleState) AddToMerkleTree(hash_ []byte)

+ func (m *MerkleState) Copy() *MerkleState

+ func (m *MerkleState) CopyAsInterface() interface{}

+ func (m *MerkleState) Equal(n *MerkleState) bool

+ func (m *MerkleState) GetIntermediate(hash Hash, height int64) (left, right Hash, err error)

+ func (m *MerkleState) GetMDRoot() (MDRoot Hash)

+ func (m *MerkleState) InitSha256()

+ func (m *MerkleState) PrintMR() (mr string)

+ func (m *MerkleState) UnMarshal(MSBytes []byte) (err error)

+ func (m *MerkleState) UnmarshalBinary(data []byte) error

+ func (m *MerkleState) UnmarshalBinaryFrom(rd io.Reader) error

+ func (m MerkleState) String() string

+ type MerkleTestCase struct

+ Cascade []YamlHexString

+ Entries []YamlHexString

+ Root YamlHexString

+ type Message struct

+ func (c *Message) Cause() record.Set[*url.TxID]

+ func (c *Message) Commit() error

+ func (c *Message) IsDirty() bool

+ func (c *Message) Produced() record.Set[*url.TxID]

+ func (c *Message) Resolve(key record.Key) (record.Record, record.Key, error)

+ func (c *Message) Signers() record.Set[*url.URL]

+ func (c *Message) WalkChanges(fn record.WalkFunc) error

+ func (m *Message) FindSigners(u *url.URL) ([]*url.URL, error)

+ func (m *Message) Main() record.Value[messaging.Message]

+ type Observer interface

+ DidChangeAccount func(batch *Batch, account *Account) (hash.Hasher, error)

+ type ReceiptList struct

+ ContinuedReceipt *merkle.Receipt

+ Elements [][]byte

+ MerkleState *MerkleState

+ Receipt *merkle.Receipt

+ func GetReceiptList(manager *MerkleManager, Start int64, End int64) (r *ReceiptList, err error)

+ func NewReceiptList() *ReceiptList

+ func (r *ReceiptList) Included(entry []byte) bool

+ func (r *ReceiptList) Validate(opts *merkle.ValidateOptions) bool

+ func (v *ReceiptList) Copy() *ReceiptList

+ func (v *ReceiptList) CopyAsInterface() interface{}

+ func (v *ReceiptList) Equal(u *ReceiptList) bool

+ func (v *ReceiptList) IsValid() error

+ func (v *ReceiptList) MarshalBinary() ([]byte, error)

+ func (v *ReceiptList) MarshalJSON() ([]byte, error)

+ func (v *ReceiptList) UnmarshalBinary(data []byte) error

+ func (v *ReceiptList) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *ReceiptList) UnmarshalJSON(data []byte) error

+ type SignatureSetEntry struct

+ Hash [32]byte

+ KeyIndex uint64

+ Path []*url.URL

+ Version uint64

+ func (a *SignatureSetEntry) PathHash() [32]byte

+ func (v *SignatureSetEntry) Copy() *SignatureSetEntry

+ func (v *SignatureSetEntry) CopyAsInterface() interface{}

+ func (v *SignatureSetEntry) Equal(u *SignatureSetEntry) bool

+ func (v *SignatureSetEntry) IsValid() error

+ func (v *SignatureSetEntry) MarshalBinary() ([]byte, error)

+ func (v *SignatureSetEntry) MarshalJSON() ([]byte, error)

+ func (v *SignatureSetEntry) UnmarshalBinary(data []byte) error

+ func (v *SignatureSetEntry) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *SignatureSetEntry) UnmarshalJSON(data []byte) error

+ type SparseHashList [][]byte

+ func (l *SparseHashList) UnmarshalBinary(height int64, data []byte) error

+ func (l SparseHashList) BinarySize(height int64) int

+ func (l SparseHashList) Copy() SparseHashList

+ func (l SparseHashList) MarshalBinary(height int64) ([]byte, error)

type SystemData

+ func (c *SystemData) WalkChanges(fn record.WalkFunc) error

type Transaction

+ func (c *Transaction) WalkChanges(fn record.WalkFunc) error

+ type VoteEntry struct

+ Authority *url.URL

+ Hash [32]byte

+ func (v *VoteEntry) Copy() *VoteEntry

+ func (v *VoteEntry) CopyAsInterface() interface{}

+ func (v *VoteEntry) Equal(u *VoteEntry) bool

+ func (v *VoteEntry) IsValid() error

+ func (v *VoteEntry) MarshalBinary() ([]byte, error)

+ func (v *VoteEntry) MarshalJSON() ([]byte, error)

+ func (v *VoteEntry) UnmarshalBinary(data []byte) error

+ func (v *VoteEntry) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *VoteEntry) UnmarshalJSON(data []byte) error

+ type YamlHexString []byte

+ func (s *YamlHexString) UnmarshalYAML(value *yaml.Node) error

Feb 1, 2023

Changes in this version

type Account

+ func (a *Account) UpdatedChains() ([]*protocol.BlockEntry, error)

type Batch

+ func (b *Batch) UpdatedAccounts() []*Account

Oct 31, 2022

Changes in this version

+ func GetSignaturesForSigner(transaction *Transaction, signer protocol.Signer) ([]protocol.Signature, error)

+ func UpdateAccount(batch *Batch, url *url.URL, fn func(T) error) (T, error)

type Account

+ func (a *Account) BptReceipt() (*managed.Receipt, error)

+ func (a *Account) ChainByName(name string) (*Chain2, error)

+ func (a *Account) Commit() error

+ func (a *Account) GetChainByName(name string) (*Chain, error)

+ func (a *Account) GetIndexChainByName(name string) (*Chain, error)

+ func (a *Account) VerifyHash(hash []byte) error

+ func (c *Account) AnchorChain(partition string) *AccountAnchorChain

+ func (c *Account) AnchorSequenceChain() *Chain2

+ func (c *Account) Chains() *record.Set[*protocol.ChainMetadata]

+ func (c *Account) Directory() *record.Set[*url.URL]

+ func (c *Account) IsDirty() bool

+ func (c *Account) Main() *record.Value[protocol.Account]

+ func (c *Account) MainChain() *Chain2

+ func (c *Account) MajorBlockChain() *Chain2

+ func (c *Account) Pending() *record.Set[*url.TxID]

+ func (c *Account) Resolve(key record.Key) (record.Record, record.Key, error)

+ func (c *Account) RootChain() *Chain2

+ func (c *Account) ScratchChain() *Chain2

+ func (c *Account) SignatureChain() *Chain2

+ func (c *Account) SyntheticAnchors() *record.Set[[32]byte]

+ func (c *Account) SyntheticSequenceChain(partition string) *Chain2

+ func (r *Account) AddPending(txid *url.TxID) error

+ func (r *Account) GetPending() (*protocol.TxIdSet, error)

+ func (r *Account) GetSyntheticForAnchor(anchor [32]byte) ([]*url.TxID, error)

+ func (r *Account) RemovePending(txid *url.TxID) error

+ func (r *Account) Url() *url.URL

+ type AccountAnchorChain struct

+ func (c *AccountAnchorChain) BPT() *Chain2

+ func (c *AccountAnchorChain) Commit() error

+ func (c *AccountAnchorChain) IsDirty() bool

+ func (c *AccountAnchorChain) Resolve(key record.Key) (record.Record, record.Key, error)

+ func (c *AccountAnchorChain) Root() *Chain2

+ type AccountData struct

+ func (c *AccountData) Commit() error

+ func (c *AccountData) Entry() *record.Counted[[32]byte]

+ func (c *AccountData) IsDirty() bool

+ func (c *AccountData) Resolve(key record.Key) (record.Record, record.Key, error)

+ func (c *AccountData) Transaction(entryHash [32]byte) *record.Value[[32]byte]

type Batch

+ func (b *Batch) BptRoot() []byte

+ func (b *Batch) DeleteAccountState_TESTONLY(url *url.URL) error

+ func (b *Batch) GetValue(key record.Key, value record.ValueWriter) error

+ func (b *Batch) PutValue(key record.Key, value record.ValueReader) error

+ func (b *Batch) SaveAccounts(file io.WriteSeeker, collect func(*Account) ([]byte, error)) error

+ func (b *Batch) VisitAccounts(visit func(*Account) error) error

+ func (c *Batch) IsDirty() bool

+ func (c *Batch) Resolve(key record.Key) (record.Record, record.Key, error)

+ func (c *Batch) SystemData(partition string) *SystemData

+ type Beginner interface

+ Begin func(bool) *Batch

+ type BlockStateSynthTxnEntry struct

+ Account *url.URL

+ ChainEntry uint64

+ Transaction []byte

+ func (e *BlockStateSynthTxnEntry) Compare(f *BlockStateSynthTxnEntry) int

+ func (v *BlockStateSynthTxnEntry) Copy() *BlockStateSynthTxnEntry

+ func (v *BlockStateSynthTxnEntry) CopyAsInterface() interface{}

+ func (v *BlockStateSynthTxnEntry) Equal(u *BlockStateSynthTxnEntry) bool

+ func (v *BlockStateSynthTxnEntry) IsValid() error

+ func (v *BlockStateSynthTxnEntry) MarshalBinary() ([]byte, error)

+ func (v *BlockStateSynthTxnEntry) MarshalJSON() ([]byte, error)

+ func (v *BlockStateSynthTxnEntry) UnmarshalBinary(data []byte) error

+ func (v *BlockStateSynthTxnEntry) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *BlockStateSynthTxnEntry) UnmarshalJSON(data []byte) error

+ type Chain2 struct

+ func (c *Chain2) Account() *url.URL

+ func (c *Chain2) Commit() error

+ func (c *Chain2) Get() (*Chain, error)

+ func (c *Chain2) Index() *Chain2

+ func (c *Chain2) Inner() *managed.Chain

+ func (c *Chain2) IsDirty() bool

+ func (c *Chain2) Key(i int) interface{}

+ func (c *Chain2) Name() string

+ func (c *Chain2) Resolve(key record.Key) (record.Record, record.Key, error)

+ func (c *Chain2) Type() managed.ChainType

+ func (c *Chain2) Url() *url.URL

type SigOrTxn

+ Txid *url.TxID

+ type SigSetEntry struct

+ KeyEntryIndex uint64

+ SignatureHash [32]byte

+ Type protocol.SignatureType

+ ValidatorKeyHash *[32]byte

+ func (s *SigSetEntry) Compare(t *SigSetEntry) int

+ func (v *SigSetEntry) Copy() *SigSetEntry

+ func (v *SigSetEntry) CopyAsInterface() interface{}

+ func (v *SigSetEntry) Equal(u *SigSetEntry) bool

+ func (v *SigSetEntry) IsValid() error

+ func (v *SigSetEntry) MarshalBinary() ([]byte, error)

+ func (v *SigSetEntry) MarshalJSON() ([]byte, error)

+ func (v *SigSetEntry) UnmarshalBinary(data []byte) error

+ func (v *SigSetEntry) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *SigSetEntry) UnmarshalJSON(data []byte) error

type SignatureSet

+ func (s *SignatureSet) Entries() []SigSetEntry

+ func (s *SignatureSet) Version() uint64

+ type SystemData struct

+ func (c *SystemData) Commit() error

+ func (c *SystemData) IsDirty() bool

+ func (c *SystemData) Resolve(key record.Key) (record.Record, record.Key, error)

+ func (c *SystemData) SyntheticIndexIndex(block uint64) *record.Value[uint64]

type Transaction

+ func (c *Transaction) Chains() *record.Set[*TransactionChainEntry]

+ func (c *Transaction) Commit() error

+ func (c *Transaction) IsDirty() bool

+ func (c *Transaction) Main() *record.Value[*SigOrTxn]

+ func (c *Transaction) Produced() *record.Set[*url.TxID]

+ func (c *Transaction) Resolve(key record.Key) (record.Record, record.Key, error)

+ func (c *Transaction) Status() *record.Value[*protocol.TransactionStatus]

+ func (t *Transaction) AddSystemSignature(net *config.Describe, newSignature protocol.Signature) (int, error)

+ func (t *Transaction) RestoreSignatureSets(signer *url.URL, version uint64, entries []SigSetEntry) error

+ type TransactionChainEntry struct

+ Account *url.URL

+ AnchorIndex uint64

+ Chain string

+ ChainIndex uint64

+ func (e *TransactionChainEntry) Compare(f *TransactionChainEntry) int

+ func (v *TransactionChainEntry) Copy() *TransactionChainEntry

+ func (v *TransactionChainEntry) CopyAsInterface() interface{}

+ func (v *TransactionChainEntry) Equal(u *TransactionChainEntry) bool

+ func (v *TransactionChainEntry) IsValid() error

+ func (v *TransactionChainEntry) MarshalBinary() ([]byte, error)

+ func (v *TransactionChainEntry) UnmarshalBinary(data []byte) error

+ func (v *TransactionChainEntry) UnmarshalBinaryFrom(rd io.Reader) error

+ type Updater interface

+ Update func(func(batch *Batch) error) error

+ type Viewer interface

+ View func(func(batch *Batch) error) error

May 2, 2022

Changes in this version

type Account

+ func (r *Account) AddSyntheticForAnchor(anchor, hash [32]byte) error

+ func (r *Account) SyntheticForAnchor(anchor [32]byte) ([][32]byte, error)

type Batch

+ func (b *Batch) ExampleGetFullState(key storage.Key) ([]byte, error)

+ type SigOrTxn struct

+ Hash [32]byte

+ Signature protocol.Signature

+ Transaction *protocol.Transaction

+ func (v *SigOrTxn) Copy() *SigOrTxn

+ func (v *SigOrTxn) CopyAsInterface() interface{}

+ func (v *SigOrTxn) Equal(u *SigOrTxn) bool

+ func (v *SigOrTxn) IsValid() error

+ func (v *SigOrTxn) MarshalBinary() ([]byte, error)

+ func (v *SigOrTxn) MarshalJSON() ([]byte, error)

+ func (v *SigOrTxn) UnmarshalBinary(data []byte) error

+ func (v *SigOrTxn) UnmarshalBinaryFrom(rd io.Reader) error

+ func (v *SigOrTxn) UnmarshalJSON(data []byte) error

type Transaction

+ func (t *Transaction) ReadSignaturesForSigner(signer protocol.Signer) (*SignatureSet, error)

+ func (t *Transaction) SignaturesForSigner(signer protocol.Signer) (*SignatureSet, error)

Apr 6, 2022

Changes in this version

type Account

+ func (r *Account) IndexChain(name string, major bool) (*Chain, error)

+ func (r *Account) ReadIndexChain(name string, major bool) (*Chain, error)

+ func (r *Account) StateReceipt() (*managed.Receipt, error)

type Batch

+ func (b *Batch) AccountByKey(key storage.Key) *Account

+ func (b *Batch) Begin(writable bool) *Batch

+ func (b *Batch) BptReceipt(key storage.Key, value [32]byte) (*managed.Receipt, error)

+ func (b *Batch) CommitBpt() ([]byte, error)

+ func (b *Batch) GetMinorRootChainAnchor(network *config.Network) ([]byte, error)

+ func (b *Batch) Update(fn func(*Batch) error) error

+ func (b *Batch) View(fn func(*Batch) error) error

type Chain

+ func (c *Chain) AnchorAt(height uint64) ([]byte, error)

+ func (c *Chain) CurrentState() *managed.MerkleState

+ func (c *Chain) EntryAs(height int64, value encoding.BinaryUnmarshaler) error

type Database

+ func OpenBadger(filepath string, logger log.Logger) (*Database, error)

+ func OpenEtcd(prefix string, config *clientv3.Config, logger log.Logger) (*Database, error)

+ func OpenInMemory(logger log.Logger) *Database

+ func (d *Database) Update(fn func(*Batch) error) error

+ func (d *Database) View(fn func(*Batch) error) error

+ type SignatureSet struct

+ func (s *SignatureSet) Add(newSignature protocol.Signature) (int, error)

+ func (s *SignatureSet) Count() int

+ func (s *SignatureSet) EntryHashes() [][32]byte

type Transaction

+ func (t *Transaction) AddSignature(newSignature protocol.Signature) (int, error)

+ func (t *Transaction) PutSyntheticTxns(v *protocol.HashSet) error

+ func (t *Transaction) ReadSignatures(signer *url.URL) (*SignatureSet, error)

+ func (t *Transaction) Signatures(signer *url.URL) (*SignatureSet, error)

+ type TypedValue interface

+ CopyAsInterface func() interface{}

+ type ValueUnmarshalFunc func([]byte) (TypedValue, error)

Feb 27, 2022

Changes in this version

+ type Account struct

+ func (r *Account) Chain(name string, typ protocol.ChainType) (*Chain, error)

+ func (r *Account) Data() (*Data, error)

+ func (r *Account) GetObject() (*protocol.ObjectMetadata, error)

+ func (r *Account) GetState() (state.Chain, error)

+ func (r *Account) GetStateAs(state state.Chain) error

+ func (r *Account) Index(key ...interface{}) *Value

+ func (r *Account) PutBpt(hash [32]byte)

+ func (r *Account) PutState(accountState state.Chain) error

+ func (r *Account) ReadChain(name string) (*Chain, error)

+ type Batch struct

+ func (b *Batch) Account(u *url.URL) *Account

+ func (b *Batch) AccountByID(id []byte) *Account

+ func (b *Batch) Commit() error

+ func (b *Batch) Discard()

+ func (b *Batch) Import(db interface{ ... })

+ func (b *Batch) RootHash() []byte

+ func (b *Batch) Transaction(id []byte) *Transaction

+ func (b *Batch) UpdateBpt()

+ type Chain struct

+ func (c *Chain) AddEntry(entry []byte, unique bool) error

+ func (c *Chain) Anchor() []byte

+ func (c *Chain) Entries(start int64, end int64) ([][]byte, error)

+ func (c *Chain) Entry(height int64) ([]byte, error)

+ func (c *Chain) Height() int64

+ func (c *Chain) HeightOf(hash []byte) (int64, error)

+ func (c *Chain) Pending() []managed.Hash

+ func (c *Chain) Receipt(from, to int64) (*managed.Receipt, error)

+ func (c *Chain) State(height int64) (*managed.MerkleState, error)

+ type Data struct

+ func (d *Data) Entry(height int64) (*protocol.DataEntry, error)

+ func (d *Data) Get(hash []byte) (*protocol.DataEntry, error)

+ func (d *Data) GetHashes(start, end int64) ([][]byte, error)

+ func (d *Data) GetLatest() ([]byte, *protocol.DataEntry, error)

+ func (d *Data) Height() int64

+ func (d *Data) Put(hash []byte, entry *protocol.DataEntry) error

+ type Database struct

+ func New(store storage.KeyValueStore, logger log.Logger) *Database

+ func Open(file string, useMemDB bool, logger log.Logger) (*Database, error)

+ func (d *Database) Begin() *Batch

+ func (d *Database) Close() error

+ type Transaction struct

+ func (t *Transaction) AddSignatures(newSignatures ...protocol.Signature) (count int, err error)

+ func (t *Transaction) AddSyntheticTxns(txids ...[32]byte) error

+ func (t *Transaction) Get() (*state.Transaction, *protocol.TransactionStatus, []protocol.Signature, error)

+ func (t *Transaction) GetSignatures() ([]protocol.Signature, error)

+ func (t *Transaction) GetState() (*state.Transaction, error)

+ func (t *Transaction) GetStatus() (*protocol.TransactionStatus, error)

+ func (t *Transaction) GetSyntheticTxns() ([][32]byte, error)

+ func (t *Transaction) Index(key ...interface{}) *Value

+ func (t *Transaction) Put(state *state.Transaction, status *protocol.TransactionStatus, ...) error

+ func (t *Transaction) PutState(state *state.Transaction) error

+ func (t *Transaction) PutStatus(status *protocol.TransactionStatus) error

+ type Value struct

+ func (v *Value) Get() ([]byte, error)

+ func (v *Value) GetAs(u encoding.BinaryUnmarshaler) error

+ func (v *Value) Key() storage.Key

+ func (v *Value) Put(data []byte)

+ func (v *Value) PutAs(u encoding.BinaryMarshaler) error