checkpoint

Documentation

Index

• Constants
• type Checkpointer
  • func NewCheckpointer(machine *vm.Machine, destroyOldCheckpoints bool) (*Checkpointer, error)
  • func (cp *Checkpointer) AddRefToValue(val value.Value) error
  • func (cp *Checkpointer) Close() error
  • func (cp *Checkpointer) EntryExists(key []byte) (bool, error)
  • func (cp *Checkpointer) RemoveRefToValue(hash common.Hash)
  • func (cp *Checkpointer) RestoreMachine(keySuffix []byte) (*vm.Machine, error)
  • func (cp *Checkpointer) RestoreValueFromHash(hash common.Hash) (value.Value, error)
  • func (cp *Checkpointer) SaveCode(machine *vm.Machine) error
  • func (cp *Checkpointer) SaveMachine(keySuffix []byte, machine *vm.Machine) error
• type Error
  • func (e Error) Error() string
• type EventChainCheckpointer
  • func NewEventChainCheckpointer(cp *Checkpointer, keySuffix []byte, machine *vm.Machine, timeBounds [2]uint64) (*EventChainCheckpointer, error)
  • func RestoreEventChainCheckpointer(cp *Checkpointer, keySuffix []byte) (*EventChainCheckpointer, error)
  • func (ecc *EventChainCheckpointer) Discard() error
  • func (ecc *EventChainCheckpointer) RecordIntentToSign(seqNum uint64, machine *vm.Machine, inbox value.Value) error
  • func (ecc *EventChainCheckpointer) RecordSignatures(seqNum uint64, marshaledSigs []byte) error
  • func (ecc *EventChainCheckpointer) RestoreChainStartMachine() (*vm.Machine, error)
  • func (ecc *EventChainCheckpointer) RestoreFromSeqNum(seqNum uint64) (*vm.Machine, value.Value, []byte, error)
• type VersionedCheckpointer
  • func NewVersionedCheckpointer(cp *Checkpointer) (*VersionedCheckpointer, error)
  • func (vcp *VersionedCheckpointer) Close() error
  • func (vcp *VersionedCheckpointer) DiscardVersions(newMinVersionNum int64) error
  • func (vcp *VersionedCheckpointer) IsKnownVersion(num int64) bool
  • func (vcp *VersionedCheckpointer) KnownVersions() (minVersionNum, maxVersionNum int64)
  • func (vcp *VersionedCheckpointer) RestoreVersion(versionNum int64) (machine *vm.Machine, stateData []byte, retError error)
  • func (vcp *VersionedCheckpointer) SaveVersion(machine *vm.Machine, stateData []byte) (versionNum int64, returnErr error)

Constants

const PrefixValue byte = iota

Types

type Checkpointer

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

func NewCheckpointer

func NewCheckpointer(machine *vm.Machine, destroyOldCheckpoints bool) (*Checkpointer, error)

func (*Checkpointer) AddRefToValue

func (cp *Checkpointer) AddRefToValue(val value.Value) error

func (*Checkpointer) Close

func (cp *Checkpointer) Close() error

func (*Checkpointer) EntryExists

func (cp *Checkpointer) EntryExists(key []byte) (bool, error)

func (*Checkpointer) RemoveRefToValue

func (cp *Checkpointer) RemoveRefToValue(hash common.Hash)

func (*Checkpointer) RestoreMachine

func (cp *Checkpointer) RestoreMachine(keySuffix []byte) (*vm.Machine, error)

func (*Checkpointer) RestoreValueFromHash

func (cp *Checkpointer) RestoreValueFromHash(hash common.Hash) (value.Value, error)

func (*Checkpointer) SaveCode

func (cp *Checkpointer) SaveCode(machine *vm.Machine) error

func (*Checkpointer) SaveMachine

func (cp *Checkpointer) SaveMachine(keySuffix []byte, machine *vm.Machine) error

type Error

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

func (Error) Error

func (e Error) Error() string

type EventChainCheckpointer

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

func NewEventChainCheckpointer

func NewEventChainCheckpointer(
	cp *Checkpointer,
	keySuffix []byte,
	machine *vm.Machine,
	timeBounds [2]uint64,
) (*EventChainCheckpointer, error)

func RestoreEventChainCheckpointer

func RestoreEventChainCheckpointer(cp *Checkpointer, keySuffix []byte) (*EventChainCheckpointer, error)

func (*EventChainCheckpointer) Discard

func (ecc *EventChainCheckpointer) Discard() error

func (*EventChainCheckpointer) RecordIntentToSign

func (ecc *EventChainCheckpointer) RecordIntentToSign(seqNum uint64, machine *vm.Machine, inbox value.Value) error

func (*EventChainCheckpointer) RecordSignatures

func (ecc *EventChainCheckpointer) RecordSignatures(seqNum uint64, marshaledSigs []byte) error

func (*EventChainCheckpointer) RestoreChainStartMachine

func (ecc *EventChainCheckpointer) RestoreChainStartMachine() (*vm.Machine, error)

func (*EventChainCheckpointer) RestoreFromSeqNum

func (ecc *EventChainCheckpointer) RestoreFromSeqNum(seqNum uint64) (*vm.Machine, value.Value, []byte, error)

type VersionedCheckpointer

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

func NewVersionedCheckpointer

func NewVersionedCheckpointer(cp *Checkpointer) (*VersionedCheckpointer, error)

func (*VersionedCheckpointer) Close

func (vcp *VersionedCheckpointer) Close() error

func (*VersionedCheckpointer) DiscardVersions

func (vcp *VersionedCheckpointer) DiscardVersions(newMinVersionNum int64) error

func (*VersionedCheckpointer) IsKnownVersion

func (vcp *VersionedCheckpointer) IsKnownVersion(num int64) bool

func (*VersionedCheckpointer) KnownVersions

func (vcp *VersionedCheckpointer) KnownVersions() (minVersionNum, maxVersionNum int64)

func (*VersionedCheckpointer) RestoreVersion

func (vcp *VersionedCheckpointer) RestoreVersion(versionNum int64) (machine *vm.Machine, stateData []byte, retError error)

func (*VersionedCheckpointer) SaveVersion

func (vcp *VersionedCheckpointer) SaveVersion(machine *vm.Machine, stateData []byte) (versionNum int64, returnErr error)