Versions in this module Expand all Collapse all v6 v6.2.13 Sep 22, 2026 v6.2.12 Sep 21, 2026 Changes in this version + const MaxReprocessBufferSize + const ModuleName + var ErrDIDNutsDisabled = errors.New("network operations not supported; did:nuts support not configured") + 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) CreateTransaction(ctx context.Context, spec Template) (dag.Transaction, error) + func (m *MockTransactions) Disabled() bool + 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) CreateTransaction(ctx, spec any) *gomock.Call + func (mr *MockTransactionsMockRecorder) Disabled() *gomock.Call + func (mr *MockTransactionsMockRecorder) DiscoverServices(updatedDID any) *gomock.Call + func (mr *MockTransactionsMockRecorder) GetTransaction(transactionRef any) *gomock.Call + func (mr *MockTransactionsMockRecorder) GetTransactionPayload(transactionRef any) *gomock.Call + func (mr *MockTransactionsMockRecorder) ListTransactionsInRange(startInclusive, endExclusive any) *gomock.Call + func (mr *MockTransactionsMockRecorder) PeerDiagnostics() *gomock.Call + func (mr *MockTransactionsMockRecorder) Reprocess(ctx, contentType any) *gomock.Call + func (mr *MockTransactionsMockRecorder) Subscribe(name, receiver any, filters ...any) *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) Disabled() bool + 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 + KID string + Participants dag.PAL + Payload []byte + PublicKey crypto.PublicKey + Timestamp time.Time + Type string + func TransactionTemplate(payloadType string, payload []byte, kid string) Template + func (t Template) WithAdditionalPrevs(additionalPrevs []hash.SHA256Hash) Template + func (t Template) WithAttachKey(key crypto.PublicKey) Template + func (t Template) WithPrivate(participants []did.DID) Template + func (t Template) WithTimestamp(timestamp time.Time) Template + type Transactions interface + AddressBook func() []transport.Contact + CreateTransaction func(ctx context.Context, spec Template) (dag.Transaction, error) + Disabled func() bool + 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/v5
Go to main page