Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

network

package

Go to main page

Versions in this module

v0

v0.5.0

Jul 17, 2025

v0.4.0

Jan 7, 2025

Changes in this version

+ type FinalityListener interface

+ OnStatus func(ctx context.Context, txID string, status int, message string, ...)

type Network

+ func (n *Network) AddFinalityListener(namespace string, txID string, listener FinalityListener) error

+ func (n *Network) Connect(ns string) ([]token.ServiceOption, error)

+ func (n *Network) Normalize(opt *token.ServiceOptions) (*token.ServiceOptions, error)

+ func (n *Network) RemoveFinalityListener(id string, listener FinalityListener) error

+ func (n *Network) TokenVault(namespace string) (*TokenVault, error)

type Provider

+ func GetProvider(sp token.ServiceProvider) *Provider

+ func (np *Provider) Normalize(opt *token.ServiceOptions) (*token.ServiceOptions, error)

+ func (np *Provider) RegisterDriver(driver driver.Driver)

+ type TokenVault struct

+ func (v *TokenVault) CertificationStorage() driver.CertificationStorage

+ func (v *TokenVault) DeleteTokens(ids ...*token2.ID) error

+ func (v *TokenVault) PruneInvalidUnspentTokens(context view.Context) ([]*token2.ID, error)

+ func (v *TokenVault) QueryEngine() driver.QueryEngine

v0.3.0

Oct 5, 2023

Changes in this version

type Network

+ func (n *Network) ProcessNamespace(namespace string) error

v0.2.0

Dec 7, 2022

v0.1.0

Nov 16, 2022

Changes in this version

+ func Drivers() []string

+ func Register(name string, driver driver.Driver)

+ type Envelope struct

+ func (e *Envelope) Bytes() ([]byte, error)

+ func (e *Envelope) Creator() []byte

+ func (e *Envelope) FromBytes(raw []byte) error

+ func (e *Envelope) MarshalJSON() ([]byte, error)

+ func (e *Envelope) Nonce() []byte

+ func (e *Envelope) Results() []byte

+ func (e *Envelope) String() string

+ func (e *Envelope) TxID() string

+ func (e *Envelope) UnmarshalJSON(raw []byte) error

+ type GetFunc func() (view.Identity, []byte, error)

+ type Ledger struct

+ func (l *Ledger) Status(id string) (ValidationCode, error)

+ type LocalMembership struct

+ func (l *LocalMembership) AnonymousIdentity() view.Identity

+ func (l *LocalMembership) DefaultIdentity() view.Identity

+ func (l *LocalMembership) IsMe(id view.Identity) bool

+ type Network struct

+ func GetInstance(sp view2.ServiceProvider, network, channel string) *Network

+ func (n *Network) AnonymousIdentity() view.Identity

+ func (n *Network) AreTokensSpent(context view.Context, namespace string, IDs []string) ([]bool, error)

+ func (n *Network) Broadcast(blob interface{}) error

+ func (n *Network) Channel() string

+ func (n *Network) ComputeTxID(id *TxID) string

+ func (n *Network) ExistEnvelope(id string) bool

+ func (n *Network) ExistTransient(id string) bool

+ func (n *Network) FetchPublicParameters(namespace string) ([]byte, error)

+ func (n *Network) GetEnrollmentID(raw []byte) (string, error)

+ func (n *Network) GetRWSet(id string, results []byte) (*RWSet, error)

+ func (n *Network) GetTransient(id string) (TransientMap, error)

+ func (n *Network) IsFinal(ctx context.Context, id string) error

+ func (n *Network) IsFinalForParties(id string, endpoints ...view.Identity) error

+ func (n *Network) Ledger(namespace string) (*Ledger, error)

+ func (n *Network) LocalMembership() *LocalMembership

+ func (n *Network) LookupTransferMetadataKey(namespace, startingTxID, key string, timeout time.Duration, ...) ([]byte, error)

+ func (n *Network) Name() string

+ func (n *Network) NewEnvelope() *Envelope

+ func (n *Network) QueryTokens(context view.Context, namespace string, IDs []*token2.ID) ([][]byte, error)

+ func (n *Network) RequestApproval(context view.Context, namespace string, requestRaw []byte, ...) (*Envelope, error)

+ func (n *Network) StoreEnvelope(id string, env []byte) error

+ func (n *Network) StoreTransient(id string, transient TransientMap) error

+ func (n *Network) SubscribeTxStatusChanges(txID string, listener TxStatusChangeListener) error

+ func (n *Network) UnsubscribeTxStatusChanges(id string, listener TxStatusChangeListener) error

+ func (n *Network) Vault(namespace string) (*Vault, error)

+ type Provider struct

+ func NewProvider(sp view2.ServiceProvider) *Provider

+ func (np *Provider) GetNetwork(network string, channel string) (*Network, error)

+ type RWSet struct

+ func (s *RWSet) Done()

+ type TransientMap map[string][]byte

+ func (m TransientMap) Exists(key string) bool

+ func (m TransientMap) Get(id string) []byte

+ func (m TransientMap) GetState(key string, state interface{}) error

+ func (m TransientMap) IsEmpty() bool

+ func (m TransientMap) Set(key string, raw []byte) error

+ func (m TransientMap) SetState(key string, state interface{}) error

+ type TxID struct

+ Creator []byte

+ Nonce []byte

+ func (t *TxID) String() string

+ type TxStatusChangeListener interface

+ OnStatusChange func(txID string, status int) error

+ type UnspentTokensIterator = driver.UnspentTokensIterator

+ type ValidationCode int

+ const Busy

+ const HasDependencies

+ const Invalid

+ const Unknown

+ const Valid

+ type Vault struct

+ func (v *Vault) DiscardTx(id string) error

+ func (v *Vault) Exists(id *token2.ID) bool

+ func (v *Vault) GetLastTxID() (string, error)

+ func (v *Vault) ListUnspentTokens() (*token2.UnspentTokens, error)

+ func (v *Vault) PruneInvalidUnspentTokens(context view.Context) ([]*token2.ID, error)

+ func (v *Vault) Status(id string) (ValidationCode, error)

+ func (v *Vault) Store(certifications map[*token2.ID][]byte) error

+ func (v *Vault) TokenVault() *vault.Vault

+ func (v *Vault) UnspentTokensIterator() (UnspentTokensIterator, error)

+ func (v *Vault) UnspentTokensIteratorBy(id, typ string) (UnspentTokensIterator, error)