orion

package

Versions in this module

v0

v0.4.0

Jan 7, 2025

Changes in this version

+ func NewCommitterBasedFLMProvider(onsp *orion.NetworkServiceProvider, tracerProvider trace.TracerProvider, ...) *committerBasedFLMProvider

+ func NewOrionDriver(onsProvider *orion.NetworkServiceProvider, viewRegistry driver2.Registry, ...) driver.Driver

+ func NewSpentTokenExecutorProvider(viewManager *view2.Manager, keyTranslator translator.KeyTranslator) *spentTokenFetcherProvider

+ func NewTokenExecutorProvider(viewManager *view2.Manager) *tokenFetcherProvider

type BroadcastView

+ DBManager *DBManager

+ type DBManager struct

+ ConfigProvider configProvider

+ IsCustodian bool

+ OrionNetworkProvider *orion.NetworkServiceProvider

+ SMMutex sync.RWMutex

+ SessionManagers map[string]*SessionManager

+ func NewDBManager(onp *orion.NetworkServiceProvider, cp configProvider, isCustodian bool) *DBManager

+ func (d *DBManager) GetSessionManager(network string) (*SessionManager, error)

type Driver

+ func NewDriver(onsProvider *orion.NetworkServiceProvider, viewRegistry driver2.Registry, ...) *Driver

+ type FinalityListener struct

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

+ type FinalityListenerManager driver.FinalityListenerManager

+ type FinalityListenerManagerProvider interface

+ NewManager func(network string, dbManager *DBManager) (FinalityListenerManager, error)

+ type GetTMSProviderFunc = func() *token.ManagementServiceProvider

+ type GetTokenRequestFunc = func(tms *token.ManagementService, txID string) ([]byte, error)

+ type GetTokensFunc = func() (*tokens.Tokens, error)

type Network

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

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

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

+ func (n *Network) RemoveFinalityListener(txID string, listener driver.FinalityListener) error

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

+ type NewVaultFunc = func(network, channel, namespace string) (driver.TokenVault, error)

type RWSetProcessor

+ GetTMSProvider GetTMSProviderFunc

+ GetTokenRequest GetTokenRequestFunc

+ GetTokens GetTokensFunc

type RequestApprovalView

+ DBManager *DBManager

type RequestTxStatusView

+ Namespace string

+ type ResponderRegistry interface

+ RegisterResponder func(responder view2.View, initiatedBy interface{}) error

+ type SessionManager struct

+ CustodianID string

+ Orion *orion.NetworkService

+ func NewSessionManager(dbManager *DBManager, network string) (*SessionManager, error)

+ func (s *SessionManager) GetSession() (os *orion.Session, err error)

+ func (s *SessionManager) PublicParameters(tds *driver.TokenDriverService, namespace string) (driver.PublicParameters, error)

+ func (s *SessionManager) ReadPublicParameters(namespace string) ([]byte, error)

+ type StatusFetcher struct

+ func NewStatusFetcher(dbManager *DBManager, keyTranslator translator.KeyTranslator) *StatusFetcher

+ func (r *StatusFetcher) FetchCode(network string, txID driver.TxID) (driver2.ValidationCode, error)

+ func (r *StatusFetcher) FetchStatus(network, namespace string, txID driver.TxID) (*TxStatusResponse, error)

+ type Transaction struct

+ func (t *Transaction) Channel() string

+ func (t *Transaction) ID() string

+ func (t *Transaction) Namespace() string

+ func (t *Transaction) Network() string

+ func (t *Transaction) Request() *token.Request

type TxStatusRequest

+ Namespace string

type TxStatusResponse

+ TokenRequestReference []byte

+ type TxStatusResponseCache interface

+ Add func(key string, value *TxStatusResponse)

+ Get func(key string) (*TxStatusResponse, bool)

+ GetOrLoad func(key string, loader func() (*TxStatusResponse, error)) (*TxStatusResponse, bool, error)

v0.3.0

Oct 5, 2023

Changes in this version

type Network

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

type Vault

+ func (v *Vault) TransactionStatus(txID string) (driver.ValidationCode, error)

type Wallets

+ DefaultCacheSize int

v0.2.0

Dec 7, 2022

v0.1.0

Nov 16, 2022

Changes in this version

+ func GetCustodian(cp configProvider, network string) (string, error)

+ func InstallViews(sp view.ServiceProvider) error

+ func IsCustodian(cp configProvider) (bool, error)

+ func LookupKey(context view.Context, request *LookupKeyRequest) ([]byte, error)

