()
| 1548 | } |
| 1549 | |
| 1550 | func (c *ClusterClient) Pipeline() Pipeliner { |
| 1551 | pipe := Pipeline{ |
| 1552 | exec: pipelineExecer(c.processPipelineHook), |
| 1553 | } |
| 1554 | pipe.init() |
| 1555 | return &pipe |
| 1556 | } |
| 1557 | |
| 1558 | func (c *ClusterClient) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { |
| 1559 | return c.Pipeline().Pipelined(ctx, fn) |
no test coverage detected