driver

package

Go to main page

Versions in this module

v0

v0.4.0

Jan 6, 2025

Changes in this version

+ const EndorserTransaction

+ var ValidationCodeMessage = map[ValidationCode]string

+ type BlockCallback func(context.Context, *common.Block) (bool, error)

+ type BlockNum = driver.BlockNum

type ByNum

+ Message string

+ TxID string

+ type ChaincodeConfig interface

+ ID func() string

+ IsPrivate func() bool

type Channel

+ ChaincodeManager func() ChaincodeManager

+ ChannelMembership func() ChannelMembership

+ Committer func() Committer

+ Delivery func() Delivery

+ Finality func() Finality

+ Ledger func() Ledger

+ RWSetLoader func() RWSetLoader

+ TXIDStore func() TXIDStore

+ Vault func() Vault

+ type ChannelConfig interface

+ ChaincodeConfigs func() []ChaincodeConfig

+ CommitParallelism func() int

+ CommitterFinalityNumRetries func() int

+ CommitterFinalityUnknownTXTimeout func() time.Duration

+ CommitterPollingTimeout func() time.Duration

+ CommitterWaitForEventTimeout func() time.Duration

+ DeliverySleepAfterFailure func() time.Duration

+ DiscoveryDefaultTTLS func() time.Duration

+ DiscoveryTimeout func() time.Duration

+ FinalityEventQueueWorkers func() int

+ FinalityForPartiesWaitTimeout func() time.Duration

+ FinalityWaitTimeout func() time.Duration

+ GetNumRetries func() uint

+ GetRetrySleep func() time.Duration

+ ID func() string

+ type ChannelConfigProvider interface

+ GetChannelConfig func(network, channel string) (ChannelConfig, error)

type Committer

+ AddFinalityListener func(txID string, listener FinalityListener) error

+ AddTransactionFilter func(tf TransactionFilter) error

+ RemoveFinalityListener func(txID string, listener FinalityListener) error

+ Start func(context context.Context) error

type ConfigService

+ BroadcastNumRetries func() int

+ BroadcastRetryInterval func() time.Duration

+ Channel func(name string) ChannelConfig

+ ChannelIDs func() []string

+ ClientConnTimeout func() time.Duration

+ DefaultChannel func() string

+ DriverName func() string

+ IsChannelQuiet func(name string) bool

+ KeepAliveClientInterval func() time.Duration

+ KeepAliveClientTimeout func() time.Duration

+ NetworkName func() string

+ NewDefaultChannelConfig func(name string) ChannelConfig

+ OrdererConnectionPoolSize func() int

+ Orderers func() []*grpc.ConnectionConfig

+ OrderingTLSClientAuthRequired func() (bool, bool)

+ OrderingTLSEnabled func() (bool, bool)

+ PickOrderer func() *grpc.ConnectionConfig

+ PickPeer func(funcType PeerFunctionType) *grpc.ConnectionConfig

+ SetConfigOrderers func([]*grpc.ConnectionConfig) error

+ TLSClientAuthRequired func() bool

+ TLSClientCertFile func() string

+ TLSClientKeyFile func() string

+ TLSEnabled func() bool

+ TLSServerHostOverride func() string

+ VaultPersistencePrefix func() string

+ VaultPersistenceType func() driver.PersistenceType

+ VaultTXStoreCacheSize func() int

+ type Configuration interface

+ ConfigFileUsed func() string

+ GetBool func(key string) bool

+ GetDuration func(key string) time.Duration

+ GetInt func(key string) int

+ GetPath func(key string) string

+ GetString func(key string) string

+ GetStringSlice func(key string) []string

+ IsSet func(key string) bool

+ TranslatePath func(path string) string

+ UnmarshalKey func(key string, rawVal interface{}) error

type Delivery

+ ScanBlock func(ctx context.Context, callback BlockCallback) error

+ Start func(ctx context.Context) error

type FabricNetworkService

+ OrderingService func() Ordering

+ type FinalityListener = driver.FinalityListener[ValidationCode]

+ type ListenerManager driver.ListenerManager[ValidationCode]

+ type ListenerManagerProvider driver.ListenerManagerProvider[ValidationCode]

+ type MSP interface

+ CacheSize func() int

+ ID func() string

+ MSPID func() string

+ MSPType func() string

+ Opts func() map[interface{}]interface{}

+ Path func() string

type ProposalResponse

+ VerifyEndorsement func(provider VerifierProvider) error

+ type RWSetInspector interface

