The highest tagged major version is v6.

mocks

package

v1.1.0 Latest Latest Go to latest Published: Oct 17, 2018 License: MIT Imports: 3 Imported by: 0

Details

View Source

const (
	// Anything is used where the expectation should not be considered.
	Anything = "mocks.Anything"
)

This section is empty.

This section is empty.

type ChildMessage struct {
	Index int
	Msg   *streams.Message
}

ChildMessage represents a message forwarded to a child index.

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

Pipe is a mock Pipe.

func NewPipe(t *testing.T) *Pipe

NewPipe create a new mock Pipe instance.

func (p *Pipe) AssertExpectations()

AssertExpectations asserts that the expectations were met.

func (p *Pipe) Commit(msg *streams.Message) error

Commit commits the current state in the sources.

func (p *Pipe) ExpectCommit()

ExpectCommit registers an expectation of a Commit the Pipe.

func (p *Pipe) ExpectForward(k, v interface{})

ExpectForward registers an expectation of a Forward of the Pipe.

func (p *Pipe) ExpectForwardToChild(k, v interface{}, index int)

ExpectForwardToChild registers an expectation of a ForwardToChild the Pipe.

func (p *Pipe) Forward(msg *streams.Message) error

Forward queues the data to all processor children in the topology.

func (p *Pipe) ForwardToChild(msg *streams.Message, index int) error

ForwardToChild queues the data to the the given processor(s) child in the topology.

func (p *Pipe) Messages() []ChildMessage

Messages gets the queued Messages for each Node.

func (p *Pipe) ShouldError()

ShouldError indicates that an error should be returned on the next operation.