Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

hlf

package

Go to main page

Versions in this module

v0

v0.0.3

Aug 14, 2024

Changes in this version

+ const ErrReqSizeMarker

+ func IsOrderingReqSizeExceededErr(err error) bool

+ func LogBatchContent(log glog.Logger, b *executordto.Batch)

+ func SplitBatchForExec(executedTxsCount, lastSuccessCount, lastErrorCount int, ...) *executordto.Batch

+ type ChCollector struct

+ func CreateChCollectorAdv(ctx context.Context, log glog.Logger, m metrics.Metrics, srcChName string, ...) *ChCollector

+ func (cc *ChCollector) Close()

+ func (cc *ChCollector) GetData() <-chan *collectordto.BlockData

type ChCollectorCreator

+ func CreateChCollectorCreatorFromConfig(cfg *config.Config, hlfProfile *hlfprofile.HlfProfile, rCfg *config.Robot) ChCollectorCreator

+ type ChExecutor struct

+ ChName string

+ Executor Executor

+ Log glog.Logger

+ Metrics metrics.Metrics

+ RetryExecuteAttempts uint

+ RetryExecuteDelay time.Duration

+ RetryExecuteMaxDelay time.Duration

+ func CreateChExecutor(ctx context.Context, chName string, connectionProfile string, userName string, ...) (*ChExecutor, error)

+ func (che *ChExecutor) CalcBatchSize(b *executordto.Batch) (uint, error)

+ func (che *ChExecutor) Close()

+ func (che *ChExecutor) Execute(ctx context.Context, b *executordto.Batch, _ uint64) (uint64, error)

type ChExecutorCreator

+ func CreateChExecutorCreatorFromConfig(cfg *config.Config, hlfProfile *hlfprofile.HlfProfile, rCfg *config.Robot) (ChExecutorCreator, error)

+ type EventsSrc interface

+ Close func()

+ GetEvents func() <-chan *fab.BlockEvent

+ type ExecWithSplitHlp struct

+ ExecuteBatch func(ctx context.Context, b *executordto.Batch) (uint64, error)

+ Log glog.Logger

+ ReqSizeExceededErrCallBack func(b *executordto.Batch, num int)

+ ReqSizeExceededErrNum int

+ func NewExecWithSplitHlp(log glog.Logger, ...) *ExecWithSplitHlp

+ func (hlp *ExecWithSplitHlp) Execute(ctx context.Context, b *executordto.Batch) (uint64, error)

+ func (hlp *ExecWithSplitHlp) RaiseReqSizeExceededIfErr(b *executordto.Batch, err error)

+ type Executor interface

+ Execute func(ctx context.Context, req channel.Request) (channel.Response, error)

v0.0.2

Jul 4, 2024

v0.0.2-debug

Sep 5, 2024

v0.0.1

Jun 5, 2024

Changes in this version

+ func IsEndorsementMismatchErr(err error) bool

+ type ChCollectorCreator func(ctx context.Context, dataReady chan<- struct{}, srcChName string, ...) (*chCollector, error)

+ func NewChCollectorCreator(dstChName, connectionProfile, userName, orgName string, ...) ChCollectorCreator

+ type ChExecutorCreator = func(ctx context.Context) (*chExecutor, error)

+ func NewChExecutorCreator(chName, connectionProfile, user, org string, execOpts ExecuteOptions) ChExecutorCreator

+ type ExecuteOptions struct

+ ExecuteTimeout time.Duration