▽

Documents Packages The Project Help Blog

Package kvledger

Variables

var (
    // ErrLedgerIDExists is thrown by a CreateLedger call if a ledger with the given id already exists
    ErrLedgerIDExists = errors.New("LedgerID already exists")
    // ErrNonExistingLedgerID is thrown by a OpenLedger call if a ledger with the given id does not exist
    ErrNonExistingLedgerID = errors.New("LedgerID does not exist")
    // ErrLedgerNotOpened is thrown by a CloseLedger call if a ledger with the given id has not been opened
    ErrLedgerNotOpened = errors.New("ledger is not opened yet")
)

func ClearPreResetHeight ¶

func ClearPreResetHeight() error

func LoadPreResetHeight ¶

func LoadPreResetHeight() (map[string]uint64, error)

LoadPreResetHeight returns the pre-reset height of all ledgers.

func NewProvider ¶

func NewProvider() (ledger.PeerLedgerProvider, error)

NewProvider instantiates a new Provider. This is not thread-safe and assumed to be synchronized be the caller

func ResetAllKVLedgers ¶

func ResetAllKVLedgers() error

ResetAllKVLedgers resets all ledger to the genesis block.

func RollbackKVLedger ¶

func RollbackKVLedger(ledgerID string, blockNum uint64) error

RollbackKVLedger rollbacks a ledger to a specified block number

type Provider ¶

Provider implements interface ledger.PeerLedgerProvider

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

func (*Provider) Close ¶

func (provider *Provider) Close()

Close implements the corresponding method from interface ledger.PeerLedgerProvider

func (*Provider) Create ¶

func (provider *Provider) Create(genesisBlock *common.Block) (ledger.PeerLedger, error)

Create implements the corresponding method from interface ledger.PeerLedgerProvider This functions sets a under construction flag before doing any thing related to ledger creation and upon a successful ledger creation with the committed genesis block, removes the flag and add entry into created ledgers list (atomically). If a crash happens in between, the 'recoverUnderConstructionLedger' function is invoked before declaring the provider to be usable

func (*Provider) Exists ¶

func (provider *Provider) Exists(ledgerID string) (bool, error)

Exists implements the corresponding method from interface ledger.PeerLedgerProvider

func (*Provider) Initialize ¶

func (provider *Provider) Initialize(initializer *ledger.Initializer) error

Initialize implements the corresponding method from interface ledger.PeerLedgerProvider

func (*Provider) List ¶

func (provider *Provider) List() ([]string, error)

List implements the corresponding method from interface ledger.PeerLedgerProvider

func (*Provider) Open ¶

func (provider *Provider) Open(ledgerID string) (ledger.PeerLedger, error)

Open implements the corresponding method from interface ledger.PeerLedgerProvider

Subdirectories