fabric

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Oct 5, 2023 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	InvokeFunction            = "invoke"
	QueryPublicParamsFunction = "queryPublicParams"
	QueryTokensFunctions      = "queryTokens"
	AreTokensSpent            = "areTokensSpent"
)

Variables

This section is empty.

Functions

This section is empty.

Types

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 GetFunc 

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

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 Network 

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

func NewNetwork 

func NewNetwork(sp view2.ServiceProvider, n *fabric.NetworkService, ch *fabric.Channel) *Network

func (*Network) AreTokensSpent 

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

func (*Network) Broadcast 

func (n *Network) Broadcast(context context.Context, 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) ProcessNamespace added in v0.3.0 

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

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, tms *token2.ManagementService, 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 RWSWrapper 

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

func NewRWSWrapper 

func NewRWSWrapper(r *fabric.RWSet) *RWSWrapper

func (*RWSWrapper) Bytes 

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

func (*RWSWrapper) DeleteState 

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

func (*RWSWrapper) Done 

func (rwset *RWSWrapper) Done()

func (*RWSWrapper) Equals 

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

func (*RWSWrapper) GetState 

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

func (*RWSWrapper) SetState 

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

type RWSetProcessor 

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

func NewTokenRWSetProcessor 

func NewTokenRWSetProcessor(network net, ns string, sp view2.ServiceProvider, ownership network.Authorization, issued network.Issued, tokenStore processor.TokenStore) *RWSetProcessor

func (*RWSetProcessor) Process 

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

type Vault 

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

func NewVault 

func NewVault(ch *fabric.Channel, 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)

func (*Vault) TransactionStatus added in v0.3.0 

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

Source Files

View all Source files

Directories

Path Synopsis
tcc
main
mock
Code generated by counterfeiter.
 Code generated by counterfeiter.

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.