notarization

package

Go to main page

Versions in this module

v0

v0.9.8

Sep 6, 2022

v0.9.7

Sep 5, 2022

v0.9.6

Sep 1, 2022

Changes in this version

type ManagerOption

+ func ManaEpochDelay(manaEpochDelay uint) ManagerOption

v0.9.5

Aug 31, 2022

Changes in this version

+ type ActivityTreeUpdatedEvent struct

+ EI epoch.Index

+ NodeID identity.ID

+ type CompetingCommitmentDetectedEvent struct

+ Block *tangleold.Block

type EpochCommitmentFactory

+ func (f *EpochCommitmentFactory) ECRandRoots(ei epoch.Index) (ecr epoch.ECR, roots *epoch.CommitmentRoots, err error)

+ type EpochConfirmedEvent struct

+ EI epoch.Index

type Events

+ ActivityTreeInserted *event.Event[*ActivityTreeUpdatedEvent]

+ ActivityTreeRemoved *event.Event[*ActivityTreeUpdatedEvent]

+ CompetingCommitmentDetected *event.Event[*CompetingCommitmentDetectedEvent]

+ EpochConfirmed *event.Event[*EpochConfirmedEvent]

+ SyncRange *event.Event[*SyncRangeEvent]

type Manager

+ func (m *Manager) EndSnapshot()

+ func (m *Manager) GetEpochDiff(ei epoch.Index) (spent []*ledger.OutputWithMetadata, created []*ledger.OutputWithMetadata)

+ func (m *Manager) LoadActivityLogs(epochActivity epoch.SnapshotEpochActivity)

+ func (m *Manager) LoadEpochDiff(epochDiff *ledger.EpochDiff)

+ func (m *Manager) OnBlockStored(block *tangleold.Block)

+ func (m *Manager) SnapshotEpochActivity(epochDiffIndex epoch.Index) (epochActivity epoch.SnapshotEpochActivity, err error)

+ func (m *Manager) StartSnapshot() (fullEpochIndex epoch.Index, ecRecord *epoch.ECRecord, err error)

+ type SyncRangeEvent struct

+ EndEI epoch.Index

+ EndPrevEC epoch.EC

+ StartEC epoch.EC

+ StartEI epoch.Index

v0.9.4

Aug 8, 2022

Changes in this version

+ var TestBlockAcceptanceStateTranslation acceptance.BlockThresholdTranslation = func(aw float64) confirmation.State

+ var TestConflictAcceptanceStateTranslation acceptance.ConflictThresholdTranslation = func(conflictID utxo.TransactionID, aw float64) confirmation.State

+ func EC(ecRecord *epoch.ECRecord) (ec epoch.EC)

+ type BootstrappedEvent struct

+ EI epoch.Index

+ type CommitmentProof struct

+ EI epoch.Index

+ type CommitmentRoots struct

+ EI epoch.Index

+ type CommitmentTrees struct

+ EI epoch.Index

+ type EpochCommitmentFactory struct

+ func NewEpochCommitmentFactory(store kvstore.KVStore, tangle *tangleold.Tangle, snapshotDepth int) *EpochCommitmentFactory

+ func (f *EpochCommitmentFactory) ECR(ei epoch.Index) (ecr epoch.ECR, err error)

+ func (f *EpochCommitmentFactory) ManaRoot() []byte

+ func (f *EpochCommitmentFactory) ProofStateMutationRoot(ei epoch.Index, txID utxo.TransactionID) (*CommitmentProof, error)

+ func (f *EpochCommitmentFactory) ProofStateRoot(ei epoch.Index, outID utxo.OutputID) (*CommitmentProof, error)

+ func (f *EpochCommitmentFactory) ProofTangleRoot(ei epoch.Index, blockID tangleold.BlockID) (*CommitmentProof, error)

+ func (f *EpochCommitmentFactory) StateRoot() []byte

+ func (f *EpochCommitmentFactory) VerifyStateMutationRoot(proof CommitmentProof, transactionID utxo.TransactionID) bool

+ func (f *EpochCommitmentFactory) VerifyTangleRoot(proof CommitmentProof, blockID tangleold.BlockID) bool

+ type EpochCommitmentStorage struct

+ func (s *EpochCommitmentStorage) CachedECRecord(ei epoch.Index, ...) (cachedEpochDiff *objectstorage.CachedObject[*epoch.ECRecord])

+ type EpochCommittableEvent struct

+ ECRecord *epoch.ECRecord

+ EI epoch.Index

+ type EventMock struct

+ func NewEventMock(t *testing.T, notarizationManager *Manager) *EventMock

+ func (e *EventMock) AssertExpectations(t mock.TestingT) bool

+ func (e *EventMock) DetachAll()

+ func (e *EventMock) EpochCommittable(event *EpochCommittableEvent)

