orion

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 16, 2022 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetCustodian 

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

func InstallViews 

func InstallViews(sp view.ServiceProvider) error

func IsCustodian 

func IsCustodian(cp configProvider) (bool, error)

func LookupKey 

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

func ReadPublicParameters 

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

Types

type ApprovalRequest 

type ApprovalRequest struct {
	Network   string
	Namespace string
	TxID      string
	Request   []byte
}

type ApprovalResponse 

type ApprovalResponse struct {
	Envelope []byte
}

type BroadcastRequest 

type BroadcastRequest struct {
	Network string
	Blob    []byte
}

type BroadcastResponderView 

type BroadcastResponderView struct{}

func (*BroadcastResponderView) Call 

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

type BroadcastResponse 

type BroadcastResponse struct {
	Err error
}

type BroadcastView 

type BroadcastView struct {
	Network driver.Network
	Blob    interface{}
}

func NewBroadcastView 

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

func (*BroadcastView) Call 

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

type Certification 

type Certification struct {
	Interactive *InteractiveCertification `yaml:"interactive,omitempty"`
}

type Custodian 

type Custodian struct {
	ID      string `yaml:"id"`
	Enabled bool   `yaml:"enabled,omitempty"`
}

type Driver 

type Driver struct {
}

func (*Driver) New 

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

type Executor 

type Executor struct {
	// contains filtered or unexported fields
}

func (*Executor) Done 

func (e *Executor) Done()

func (*Executor) GetState 

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

func (*Executor) GetStateMetadata 

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

func (*Executor) GetStateRangeScanIterator 

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

type Identity 

type Identity struct {
	ID      string `yaml:"id"`
	Default bool   `yaml:"default,omitempty"`
	Type    string `yaml:"type"`
	Path    string `yaml:"path"`
}

type IdentityProvider 

type IdentityProvider interface {
	DefaultIdentity() view.Identity
}

type InteractiveCertification 

type InteractiveCertification struct {
	IDs []string `yaml:"ids,omitempty"`
}

type Iterator 

type Iterator struct {
	// contains filtered or unexported fields
}

func (*Iterator) Close 

func (i *Iterator) Close()

func (*Iterator) Next 

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

type LedgerWrapper 

type LedgerWrapper struct {
	// contains filtered or unexported fields
}

func (*LedgerWrapper) GetState 

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

type LookupKeyRequest 

type LookupKeyRequest struct {
	Network      string
	Namespace    string
	StartingTxID string
	Key          string
	Timeout      time.Duration
}

func (*LookupKeyRequest) String 

func (l *LookupKeyRequest) String() string

type LookupKeyRequestRespondView 

type LookupKeyRequestRespondView struct{}

func (*LookupKeyRequestRespondView) Call 

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

type LookupKeyRequestView 

type LookupKeyRequestView struct {
	*LookupKeyRequest
}

func NewLookupKeyRequestView 

func NewLookupKeyRequestView(network string, namespace string, startingTxID string, key string, timeout time.Duration) *LookupKeyRequestView

func (*LookupKeyRequestView) Call 

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

type LookupKeyResponse 

type LookupKeyResponse struct {
	Raw []byte
}

type Manager 

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager 

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

func (*Manager) TMS 

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

func (*Manager) TranslatePath 

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

type Network 

type Network struct {
	// contains filtered or unexported fields
}

func NewNetwork 

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

func (*Network) AreTokensSpent 

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

func (*Network) Broadcast 

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

func (*Network) Channel 

func (n *Network) Channel() string

func (*Network) ComputeTxID 

func (n *Network) ComputeTxID(id *driver.TxID) string

func (*Network) EnvelopeExists 

func (n *Network) EnvelopeExists(id string) bool

func (*Network) FetchPublicParameters 

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

func (*Network) GetEnrollmentID 

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

func (*Network) GetRWSet 

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

func (*Network) GetTransient 

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

func (*Network) IsFinal 

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

func (*Network) IsFinalForParties 

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

func (*Network) Ledger 

func (n *Network) Ledger() (driver.Ledger, error)

func (*Network) LocalMembership 

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

func (*Network) LookupTransferMetadataKey 

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

func (*Network) Name 

func (n *Network) Name() string

func (*Network) NewEnvelope 

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

func (*Network) QueryTokens 

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

func (*Network) RequestApproval 

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

func (*Network) StoreEnvelope 

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

func (*Network) StoreTransient 

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

func (*Network) SubscribeTxStatusChanges 

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

func (*Network) TransientExists 

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

func (*Network) UnsubscribeTxStatusChanges 

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

func (*Network) Vault 

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

type ONS 

type ONS interface {
	Name() string
	MetadataService() *orion.MetadataService
}

type Orion 

type Orion struct {
	Custodian *Custodian `yaml:"custodian,omitempty"`
}

type PublicParamsRequest 

type PublicParamsRequest struct {
	Network   string
	Namespace string
}

type PublicParamsRequestResponderView 

type PublicParamsRequestResponderView struct{}

func (*PublicParamsRequestResponderView) Call 

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

type PublicParamsRequestView 

type PublicParamsRequestView struct {
	Network   string
	Namespace string
	// contains filtered or unexported fields
}

func NewPublicParamsRequestView 

func NewPublicParamsRequestView(network string, namespace string) *PublicParamsRequestView

func (*PublicParamsRequestView) Call 

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

