Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsEndorsementMismatchErr ¶
IsEndorsementMismatchErr checks if the error is a mismatch.
Types ¶
type ChCollectorCreator ¶
type ChCollectorCreator func(ctx context.Context, dataReady chan<- struct{}, srcChName string, startFrom uint64) (*chCollector, error)
ChCollectorCreator is a type for channel collector creator
func NewChCollectorCreator ¶
func NewChCollectorCreator( dstChName, connectionProfile, userName, orgName string, txPrefixes parserdto.TxPrefixes, bufSize uint, ) ChCollectorCreator
NewChCollectorCreator creates a new ChCollectorCreator
func NewChCollectorCreatorWithCryptoMgr ¶
func NewChCollectorCreatorWithCryptoMgr( dstChName, connectionProfile, userName, orgName string, txPrefixes parserdto.TxPrefixes, cryptoManager manager.Manager, bufSize uint, ) ChCollectorCreator
NewChCollectorCreatorWithCryptoMgr creates a new ChCollectorCreator with crypto manager
type ChExecutorCreator ¶
ChExecutorCreator is a type for channel executor creator
func NewChExecutorCreator ¶
func NewChExecutorCreator(chName, connectionProfile, user, org string, useSmartBFT bool, execOpts ExecuteOptions, ) ChExecutorCreator
NewChExecutorCreator creates a new ChExecutorCreator
func NewChExecutorCreatorWithCryptoMgr ¶
func NewChExecutorCreatorWithCryptoMgr(chName, connectionProfile, user, org string, useSmartBFT bool, execOpts ExecuteOptions, cryptoManager manager.Manager, ) ChExecutorCreator
NewChExecutorCreatorWithCryptoMgr creates a new ChExecutorCreator with crypto manager
type ExecuteOptions ¶
type ExecuteOptions struct {
// ExecuteTimeout is a timeout for Execute method
ExecuteTimeout time.Duration
// WaitCommitAttempts is a number of attempts to wait for commit event
WaitCommitAttempts uint
// WaitCommitAttemptTimeout is a timeout for each attempt to wait for commit event
WaitCommitAttemptTimeout time.Duration
}
ExecuteOptions for Execute method
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.