+ func ReadPublicParameters(context view2.ServiceProvider, network, namespace string) ([]byte, error)

+ type ApprovalRequest struct

+ Namespace string

+ Network string

+ Request []byte

+ TxID string

+ type ApprovalResponse struct

+ Envelope []byte

+ type BroadcastRequest struct

+ Blob []byte

+ Network string

+ type BroadcastResponderView struct

+ func (r *BroadcastResponderView) Call(context view.Context) (interface{}, error)

+ type BroadcastResponse struct

+ Err error

+ type BroadcastView struct

+ Blob interface{}

+ Network driver.Network

+ func NewBroadcastView(network driver.Network, blob interface{}) *BroadcastView

+ func (r *BroadcastView) Call(context view.Context) (interface{}, error)

+ type Certification struct

+ Interactive *InteractiveCertification

+ type Custodian struct

+ Enabled bool

+ ID string

+ type Driver struct

+ func (d *Driver) New(sp view.ServiceProvider, network, channel string) (driver.Network, error)

+ type Executor struct

+ func (e *Executor) Done()

+ func (e *Executor) GetState(namespace string, key string) ([]byte, error)

+ func (e *Executor) GetStateMetadata(namespace string, id string) (map[string][]byte, error)

+ func (e *Executor) GetStateRangeScanIterator(namespace string, start string, end string) (driver.Iterator, error)

+ type Identity struct

+ Default bool

+ ID string

+ Path string

+ Type string

+ type IdentityProvider interface

+ DefaultIdentity func() view.Identity

+ type InteractiveCertification struct

+ IDs []string

+ type Iterator struct

+ func (i *Iterator) Close()

+ func (i *Iterator) Next() (driver.Entry, error)

+ type LedgerWrapper struct

+ func (l *LedgerWrapper) GetState(key string) ([]byte, error)

+ type LookupKeyRequest struct

+ Key string

+ Namespace string

+ Network string

+ StartingTxID string

+ Timeout time.Duration

+ func (l *LookupKeyRequest) String() string

+ type LookupKeyRequestRespondView struct

+ func (v *LookupKeyRequestRespondView) Call(context view.Context) (interface{}, error)

+ type LookupKeyRequestView struct

+ func NewLookupKeyRequestView(network string, namespace string, startingTxID string, key string, ...) *LookupKeyRequestView

+ func (v *LookupKeyRequestView) Call(context view.Context) (interface{}, error)

+ type LookupKeyResponse struct

+ Raw []byte

+ type Manager struct

+ func NewManager(cp configProvider, network, channel, namespace string) (*Manager, error)

+ func (m *Manager) TMS() *config.TMS

+ func (m *Manager) TranslatePath(path string) string

+ type Network struct

+ func NewNetwork(sp view2.ServiceProvider, ip IdentityProvider, n *orion.NetworkService) *Network

+ 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 *driver.TxID) string

+ func (n *Network) EnvelopeExists(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) (driver.RWSet, error)

