chrobot

type ChCollector interface {
	GetData() <-chan *collectordto.BlockData
	Close()
}

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

type ChExecutor interface {
	// CalcBatchSize calculates and returns batch size (in bytes) which will be sent to chaincode,
	// in method Execute
	CalcBatchSize(b *executordto.Batch) (uint, error)

	// Execute sends batch to chaincode and returns num of block in which batch was committed.
	// minHeight - the minimum height that peers must have in order to execute batch
	Execute(ctx context.Context, b *executordto.Batch, minHeight uint64) (uint64, error)
	Close()
}

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

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

type ChStorage interface {
	SaveCheckPoints(ctx context.Context, cp *stordto.ChCheckPoint) (*stordto.ChCheckPoint, error)
	LoadCheckPoints(ctx context.Context) (*stordto.ChCheckPoint, bool, error)
}