Skip to content
This repository was archived by the owner on Dec 1, 2021. It is now read-only.

Commit 22f2d10

Browse files
committed
align interface
1 parent 71d7f36 commit 22f2d10

File tree

2 files changed

+13
-1
lines changed

2 files changed

+13
-1
lines changed

src/Client.php

+1-1
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,7 @@ public function stack($tag = null, $connectionAlias = null)
132132
*/
133133
public function runStack(StackInterface $stack)
134134
{
135-
$connectionAlias = $stack instanceof Stack && $stack->hasWrites()
135+
$connectionAlias = $stack->hasWrites()
136136
? $this->connectionManager->getMasterConnection()->getAlias()
137137
: $stack->getConnectionAlias();
138138
$pipeline = $this->pipeline(null, null, $stack->getTag(), $connectionAlias);

src/StackInterface.php

+12
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,13 @@ public static function create($tag = null, $connectionAlias = null);
3333
*/
3434
public function push($query, $parameters = null, $tag = null);
3535

36+
/**
37+
* @param string $query
38+
* @param null|array $parameters
39+
* @param null|array $tag
40+
*/
41+
public function pushWrite($query, $parameters = null, $tag = null);
42+
3643
/**
3744
* @param $query
3845
* @param array|null $parameters
@@ -69,4 +76,9 @@ public function getTag();
6976
* @return null|string
7077
*/
7178
public function getConnectionAlias();
79+
80+
/**
81+
* @return bool
82+
*/
83+
public function hasWrites();
7284
}

0 commit comments

Comments
 (0)