Documentation
      ¶
    
    
  
    
  
    Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Receiver ¶
type Receiver struct {
	// IsolatedTx causes Ordered returns [][]{curBatch, []{newTx}}, false when set to true
	IsolatedTx bool
	// CutAncestors causes Ordered returns [][]{curBatch}, true when set to true
	CutAncestors bool
	// CutNext causes Ordered returns [][]{append(curBatch, newTx)}, false when set to true
	CutNext bool
	// CurBatch is the currently outstanding messages in the batch
	CurBatch []*cb.Envelope
	// Block is a channel which is read from before returning from Ordered, it is useful for synchronization
	// If you do not wish synchronization for whatever reason, simply close the channel
	Block chan struct{}
}
    Receiver mocks the blockcutter.Receiver interface
func NewReceiver ¶
func NewReceiver() *Receiver
NewReceiver returns the mock blockcutter.Receiver implementation
func (*Receiver) Cut ¶
Cut terminates the current batch, returning it
      
      Source Files
      ¶
    
- blockcutter.go
 
 Click to show internal directories. 
   Click to hide internal directories.