Versions in this module Expand all Collapse all v5 v5.4.40 Sep 22, 2026 v5.4.39 Sep 21, 2026 Changes in this version + const IbltNumBuckets + const MaxLamportClock + const PageSize + const PayloadEventType + const TransactionCountDiagnostic + const TransactionEventType + var ErrInvalidLamportClockValue = errors.New("transaction has an invalid lamport clock value") + var ErrPayloadNotFound = errors.New("payload not found") + var ErrPreviousTransactionMissing = errors.New("transaction is referring to non-existing previous transaction") + var ErrTransactionNotFound = errors.New("transaction not found") + func CreateDAG(t *testing.T) *dag + func ValidatePayloadType(payloadType string) bool + type Addressable interface + PAL func() [][]byte + type DotGraphVisitor struct + func NewDotGraphVisitor(labelStyle LabelStyle) *DotGraphVisitor + func (d *DotGraphVisitor) Accept(transaction Transaction) bool + func (d *DotGraphVisitor) Render() string + type EncryptedPAL [][]byte + func (epal EncryptedPAL) Decrypt(ctx context.Context, keyAgreementKIDs []string, decryptor crypto.Decrypter) (PAL, error) + type Event struct + Error string + Hash hash.SHA256Hash + Latest *time.Time + Payload []byte + Retries int + Transaction Transaction + Type string + func (j *Event) UnmarshalJSON(bytes []byte) error + type EventFatal struct + Err error + func (e EventFatal) Error() string + func (e EventFatal) Unwrap() error + type LabelStyle int + const ShowAliasLabelStyle + const ShowRefLabelStyle + const ShowShortRefLabelStyle + type MockNotifier struct + func NewMockNotifier(ctrl *gomock.Controller) *MockNotifier + func (m *MockNotifier) Close() error + func (m *MockNotifier) EXPECT() *MockNotifierMockRecorder + func (m *MockNotifier) Finished(hash hash.SHA256Hash) error + func (m *MockNotifier) GetFailedEvents() ([]Event, error) + func (m *MockNotifier) Name() string + func (m *MockNotifier) Notify(event Event) + func (m *MockNotifier) Run() error + func (m *MockNotifier) Save(tx stoabs.WriteTx, event Event) error + type MockNotifierMockRecorder struct + func (mr *MockNotifierMockRecorder) Close() *gomock.Call + func (mr *MockNotifierMockRecorder) Finished(hash interface{}) *gomock.Call + func (mr *MockNotifierMockRecorder) GetFailedEvents() *gomock.Call + func (mr *MockNotifierMockRecorder) Name() *gomock.Call + func (mr *MockNotifierMockRecorder) Notify(event interface{}) *gomock.Call + func (mr *MockNotifierMockRecorder) Run() *gomock.Call + func (mr *MockNotifierMockRecorder) Save(tx, event interface{}) *gomock.Call + type MockPayloadStore struct + func NewMockPayloadStore(ctrl *gomock.Controller) *MockPayloadStore + func (m *MockPayloadStore) EXPECT() *MockPayloadStoreMockRecorder + type MockPayloadStoreMockRecorder struct + type MockState struct + func NewMockState(ctrl *gomock.Controller) *MockState + func (m *MockState) Add(ctx context.Context, transactions Transaction, payload []byte) error + func (m *MockState) CorrectStateDetected() + func (m *MockState) Diagnostics() []core.DiagnosticResult + func (m *MockState) EXPECT() *MockStateMockRecorder + func (m *MockState) FindBetweenLC(ctx context.Context, startInclusive, endExclusive uint32) ([]Transaction, error) + func (m *MockState) GetTransaction(ctx context.Context, hash hash.SHA256Hash) (Transaction, error) + func (m *MockState) Head(ctx context.Context) (hash.SHA256Hash, error) + func (m *MockState) IBLT(reqClock uint32) (tree.Iblt, uint32) + func (m *MockState) IncorrectStateDetected() + func (m *MockState) IsPayloadPresent(ctx context.Context, payloadHash hash.SHA256Hash) (bool, error) + func (m *MockState) IsPresent(arg0 context.Context, arg1 hash.SHA256Hash) (bool, error) + func (m *MockState) Migrate() error + func (m *MockState) Notifier(name string, receiver ReceiverFn, filters ...NotifierOption) (Notifier, error) + func (m *MockState) Notifiers() []Notifier + func (m *MockState) ReadPayload(ctx context.Context, payloadHash hash.SHA256Hash) ([]byte, error) + func (m *MockState) Shutdown() error + func (m *MockState) Start() error + func (m *MockState) Verify(ctx context.Context) error + func (m *MockState) WritePayload(ctx context.Context, transaction Transaction, payloadHash hash.SHA256Hash, ...) error + func (m *MockState) XOR(reqClock uint32) (hash.SHA256Hash, uint32) + type MockStateMockRecorder struct + func (mr *MockStateMockRecorder) Add(ctx, transactions, payload interface{}) *gomock.Call + func (mr *MockStateMockRecorder) CorrectStateDetected() *gomock.Call + func (mr *MockStateMockRecorder) Diagnostics() *gomock.Call + func (mr *MockStateMockRecorder) FindBetweenLC(ctx, startInclusive, endExclusive interface{}) *gomock.Call + func (mr *MockStateMockRecorder) GetTransaction(ctx, hash interface{}) *gomock.Call + func (mr *MockStateMockRecorder) Head(ctx interface{}) *gomock.Call + func (mr *MockStateMockRecorder) IBLT(reqClock interface{}) *gomock.Call + func (mr *MockStateMockRecorder) IncorrectStateDetected() *gomock.Call + func (mr *MockStateMockRecorder) IsPayloadPresent(ctx, payloadHash interface{}) *gomock.Call + func (mr *MockStateMockRecorder) IsPresent(arg0, arg1 interface{}) *gomock.Call + func (mr *MockStateMockRecorder) Migrate() *gomock.Call + func (mr *MockStateMockRecorder) Notifier(name, receiver interface{}, filters ...interface{}) *gomock.Call + func (mr *MockStateMockRecorder) Notifiers() *gomock.Call + func (mr *MockStateMockRecorder) ReadPayload(ctx, payloadHash interface{}) *gomock.Call + func (mr *MockStateMockRecorder) Shutdown() *gomock.Call + func (mr *MockStateMockRecorder) Start() *gomock.Call + func (mr *MockStateMockRecorder) Verify(ctx interface{}) *gomock.Call + func (mr *MockStateMockRecorder) WritePayload(ctx, transaction, payloadHash, data interface{}) *gomock.Call + func (mr *MockStateMockRecorder) XOR(reqClock interface{}) *gomock.Call + type NetworkHeader interface + Previous func() []hash.SHA256Hash + Version func() Version + type NotificationFilter func(event Event) bool + type Notifier interface + Close func() error + Finished func(hash hash.SHA256Hash) error + GetFailedEvents func() ([]Event, error) + Name func() string + Notify func(event Event) + Run func() error + Save func(tx stoabs.WriteTx, event Event) error + func NewNotifier(name string, receiverFn ReceiverFn, options ...NotifierOption) Notifier + type NotifierOption func(notifier *notifier) + func WithContext(ctx context.Context) NotifierOption + func WithPersistency(db stoabs.KVStore) NotifierOption + func WithRetryDelay(delay time.Duration) NotifierOption + func WithSelectionFilter(filter NotificationFilter) NotifierOption + type PAL []did.DID + func (pal PAL) Contains(id did.DID) bool + func (pal PAL) Encrypt(keyResolver types.KeyResolver) (EncryptedPAL, error) + type PayloadReferencer interface + PayloadHash func() hash.SHA256Hash + PayloadType func() string + type PayloadStore interface + func NewPayloadStore() PayloadStore + type ReceiverFn func(event Event) (bool, error) + type Referencable interface + Ref func() hash.SHA256Hash + type Signable interface + SigningAlgorithm func() string + SigningKey func() jwk.Key + SigningKeyID func() string + SigningTime func() time.Time + type State interface + Add func(ctx context.Context, transactions Transaction, payload []byte) error + CorrectStateDetected func() + FindBetweenLC func(ctx context.Context, startInclusive uint32, endExclusive uint32) ([]Transaction, error) + GetTransaction func(ctx context.Context, hash hash.SHA256Hash) (Transaction, error) + Head func(ctx context.Context) (hash.SHA256Hash, error) + IBLT func(reqClock uint32) (tree.Iblt, uint32) + IncorrectStateDetected func() + IsPayloadPresent func(ctx context.Context, payloadHash hash.SHA256Hash) (bool, error) + IsPresent func(context.Context, hash.SHA256Hash) (bool, error) + Notifier func(name string, receiver ReceiverFn, filters ...NotifierOption) (Notifier, error) + Notifiers func() []Notifier + ReadPayload func(ctx context.Context, payloadHash hash.SHA256Hash) ([]byte, error) + Shutdown func() error + Start func() error + Verify func(ctx context.Context) error + WritePayload func(ctx context.Context, transaction Transaction, payloadHash hash.SHA256Hash, ...) error + XOR func(reqClock uint32) (hash.SHA256Hash, uint32) + func NewState(db stoabs.KVStore, verifiers ...Verifier) (State, error) + type Statistics struct + DataSize int64 + NumberOfTransactions uint + type Transaction interface + Data func() []byte + func CreateSignedTestTransaction(payloadNum uint32, signingTime time.Time, pal [][]byte, payloadType string, ...) Transaction + func CreateTestTransaction(num uint32, prevs ...Transaction) (Transaction, string, crypto.PublicKey) + func CreateTestTransactionEx(num uint32, payloadHash hash.SHA256Hash, participants EncryptedPAL, ...) (Transaction, string, crypto.PublicKey) + func CreateTestTransactionWithJWK(num uint32, prevs ...Transaction) Transaction + func ParseTransaction(input []byte) (Transaction, error) + type TransactionSigner interface + Sign func(ctx context.Context, input UnsignedTransaction, signingTime time.Time) (Transaction, error) + func NewTransactionSigner(signer crypto.JWTSigner, key crypto.Key, attach bool) TransactionSigner + type UnsignedTransaction interface + Clock func() uint32 + func NewTransaction(payload hash.SHA256Hash, payloadType string, prevs []hash.SHA256Hash, ...) (UnsignedTransaction, error) + type Verifier func(tx stoabs.ReadTx, transaction Transaction) error + func NewPrevTransactionsVerifier() Verifier + func NewTransactionSignatureVerifier(resolver types.KeyResolver) Verifier + type Version int + type Visitor func(transaction Transaction) bool Other modules containing this package github.com/nuts-foundation/nuts-node github.com/nuts-foundation/nuts-node/v6
Go to main page