Struct StreamingPlanNode

broker/common/mocks/StreamingPlanNode.go:8–10

StreamingPlanNode is an autogenerated mock type for the StreamingPlanNode type

// StreamingPlanNode is an autogenerated mock type for the StreamingPlanNode type
type StreamingPlanNode struct {
	mock.Mock
}

// Execute provides a mock function with given fields: writer
func (_m *StreamingPlanNode) Execute(writer io.Writer) error {