+ GetExistingRWSet func(txID driver.TxID) (RWSet, error)

+ GetRWSet func(txid string, rwset []byte) (RWSet, error)

+ InspectRWSet func(rwsetBytes []byte, namespaces ...driver.Namespace) (RWSet, error)

+ NewRWSet func(txid string) (RWSet, error)

+ RWSExists func(txid string) bool

type RWSetLoader

+ AddHandlerProvider func(headerType common.HeaderType, handlerProvider RWSetPayloadHandlerProvider) error

+ GetInspectingRWSetFromEvn func(id string, envelopeRaw []byte) (RWSet, ProcessTransaction, error)

+ type RWSetPayloadHandler interface

+ Load func(payl *common.Payload, header *common.ChannelHeader) (RWSet, ProcessTransaction, error)

+ type RWSetPayloadHandlerProvider = func(network, channel string, v RWSetInspector) RWSetPayloadHandler

+ type Resolver interface

+ Addresses func() map[string]string

+ Aliases func() []string

+ Domain func() string

+ Identity func() MSP

+ Name func() string

+ type SeekSet struct

+ TxIDs []string

type TXIDStore

+ Get func(txid string) (ValidationCode, string, error)

+ Set func(txID string, code ValidationCode, message string) error

+ SetMultiple func(txs []driver.ByNum[ValidationCode]) error

+ type TransactionFactory interface

+ NewTransaction func(channel string, nonce []byte, creator []byte, txid string, rawRequest []byte) (Transaction, error)

+ type TransactionFilter = driver.TransactionFilter

type TransactionManager

+ AddTransactionFactory func(tt TransactionType, factory TransactionFactory)

+ NewProcessedTransaction func(pt []byte) (ProcessedTransaction, error)

+ NewProcessedTransactionFromEnvelopePayload func(envelopePayload []byte) (ProcessedTransaction, int32, error)

+ NewProcessedTransactionFromEnvelopeRaw func(envelope []byte) (ProcessedTransaction, error)

+ NewTransactionFromEnvelopeBytes func(channel string, raw []byte) (Transaction, error)

type TransactionStatusChanged

+ ValidationMessage string

+ type TransactionType int32

+ type TxIDIterator = collections.Iterator[*driver.ByNum[ValidationCode]]

+ type TxNum = driver.TxNum

+ type TxValidationStatus = driver.TxValidationStatus[ValidationCode]

+ type ValidationCodeProvider struct

+ func (p *ValidationCodeProvider) Busy() ValidationCode

+ func (p *ValidationCodeProvider) FromInt32(code int32) ValidationCode

+ func (p *ValidationCodeProvider) Invalid() ValidationCode

+ func (p *ValidationCodeProvider) NotFound() ValidationCode

+ func (p *ValidationCodeProvider) ToInt32(code ValidationCode) int32

+ func (p *ValidationCodeProvider) Unknown() ValidationCode

+ func (p *ValidationCodeProvider) Valid() ValidationCode

type Vault

+ Close func() error

+ InspectRWSet func(rwset []byte, namespaces ...string) (RWSet, error)

+ Match func(id string, results []byte) error

+ RWSExists func(id string) bool

+ type VerifierProvider interface

+ GetVerifier func(identity view.Identity) (Verifier, error)

v0.3.0

Oct 5, 2023

Changes in this version

+ const PeerForAnything

+ const PeerForDelivery

+ const PeerForDiscovery

+ const PeerForFinality

+ const PeerForQuery

type ChaincodeInvocation

+ WithContext func(context context.Context) ChaincodeInvocation

type Config

+ PickPeer func(funcType PeerFunctionType) *grpc.ConnectionConfig

type Ordering

+ SetConsensusType func(consensusType string) error

+ type PeerFunctionType int

v0.2.0

Dec 7, 2022

Changes in this version

type ChaincodeInvocation

+ WithMatchEndorsementPolicy func() ChaincodeInvocation

+ WithNumRetries func(numRetries uint) ChaincodeInvocation

+ WithRetrySleep func(duration time.Duration) ChaincodeInvocation

+ type Driver interface

+ New func(sp view.ServiceProvider, network string, defaultNetwork bool) (FabricNetworkService, error)

type ProposalResponse

+ Bytes func() ([]byte, error)

type Transaction

+ Envelope func() (Envelope, error)

v0.1.0

Nov 16, 2022

Changes in this version

+ type Block interface

+ DataAt func(i int) []byte

+ ProcessedTransaction func(i int) (ProcessedTransaction, error)

