hlf

Documentation

Index

• Constants
• func IsEndorsementMismatchErr(err error) bool
• func IsOrderingReqSizeExceededErr(err error) bool
• func LogBatchContent(log glog.Logger, b *executordto.Batch)
• func SplitBatchForExec(executedTxsCount, lastSuccessCount, lastErrorCount int, ...) *executordto.Batch
• type ChCollector
  • 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
  • func NewChCollectorCreator(dstChName string, connectionProfile string, userName string, orgName string, ...) ChCollectorCreator
• type ChExecutor
  • 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)
  • func NewChExecutorCreator(chName string, connectionProfile string, user string, org string, ...) ChExecutorCreator
• type EventsSrc
• type ExecWithSplitHlp
  • 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 ExecuteOptions
• type Executor

Constants

const ErrReqSizeMarker = "is bigger than request max bytes"

Functions

func IsEndorsementMismatchErr

func IsEndorsementMismatchErr(err error) bool

IsEndorsementMismatchErr checks if the error is a mismatch.

func IsOrderingReqSizeExceededErr

func IsOrderingReqSizeExceededErr(err error) bool

IsOrderingReqSizeExceededErr checks error message for containing ErrReqSizeMarker

func LogBatchContent

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

func SplitBatchForExec

func SplitBatchForExec(executedTxsCount, lastSuccessCount, lastErrorCount int, origBatch *executordto.Batch, log glog.Logger) *executordto.Batch

SplitBatchForExec splits transactions, based on results of previous executions of a batch executedTxsCount - amount of transactions that were successfully executed and must be skipped lastSuccessCount - amount of transactions that were successfully executed previously, next batch must be the same or less lastErrorCount - amount of transactions that were not successfully executed previously, next batch must be less

Types

type ChCollector

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

func CreateChCollectorAdv

func CreateChCollectorAdv(ctx context.Context,
	log glog.Logger, m metrics.Metrics,
	srcChName string, startFrom uint64,
	connectionProfile, userName, orgName string,
	proxyEvents chan<- *fab.BlockEvent,
	rc realCollector,
	createEventsSrc func(ctx context.Context, startFrom uint64) (EventsSrc, error),
	delayAfterSrcError time.Duration,
	awaitEventsTimeout time.Duration,
) *ChCollector

CreateChCollectorAdv - creates advanced channel collector

func (*ChCollector) Close

func (cc *ChCollector) Close()

func (*ChCollector) GetData

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

type ChCollectorCreator

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

func CreateChCollectorCreatorFromConfig

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

CreateChCollectorCreatorFromConfig creates ChCollectorCreator specified by robot config

func NewChCollectorCreator

func NewChCollectorCreator(
	dstChName string,
	connectionProfile string,
	userName string,
	orgName string,
	txPrefixes parserdto.TxPrefixes,
	bufSize uint,
) ChCollectorCreator

type ChExecutor

type ChExecutor struct {
	// args
	Log     glog.Logger
	Metrics metrics.Metrics
	ChName  string

	Executor             Executor
	RetryExecuteAttempts uint
	RetryExecuteMaxDelay time.Duration
	RetryExecuteDelay    time.Duration
	// contains filtered or unexported fields
}

func CreateChExecutor

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

CreateChExecutor creates New ChExecutor

func (*ChExecutor) CalcBatchSize

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

func (*ChExecutor) Close

func (che *ChExecutor) Close()

func (*ChExecutor) Execute

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

type ChExecutorCreator

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

func CreateChExecutorCreatorFromConfig

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

CreateChExecutorCreatorFromConfig - creates ChExecutorCreator specified by robot config

func NewChExecutorCreator

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

type EventsSrc

type EventsSrc interface {
	Close()
	GetEvents() <-chan *fab.BlockEvent
}

EventsSrc - event source

type ExecWithSplitHlp

type ExecWithSplitHlp struct {
	Log                        glog.Logger
	ExecuteBatch               func(ctx context.Context, b *executordto.Batch) (uint64, error)
	ReqSizeExceededErrCallBack func(b *executordto.Batch, num int)
	ReqSizeExceededErrNum      int
}

ExecWithSplitHlp - struct for execution with split

func NewExecWithSplitHlp

func NewExecWithSplitHlp(
	log glog.Logger,
	executeBatch func(ctx context.Context, b *executordto.Batch) (uint64, error),
	reqSizeExceededErrCallBack func(b *executordto.Batch, num int),
) *ExecWithSplitHlp

func (*ExecWithSplitHlp) Execute

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

func (*ExecWithSplitHlp) RaiseReqSizeExceededIfErr

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

type ExecuteOptions

type ExecuteOptions struct {
	ExecuteTimeout time.Duration
}

type Executor

type Executor interface {
	Execute(ctx context.Context, req channel.Request) (channel.Response, error)
}