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 AnyPayloadType + const MaxReprocessBufferSize + const ModuleName + type Config struct + BootstrapNodes []string + ConnectionTimeout int + EnableDiscovery bool + GrpcAddr string + IdleTimeout time.Duration + MaxBackoff time.Duration + NodeDID string + ProtocolV2 v2.Config + Protocols []int + func DefaultConfig() Config + func TestNetworkConfig() Config + func (c Config) IsProtocolEnabled(version int) bool + type EventType string + type MockTransactions struct + func NewMockTransactions(ctrl *gomock.Controller) *MockTransactions + func (m *MockTransactions) AddressBook() []transport.Contact + func (m *MockTransactions) CleanupSubscriberEvents(subcriberName, errorPrefix string) error + func (m *MockTransactions) CreateTransaction(ctx context.Context, spec Template) (dag.Transaction, error) + func (m *MockTransactions) DiscoverServices(updatedDID did.DID) + func (m *MockTransactions) EXPECT() *MockTransactionsMockRecorder + func (m *MockTransactions) GetTransaction(transactionRef hash.SHA256Hash) (dag.Transaction, error) + func (m *MockTransactions) GetTransactionPayload(transactionRef hash.SHA256Hash) ([]byte, error) + func (m *MockTransactions) ListTransactionsInRange(startInclusive, endExclusive uint32) ([]dag.Transaction, error) + func (m *MockTransactions) PeerDiagnostics() map[transport.PeerID]transport.Diagnostics + func (m *MockTransactions) Reprocess(ctx context.Context, contentType string) (*ReprocessReport, error) + func (m *MockTransactions) Subscribe(name string, receiver dag.ReceiverFn, filters ...SubscriberOption) error + func (m *MockTransactions) Subscribers() []dag.Notifier + func (m *MockTransactions) WithPersistency() SubscriberOption + type MockTransactionsMockRecorder struct + func (mr *MockTransactionsMockRecorder) AddressBook() *gomock.Call + func (mr *MockTransactionsMockRecorder) CleanupSubscriberEvents(subcriberName, errorPrefix interface{}) *gomock.Call + func (mr *MockTransactionsMockRecorder) CreateTransaction(ctx, spec interface{}) *gomock.Call + func (mr *MockTransactionsMockRecorder) DiscoverServices(updatedDID interface{}) *gomock.Call + func (mr *MockTransactionsMockRecorder) GetTransaction(transactionRef interface{}) *gomock.Call + func (mr *MockTransactionsMockRecorder) GetTransactionPayload(transactionRef interface{}) *gomock.Call + func (mr *MockTransactionsMockRecorder) ListTransactionsInRange(startInclusive, endExclusive interface{}) *gomock.Call + func (mr *MockTransactionsMockRecorder) PeerDiagnostics() *gomock.Call + func (mr *MockTransactionsMockRecorder) Reprocess(ctx, contentType interface{}) *gomock.Call + func (mr *MockTransactionsMockRecorder) Subscribe(name, receiver interface{}, filters ...interface{}) *gomock.Call + func (mr *MockTransactionsMockRecorder) Subscribers() *gomock.Call + func (mr *MockTransactionsMockRecorder) WithPersistency() *gomock.Call + type Network struct + func NewNetworkInstance(config Config, store didstore.Store, keyStore crypto.KeyStore, ...) *Network + func NewTestNetworkInstance(t *testing.T) *Network + func (n *Network) AddressBook() []transport.Contact + func (n *Network) CheckHealth() map[string]core.Health + func (n *Network) CleanupSubscriberEvents(subscriberName, errorPrefix string) error + func (n *Network) Config() interface{} + func (n *Network) Configure(config core.ServerConfig) error + func (n *Network) CreateTransaction(ctx context.Context, template Template) (dag.Transaction, error) + func (n *Network) Diagnostics() []core.DiagnosticResult + func (n *Network) DiscoverServices(updatedDID did.DID) + func (n *Network) GetTransaction(transactionRef hash.SHA256Hash) (dag.Transaction, error) + func (n *Network) GetTransactionPayload(transactionRef hash.SHA256Hash) ([]byte, error) + func (n *Network) ListTransactionsInRange(startInclusive uint32, endExclusive uint32) ([]dag.Transaction, error) + func (n *Network) Migrate() error + func (n *Network) Name() string + func (n *Network) PeerDiagnostics() map[transport.PeerID]transport.Diagnostics + func (n *Network) Reprocess(ctx context.Context, contentType string) (*ReprocessReport, error) + func (n *Network) Shutdown() error + func (n *Network) Start() error + func (n *Network) Subscribe(name string, subscriber dag.ReceiverFn, options ...SubscriberOption) error + func (n *Network) Subscribers() []dag.Notifier + func (n *Network) WithPersistency() SubscriberOption + type Receiver func(transaction dag.Transaction, payload []byte) error + type ReprocessReport struct + type SubscriberOption func() dag.NotifierOption + func WithSelectionFilter(filter dag.NotificationFilter) SubscriberOption + type Template struct + AdditionalPrevs []hash.SHA256Hash + AttachKey bool + Key crypto.Key + Participants dag.PAL + Payload []byte + Timestamp time.Time + Type string + func TransactionTemplate(payloadType string, payload []byte, key crypto.Key) Template + func (t Template) WithAdditionalPrevs(additionalPrevs []hash.SHA256Hash) Template + func (t Template) WithAttachKey() Template + func (t Template) WithPrivate(participants []did.DID) Template + func (t Template) WithTimestamp(timestamp time.Time) Template + type Transactions interface + AddressBook func() []transport.Contact + CleanupSubscriberEvents func(subcriberName, errorPrefix string) error + CreateTransaction func(ctx context.Context, spec Template) (dag.Transaction, error) + DiscoverServices func(updatedDID did.DID) + GetTransaction func(transactionRef hash.SHA256Hash) (dag.Transaction, error) + GetTransactionPayload func(transactionRef hash.SHA256Hash) ([]byte, error) + ListTransactionsInRange func(startInclusive uint32, endExclusive uint32) ([]dag.Transaction, error) + PeerDiagnostics func() map[transport.PeerID]transport.Diagnostics + Reprocess func(ctx context.Context, contentType string) (*ReprocessReport, error) + Subscribe func(name string, receiver dag.ReceiverFn, filters ...SubscriberOption) error + Subscribers func() []dag.Notifier + WithPersistency func() SubscriberOption Other modules containing this package github.com/nuts-foundation/nuts-node github.com/nuts-foundation/nuts-node/v6
Go to main page