+ type ByNum struct

+ Code ValidationCode

+ Txid string

+ type Chaincode interface

+ IsAvailable func() (bool, error)

+ IsPrivate func() bool

+ NewDiscover func() ChaincodeDiscover

+ NewInvocation func(function string, args ...interface{}) ChaincodeInvocation

+ Version func() (string, error)

+ type ChaincodeDiscover interface

+ Call func() ([]DiscoveredPeer, error)

+ WithFilterByMSPIDs func(mspIDs ...string) ChaincodeDiscover

+ WithImplicitCollections func(mspIDs ...string) ChaincodeDiscover

+ type ChaincodeInvocation interface

+ Endorse func() (Envelope, error)

+ Query func() ([]byte, error)

+ Submit func() (string, []byte, error)

+ WithDiscoveredEndorsersByEndpoints func(endpoints ...string) ChaincodeInvocation

+ WithEndorsersByConnConfig func(ccs ...*grpc.ConnectionConfig) ChaincodeInvocation

+ WithEndorsersByMSPIDs func(mspIDs ...string) ChaincodeInvocation

+ WithEndorsersFromMyOrg func() ChaincodeInvocation

+ WithImplicitCollections func(mspIDs ...string) ChaincodeInvocation

+ WithSignerIdentity func(id view.Identity) ChaincodeInvocation

+ WithTransientEntry func(k string, v interface{}) ChaincodeInvocation

+ WithTxID func(id TxID) ChaincodeInvocation

+ type ChaincodeManager interface

+ Chaincode func(name string) Chaincode

+ type Channel interface

+ Close func() error

+ EnvelopeService func() EnvelopeService

+ MetadataService func() MetadataService

+ Name func() string

+ NewPeerClientForAddress func(cc grpc.ConnectionConfig) (peer.Client, error)

+ TransactionService func() EndorserTransactionService

+ type ChannelMembership interface

+ GetMSPIDs func() []string

+ GetVerifier func(identity view.Identity) (driver.Verifier, error)

+ IsValid func(identity view.Identity) error

+ MSPManager func() MSPManager

+ type Committer interface

+ CommitConfig func(blockNumber uint64, raw []byte, envelope *common.Envelope) error

+ CommitTX func(txid string, block uint64, indexInBloc int, envelope *common.Envelope) error

+ DiscardTx func(txid string) error

+ ProcessNamespace func(nss ...string) error

+ Status func(txid string) (ValidationCode, []string, error)

+ SubscribeTxStatusChanges func(txID string, listener TxStatusChangeListener) error

+ UnsubscribeTxStatusChanges func(txID string, listener TxStatusChangeListener) error

+ type Config interface

+ Channels func() []string

+ DefaultChannel func() string

+ Orderers func() []*grpc.ConnectionConfig

+ Peers func() []*grpc.ConnectionConfig

+ type ConfigService interface

+ GetBool func(key string) bool

+ GetDuration func(key string) time.Duration

+ GetPath func(key string) string

+ GetString func(key string) string

+ IsSet func(key string) bool

+ TranslatePath func(path string) string

+ UnmarshalKey func(key string, rawVal interface{}) error

+ type Delivery interface

+ Scan func(ctx context.Context, txID string, callback DeliveryCallback) error

+ StartDelivery func(ctx context.Context) error

+ type DeliveryCallback func(tx ProcessedTransaction) (bool, error)

+ type DiscoveredPeer struct

+ Endpoint string

+ Identity view.Identity

+ MSPID string

+ TLSRootCerts [][]byte

+ type EndorserTransactionService interface

+ Exists func(txid string) bool

+ LoadTransaction func(txid string) ([]byte, error)

+ StoreTransaction func(txid string, raw []byte) error

+ type Envelope interface

+ Bytes func() ([]byte, error)

+ Creator func() []byte

+ FromBytes func(raw []byte) error

+ Nonce func() []byte

+ Results func() []byte

+ String func() string

+ TxID func() string

+ type EnvelopeService interface

+ Exists func(txid string) bool

+ LoadEnvelope func(txid string) ([]byte, error)

+ StoreEnvelope func(txid string, env interface{}) error

+ type FabricNetworkService interface

+ Channel func(name string) (Channel, error)

+ Committer func(name string) (Committer, error)

+ ConfigService func() ConfigService

+ IdentityProvider func() IdentityProvider

+ Ledger func(name string) (Ledger, error)

+ LocalMembership func() LocalMembership

+ Name func() string

+ ProcessorManager func() ProcessorManager