+ func (e *EventMock) Expect(eventName string, arguments ...interface{})

+ func (e *EventMock) ManaVectorUpdate(event *ManaVectorUpdateEvent)

+ type Events struct

+ Bootstrapped *event.Event[*BootstrappedEvent]

+ EpochCommittable *event.Event[*EpochCommittableEvent]

+ ManaVectorUpdate *event.Event[*ManaVectorUpdateEvent]

+ StateMutationTreeInserted *event.Event[*StateMutationTreeUpdatedEvent]

+ StateMutationTreeRemoved *event.Event[*StateMutationTreeUpdatedEvent]

+ TangleTreeInserted *event.Event[*TangleTreeUpdatedEvent]

+ TangleTreeRemoved *event.Event[*TangleTreeUpdatedEvent]

+ UTXOTreeInserted *event.Event[*UTXOUpdatedEvent]

+ UTXOTreeRemoved *event.Event[*UTXOUpdatedEvent]

+ type ManaVectorUpdateEvent struct

+ EI epoch.Index

+ EpochDiffCreated []*ledger.OutputWithMetadata

+ EpochDiffSpent []*ledger.OutputWithMetadata

+ type Manager struct

+ Events *Events

+ func NewManager(epochCommitmentFactory *EpochCommitmentFactory, t *tangleold.Tangle, ...) (new *Manager)

+ func (m *Manager) Bootstrapped() bool

+ func (m *Manager) GetBlockInclusionProof(blockID tangleold.BlockID) (*CommitmentProof, error)

+ func (m *Manager) GetLatestEC() (ecRecord *epoch.ECRecord, err error)

+ func (m *Manager) GetTransactionInclusionProof(transactionID utxo.TransactionID) (*CommitmentProof, error)

+ func (m *Manager) LatestConfirmedEpochIndex() (epoch.Index, error)

+ func (m *Manager) LoadECandEIs(header *ledger.SnapshotHeader)

+ func (m *Manager) LoadEpochDiffs(header *ledger.SnapshotHeader, epochDiffs map[epoch.Index]*ledger.EpochDiff)

+ func (m *Manager) LoadOutputsWithMetadata(outputsWithMetadatas []*ledger.OutputWithMetadata)

+ func (m *Manager) OnAcceptanceTimeUpdated(newTime time.Time)

+ func (m *Manager) OnBlockAccepted(block *tangleold.Block)

+ func (m *Manager) OnBlockOrphaned(block *tangleold.Block)

+ func (m *Manager) OnConflictAccepted(conflictID utxo.TransactionID)

+ func (m *Manager) OnConflictCreated(conflictID utxo.TransactionID)

+ func (m *Manager) OnConflictRejected(conflictID utxo.TransactionID)

+ func (m *Manager) OnTransactionAccepted(event *ledger.TransactionAcceptedEvent)

+ func (m *Manager) OnTransactionInclusionUpdated(event *ledger.TransactionInclusionUpdatedEvent)

+ func (m *Manager) PendingConflictsCount(ei epoch.Index) (pendingConflictsCount uint64)

+ func (m *Manager) PendingConflictsCountAll() (pendingConflicts map[epoch.Index]uint64)

+ func (m *Manager) ReadLockLedger()

+ func (m *Manager) ReadUnlockLedger()

+ func (m *Manager) Shutdown()

+ func (m *Manager) SnapshotEpochDiffs(lastConfirmedEpoch, latestCommittableEpoch epoch.Index) (map[epoch.Index]*ledger.EpochDiff, error)

+ func (m *Manager) SnapshotLedgerState(lastConfirmedEpoch epoch.Index, prodChan chan *ledger.OutputWithMetadata)

+ func (m *Manager) WriteLockLedger()

+ func (m *Manager) WriteUnlockLedger()

+ type ManagerOption func(options *ManagerOptions)

+ func BootstrapWindow(d time.Duration) ManagerOption

+ func Log(log *logger.Logger) ManagerOption

+ func ManaDelay(d uint) ManagerOption

+ func MinCommittableEpochAge(d time.Duration) ManagerOption

+ type ManagerOptions struct

+ BootstrapWindow time.Duration

+ Log *logger.Logger

+ ManaEpochDelay uint

+ MinCommittableEpochAge time.Duration

+ type Option func(*options)

+ func WithStore(store kvstore.KVStore) (option Option)

+ type StateMutationTreeUpdatedEvent struct

+ EI epoch.Index

+ TransactionID utxo.TransactionID

+ type TangleTreeUpdatedEvent struct

+ BlockID tangleold.BlockID

+ EI epoch.Index

+ type UTXOUpdatedEvent struct

+ Created []*ledger.OutputWithMetadata

+ EI epoch.Index

+ Spent []*ledger.OutputWithMetadata

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL