checkpoint

Documentation

Index

• type CheckpointError
  • func (e CheckpointError) Error() string
• 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 [32]byte)
  • func (cp *Checkpointer) RestoreMachine(keySuffix []byte) (*vm.Machine, error)
  • func (cp *Checkpointer) RestoreValueFromHash(hash [32]byte) (value.Value, error)
  • func (cp *Checkpointer) SaveCode(machine *vm.Machine) error
  • func (cp *Checkpointer) SaveMachine(keySuffix []byte, machine *vm.Machine) error
• 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)

Types

type CheckpointError

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

func (CheckpointError) Error

func (e CheckpointError) Error() string

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 [32]byte)

func (*Checkpointer) RestoreMachine

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

func (*Checkpointer) RestoreValueFromHash

func (cp *Checkpointer) RestoreValueFromHash(hash [32]byte) (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 EventChainCheckpointer

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

func NewEventChainCheckpointer

func NewEventChainCheckpointer(
	cp *Checkpointer,
	keySuffix []byte,
	machine *vm.Machine,
	timeBounds [2]uint64,
	balances *protocol.BalanceTracker) (*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)