type PublicParamsResponse 

type PublicParamsResponse struct {
	Raw []byte
}

type QueryTokensRequest 

type QueryTokensRequest struct {
	Network   string
	Namespace string
	IDs       []*token2.ID
}

type QueryTokensResponse 

type QueryTokensResponse struct {
	Content [][]byte
}

type RWSWrapper 

type RWSWrapper struct {
	// contains filtered or unexported fields
}

func NewRWSWrapper 

func NewRWSWrapper(r *orion.RWSet) *RWSWrapper

func (*RWSWrapper) Bytes 

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

func (*RWSWrapper) DeleteState 

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

func (*RWSWrapper) Done 

func (r *RWSWrapper) Done()

func (*RWSWrapper) Equals 

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

func (*RWSWrapper) GetState 

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

func (*RWSWrapper) SetState 

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

type RWSetProcessor 

type RWSetProcessor struct {
	// contains filtered or unexported fields
}

func NewTokenRWSetProcessor 

func NewTokenRWSetProcessor(network ONS, ns string, sp view2.ServiceProvider, ownership network.Authorization, issued network.Issued) *RWSetProcessor

func (*RWSetProcessor) Process 

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

type ReadOnlyRWSWrapper 

type ReadOnlyRWSWrapper struct {
	// contains filtered or unexported fields
}

func (*ReadOnlyRWSWrapper) Bytes 

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

func (*ReadOnlyRWSWrapper) DeleteState 

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

func (*ReadOnlyRWSWrapper) Done 

func (r *ReadOnlyRWSWrapper) Done()

func (*ReadOnlyRWSWrapper) Equals 

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

func (*ReadOnlyRWSWrapper) GetState 

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

func (*ReadOnlyRWSWrapper) SetState 

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

type RequestApprovalResponderView 

type RequestApprovalResponderView struct{}

func (*RequestApprovalResponderView) Call 

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

type RequestApprovalView 

type RequestApprovalView struct {
	Network    driver.Network
	Namespace  string
	RequestRaw []byte
	Signer     view.Identity
	TxID       string
}

func NewRequestApprovalView 

func NewRequestApprovalView(network driver.Network, namespace string, requestRaw []byte, signer view.Identity, txID string) *RequestApprovalView

func (*RequestApprovalView) Call 

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

type RequestQueryTokensResponderView 

type RequestQueryTokensResponderView struct{}

func (*RequestQueryTokensResponderView) Call 

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

type RequestQueryTokensView 

type RequestQueryTokensView struct {
	Network   driver.Network
	Namespace string
	IDs       []*token2.ID
}

func NewRequestQueryTokensView 

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

func (*RequestQueryTokensView) Call 

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

type RequestSpentTokensResponderView 

type RequestSpentTokensResponderView struct{}

func (*RequestSpentTokensResponderView) Call 

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

type RequestSpentTokensView 

type RequestSpentTokensView struct {
	Network   driver.Network
	Namespace string
	IDs       []string
}

func NewRequestSpentTokensView 

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

func (*RequestSpentTokensView) Call 

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

type RequestTxStatusResponderView 

type RequestTxStatusResponderView struct{}

func (*RequestTxStatusResponderView) Call 

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

type RequestTxStatusView 

type RequestTxStatusView struct {
	Network driver.Network
	TxID    string
}

func NewRequestTxStatusView 

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

func (*RequestTxStatusView) Call 

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

type SpentTokensRequest 

type SpentTokensRequest struct {
	Network   string
	Namespace string
	IDs       []string
}

type SpentTokensResponse 

type SpentTokensResponse struct {
	Flags []bool
}

type TMS 

type TMS struct {
	Network       string         `yaml:"network,omitempty"`
	Channel       string         `yaml:"channel,omitempty"`
	Namespace     string         `yaml:"namespace,omitempty"`
	Orion         *Orion         `yaml:"orion,omitempty"`
	Certification *Certification `yaml:"certification,omitempty"`
	Wallets       *Wallets       `yaml:"wallets,omitempty"`
}

type Token 

type Token struct {
	Enabled bool   `yaml:"enabled,omitempty"`
	TMS     []*TMS `yaml:"tms,omitempty"`
}

type TxRWSWrapper 

type TxRWSWrapper struct {
	// contains filtered or unexported fields
}

func (*TxRWSWrapper) Bytes 

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

func (*TxRWSWrapper) DeleteState 

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

func (*TxRWSWrapper) Done 

func (r *TxRWSWrapper) Done()

func (*TxRWSWrapper) Equals 

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

func (*TxRWSWrapper) GetState 

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

func (*TxRWSWrapper) SetState 

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

type TxStatusRequest 

type TxStatusRequest struct {
	Network string
	TxID    string
}

type TxStatusResponse 

type TxStatusResponse struct {
	Status driver.ValidationCode
}

type Vault 

type Vault struct {
	// contains filtered or unexported fields
}

func NewVault 

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

func (*Vault) DeleteTokens 

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

func (*Vault) NewQueryExecutor 

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

func (*Vault) NewRWSet 

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

type Wallets 

type Wallets struct {
	Certifiers []*Identity `yaml:"certifiers,omitempty"`
	Owners     []*Identity `yaml:"owners,omitempty"`
	Issuers    []*Identity `yaml:"issuers,omitempty"`
	Auditors   []*Identity `yaml:"auditors,omitempty"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.