+ func (n *Network) GetTransient(id string) (driver.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() (driver.Ledger, error)

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

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

+ func (n *Network) Name() string

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

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

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

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

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

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

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

+ func (n *Network) UnsubscribeTxStatusChanges(txID string, listener driver.TxStatusChangeListener) error

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

+ type ONS interface

+ MetadataService func() *orion.MetadataService

+ Name func() string

+ type Orion struct

+ Custodian *Custodian

+ type PublicParamsRequest struct

+ Namespace string

+ Network string

+ type PublicParamsRequestResponderView struct

+ func (v *PublicParamsRequestResponderView) Call(context view.Context) (interface{}, error)

+ type PublicParamsRequestView struct

+ Namespace string

+ Network string

+ func NewPublicParamsRequestView(network string, namespace string) *PublicParamsRequestView

+ func (v *PublicParamsRequestView) Call(context view.Context) (interface{}, error)

+ type PublicParamsResponse struct

+ Raw []byte

+ type QueryTokensRequest struct

+ IDs []*token2.ID

+ Namespace string

+ Network string

+ type QueryTokensResponse struct

+ Content [][]byte

+ type RWSWrapper struct

+ func NewRWSWrapper(r *orion.RWSet) *RWSWrapper

+ func (r *RWSWrapper) Bytes() ([]byte, error)

+ func (r *RWSWrapper) DeleteState(namespace string, key string) error

+ func (r *RWSWrapper) Done()

+ func (r *RWSWrapper) Equals(right interface{}, namespace string) error

+ func (r *RWSWrapper) GetState(namespace string, key string) ([]byte, error)

+ func (r *RWSWrapper) SetState(namespace string, key string, value []byte) error

+ type RWSetProcessor struct

+ func NewTokenRWSetProcessor(network ONS, ns string, sp view2.ServiceProvider, ...) *RWSetProcessor

+ func (r *RWSetProcessor) Process(req orion.Request, tx orion.ProcessTransaction, rws *orion.RWSet, ns string) error

+ type ReadOnlyRWSWrapper struct

+ func (r *ReadOnlyRWSWrapper) Bytes() ([]byte, error)

+ func (r *ReadOnlyRWSWrapper) DeleteState(namespace string, key string) error

+ func (r *ReadOnlyRWSWrapper) Done()

+ func (r *ReadOnlyRWSWrapper) Equals(right interface{}, namespace string) error

+ func (r *ReadOnlyRWSWrapper) GetState(namespace string, key string) ([]byte, error)

+ func (r *ReadOnlyRWSWrapper) SetState(namespace string, key string, value []byte) error

+ type RequestApprovalResponderView struct

+ func (r *RequestApprovalResponderView) Call(context view.Context) (interface{}, error)

+ type RequestApprovalView struct

+ Namespace string

+ Network driver.Network

+ RequestRaw []byte

+ Signer view.Identity

+ TxID string

+ func NewRequestApprovalView(network driver.Network, namespace string, requestRaw []byte, ...) *RequestApprovalView

+ func (r *RequestApprovalView) Call(context view.Context) (interface{}, error)

+ type RequestQueryTokensResponderView struct

+ func (r *RequestQueryTokensResponderView) Call(context view.Context) (interface{}, error)

+ type RequestQueryTokensView struct

+ IDs []*token2.ID

+ Namespace string

+ Network driver.Network

+ func NewRequestQueryTokensView(network driver.Network, namespace string, IDs []*token2.ID) *RequestQueryTokensView

+ func (r *RequestQueryTokensView) Call(context view.Context) (interface{}, error)

+ type RequestSpentTokensResponderView struct

+ func (r *RequestSpentTokensResponderView) Call(context view.Context) (interface{}, error)

+ type RequestSpentTokensView struct

+ IDs []string

+ Namespace string

+ Network driver.Network

+ func NewRequestSpentTokensView(network driver.Network, namespace string, IDs []string) *RequestSpentTokensView

+ func (r *RequestSpentTokensView) Call(context view.Context) (interface{}, error)

+ type RequestTxStatusResponderView struct

+ func (r *RequestTxStatusResponderView) Call(context view.Context) (interface{}, error)

+ type RequestTxStatusView struct

+ Network driver.Network

+ TxID string

+ func NewRequestTxStatusView(network driver.Network, txID string) *RequestTxStatusView

+ func (r *RequestTxStatusView) Call(context view.Context) (interface{}, error)

+ type SpentTokensRequest struct

+ IDs []string

+ Namespace string

+ Network string

+ type SpentTokensResponse struct

+ Flags []bool

+ type TMS struct

+ Certification *Certification

+ Channel string

+ Namespace string

+ Network string

+ Orion *Orion

+ Wallets *Wallets

+ type Token struct

+ Enabled bool

+ TMS []*TMS

+ type TxRWSWrapper struct

+ func (r *TxRWSWrapper) Bytes() ([]byte, error)

+ func (r *TxRWSWrapper) DeleteState(namespace string, key string) error

+ func (r *TxRWSWrapper) Done()

+ func (r *TxRWSWrapper) Equals(right interface{}, namespace string) error

+ func (r *TxRWSWrapper) GetState(namespace string, key string) ([]byte, error)

+ func (r *TxRWSWrapper) SetState(namespace string, key string, value []byte) error

+ type TxStatusRequest struct

+ Network string

+ TxID string

+ type TxStatusResponse struct

+ Status driver.ValidationCode

+ type Vault struct

+ func NewVault(ons *orion.NetworkService, tokenStore processor.TokenStore) *Vault

+ func (v *Vault) DeleteTokens(ns string, ids ...*token.ID) error

+ func (v *Vault) NewQueryExecutor() (driver.Executor, error)

+ func (v *Vault) NewRWSet(txID string) (driver.RWSet, error)

+ type Wallets struct

+ Auditors []*Identity

+ Certifiers []*Identity

+ Issuers []*Identity

+ Owners []*Identity

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