+ SignerService func() SignerService

+ TransactionManager func() TransactionManager

+ type FabricNetworkServiceProvider interface

+ DefaultName func() string

+ FabricNetworkService func(id string) (FabricNetworkService, error)

+ Names func() []string

+ func GetFabricManagementService(ctx view2.ServiceProvider) FabricNetworkServiceProvider

+ type Finality interface

+ IsFinal func(ctx context.Context, txID string) error

+ IsFinalForParties func(txID string, parties ...view.Identity) error

+ type GetIdentityFunc func(opts *IdentityOptions) (view.Identity, []byte, error)

+ type GetStateOpt int

+ const FromBoth

+ const FromIntermediate

+ const FromStorage

+ type IdentityInfo struct

+ EnrollmentID string

+ GetIdentity GetIdentityFunc

+ ID string

+ type IdentityOptions struct

+ AuditInfo []byte

+ EIDExtension bool

+ type IdentityProvider interface

+ Identity func(label string) view.Identity

+ type Ledger interface

+ GetBlockByNumber func(number uint64) (Block, error)

+ GetBlockNumberByTxID func(txID string) (uint64, error)

+ GetTransactionByID func(txID string) (ProcessedTransaction, error)

+ type LocalMembership interface

+ AnonymousIdentity func() view.Identity

+ DefaultIdentity func() view.Identity

+ DefaultSigningIdentity func() SigningIdentity

+ GetIdentityByID func(id string) (view.Identity, error)

+ GetIdentityInfoByIdentity func(mspType string, id view.Identity) *IdentityInfo

+ GetIdentityInfoByLabel func(mspType string, label string) *IdentityInfo

+ IsMe func(id view.Identity) bool

+ Refresh func() error

+ RegisterIdemixMSP func(id string, path string, mspID string) error

+ RegisterX509MSP func(id string, path string, mspID string) error

+ type MSPIdentity interface

+ GetMSPIdentifier func() string

+ Validate func() error

+ Verify func(message, sigma []byte) error

+ type MSPManager interface

+ DeserializeIdentity func(serializedIdentity []byte) (MSPIdentity, error)

+ type MetadataService interface

+ Exists func(txid string) bool

+ LoadTransient func(txid string) (TransientMap, error)

+ StoreTransient func(txid string, transientMap TransientMap) error

+ type Ordering interface

+ Broadcast func(blob interface{}) error

+ type ProcessTransaction interface

+ Channel func() string

+ FunctionAndParameters func() (string, []string)

+ ID func() string

+ Network func() string

+ type ProcessedTransaction interface

+ Envelope func() []byte

+ IsValid func() bool

+ Results func() []byte

+ TxID func() string

+ ValidationCode func() int32

+ type Processor interface

+ Process func(req Request, tx ProcessTransaction, rws RWSet, ns string) error

+ type ProcessorManager interface

+ AddChannelProcessor func(channel string, ns string, processor Processor) error

+ AddProcessor func(ns string, processor Processor) error

+ ProcessByID func(channel, txid string) error

+ SetDefaultProcessor func(processor Processor) error

+ type Proposal interface

+ Header func() []byte

+ Payload func() []byte

+ type ProposalResponse interface

+ Endorser func() []byte

+ EndorserSignature func() []byte

+ Payload func() []byte

+ ResponseMessage func() string

+ ResponseStatus func() int32

+ Results func() []byte

+ type QueryExecutor interface

+ Done func()

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

+ GetStateMetadata func(namespace, key string) (map[string][]byte, uint64, uint64, error)

+ GetStateRangeScanIterator func(namespace string, startKey string, endKey string) (driver.VersionedResultsIterator, error)

+ type RWSExtractor interface

+ Extract func(tx []byte) (ProcessTransaction, RWSet, error)

+ type RWSet interface

+ AppendRWSet func(raw []byte, nss ...string) error

+ Bytes func() ([]byte, error)

+ Clear func(ns string) error

+ DeleteState func(namespace string, key string) error

+ Done func()

+ Equals func(rws interface{}, nss ...string) error

+ GetReadAt func(ns string, i int) (string, []byte, error)

+ GetReadKeyAt func(ns string, i int) (string, error)

+ GetState func(namespace string, key string, opts ...GetStateOpt) ([]byte, error)

+ GetStateMetadata func(namespace, key string, opts ...GetStateOpt) (map[string][]byte, error)

+ GetWriteAt func(ns string, i int) (string, []byte, error)

+ IsValid func() error

+ Namespaces func() []string

