Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Receiver ¶
type Receiver struct {
// QueueNext causes Ordered returns nil false when not set to true
QueueNext bool
// IsolatedTx causes Ordered returns [][]{curBatch, []{newTx}}, true when set to true
IsolatedTx bool
// CutNext causes Ordered returns [][]{append(curBatch, newTx)}, true 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 implemenation
func (*Receiver) Cut ¶
Cut terminates the current batch, returning it
Source Files
¶
- blockcutter.go
Click to show internal directories.
Click to hide internal directories.