sdktest

Documentation

Index

• type MockPipe
  • func (p *MockPipe) Close() error
  • func (p *MockPipe) Flush() error
  • func (p *MockPipe) Write(object sdk.Model) error

Types

type MockPipe

type MockPipe struct {
	// Written is all the models written to this pipe in order
	Written []sdk.Model
	// Closed is set to true every time Close() is called
	Closed bool
	// Flushed is set to true every time Flush() is called
	Flushed bool

	// WriteErr is returned by Write
	WriteErr error
	// FlushErr is returned by Flush
	FlushErr error
	// CloseErr is returned by Close
	CloseErr error
}

MockPipe stores sent things inside it

func (*MockPipe) Close

func (p *MockPipe) Close() error

Close is called when the integration has completed and no more data will be sent

func (*MockPipe) Flush

func (p *MockPipe) Flush() error

Flush will tell the pipe to flush any pending data

func (*MockPipe) Write

func (p *MockPipe) Write(object sdk.Model) error

Write a model back to the output system