+ NumReads func(ns string) int

+ NumWrites func(ns string) int

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

+ SetStateMetadata func(namespace, key string, metadata map[string][]byte) error

+ type RWSetLoader interface

+ GetRWSetFromETx func(txID string) (RWSet, ProcessTransaction, error)

+ GetRWSetFromEvn func(txID string) (RWSet, ProcessTransaction, error)

+ type Request interface

+ ID func() string

+ type SeekEnd struct

+ type SeekPos struct

+ Txid string

+ type SeekStart struct

+ type SignedProposal interface

+ ChaincodeName func() string

+ ChaincodeVersion func() string

+ ProposalBytes func() []byte

+ ProposalHash func() []byte

+ Signature func() []byte

+ type Signer interface

+ Sign func(message []byte) ([]byte, error)

+ type SignerService interface

+ GetSigner func(id view.Identity) (Signer, error)

+ GetSigningIdentity func(id view.Identity) (SigningIdentity, error)

+ RegisterSigner func(identity view.Identity, signer Signer, verifier Verifier) error

+ type SigningIdentity interface

+ Serialize func() ([]byte, error)

+ Sign func(msg []byte) ([]byte, error)

+ type TXIDStore interface

+ GetLastTxID func() (string, error)

+ Iterator func(pos interface{}) (TxidIterator, error)

+ type Transaction interface

+ AppendParameter func(p []byte)

+ AppendProposalResponse func(response ProposalResponse) error

+ Bytes func() ([]byte, error)

+ BytesNoTransient func() ([]byte, error)

+ Chaincode func() string

+ ChaincodeVersion func() string

+ Channel func() string

+ Close func()

+ Creator func() view.Identity

+ Done func() error

+ Endorse func() error

+ EndorseProposal func() error

+ EndorseProposalResponse func() error

+ EndorseProposalResponseWithIdentity func(identity view.Identity) error

+ EndorseProposalWithIdentity func(identity view.Identity) error

+ EndorseWithIdentity func(identity view.Identity) error

+ EndorseWithSigner func(identity view.Identity, s Signer) error

+ From func(payload Transaction) (err error)

+ Function func() string

+ FunctionAndParameters func() (string, []string)

+ GetRWSet func() (RWSet, error)

+ ID func() string

+ Network func() string

+ Nonce func() []byte

+ Parameters func() [][]byte

+ Proposal func() Proposal

+ ProposalHasBeenEndorsedBy func(party view.Identity) error

+ ProposalResponse func() ([]byte, error)

+ ProposalResponses func() []ProposalResponse

+ RWS func() RWSet

+ Raw func() ([]byte, error)

+ ResetTransient func()

+ Results func() ([]byte, error)

+ SetFromBytes func(raw []byte) error

+ SetFromEnvelopeBytes func(raw []byte) error

+ SetParameterAt func(i int, p []byte) error

+ SetProposal func(chaincode string, version string, function string, params ...string)

+ SetRWSet func() error

+ SignedProposal func() SignedProposal

+ StoreTransient func() error

+ Transient func() TransientMap

+ type TransactionManager interface

+ ComputeTxID func(id *TxID) string

+ NewEnvelope func() Envelope

+ NewProposalResponseFromBytes func(raw []byte) (ProposalResponse, error)

+ NewTransaction func(creator view.Identity, nonce []byte, txid string, channel string) (Transaction, error)

+ NewTransactionFromBytes func(channel string, raw []byte) (Transaction, error)

+ type TransactionStatusChanged struct

+ ThisTopic string

+ TxID string

+ VC ValidationCode

+ func (t *TransactionStatusChanged) Message() interface{}

+ func (t *TransactionStatusChanged) Topic() string

+ type TransientMap map[string][]byte

+ type TxID struct

+ Creator []byte

+ Nonce []byte

+ type TxStatusChangeListener interface

+ OnStatusChange func(txID string, status int) error

+ type TxidIterator interface

+ Close func()

+ Next func() (*ByNum, error)

+ type ValidationCode int

+ const Busy

+ const HasDependencies

+ const Invalid

+ const Unknown

+ const Valid

+ type Vault interface

+ GetEphemeralRWSet func(rwset []byte, namespaces ...string) (RWSet, error)

+ GetRWSet func(txid string, rwset []byte) (RWSet, error)

+ NewQueryExecutor func() (QueryExecutor, error)

+ NewRWSet func(txid string) (RWSet, error)

+ type Verifier interface

+ Verify func(message, sigma []byte) error

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