The highest tagged major version is
Documentation
¶
Index ¶
- type Pipe
- func (p *Pipe) AssertExpectations()
- func (p *Pipe) Commit(msg *streams.Message) error
- func (p *Pipe) ExpectCommit()
- func (p *Pipe) ExpectForward(k, v interface{})
- func (p *Pipe) ExpectForwardToChild(k, v interface{}, index int)
- func (p *Pipe) Forward(msg *streams.Message) error
- func (p *Pipe) ForwardToChild(msg *streams.Message, index int) error
- func (p *Pipe) Queue() []streams.NodeMessage
- func (p *Pipe) ShouldError()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Pipe ¶
type Pipe struct {
// contains filtered or unexported fields
}
Pipe is a mock Pipe.
func (*Pipe) AssertExpectations ¶
func (p *Pipe) AssertExpectations()
func (*Pipe) ExpectCommit ¶
func (p *Pipe) ExpectCommit()
func (*Pipe) ExpectForward ¶
func (p *Pipe) ExpectForward(k, v interface{})
func (*Pipe) ExpectForwardToChild ¶
func (*Pipe) ForwardToChild ¶
Forward queues the data to the the given processor(s) child in the topology.
func (*Pipe) Queue ¶
func (p *Pipe) Queue() []streams.NodeMessage
Queue gets the queued Messages for each Node.
func (*Pipe) ShouldError ¶
func (p *Pipe) ShouldError()
Source Files
Click to show internal directories.
Click to hide internal directories.