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 ¶ added in v0.3.0
type Pipe struct {
// contains filtered or unexported fields
}
Pipe is a mock Pipe.
func (*Pipe) AssertExpectations ¶ added in v0.3.0
func (p *Pipe) AssertExpectations()
func (*Pipe) ExpectCommit ¶ added in v0.3.0
func (p *Pipe) ExpectCommit()
func (*Pipe) ExpectForward ¶ added in v0.3.0
func (p *Pipe) ExpectForward(k, v interface{})
func (*Pipe) ExpectForwardToChild ¶ added in v0.3.0
func (*Pipe) Forward ¶ added in v0.3.0
Forward queues the data to all processor children in the topology.
func (*Pipe) ForwardToChild ¶ added in v0.3.0
Forward queues the data to the the given processor(s) child in the topology.
func (*Pipe) Queue ¶ added in v1.0.0
func (p *Pipe) Queue() []streams.NodeMessage
Queue gets the queued Messages for each Node.
func (*Pipe) ShouldError ¶ added in v0.3.0
func (p *Pipe) ShouldError()
Source Files
Click to show internal directories.
Click to hide internal directories.