()
| 825 | } |
| 826 | |
| 827 | func (c *Ring) TxPipeline() Pipeliner { |
| 828 | pipe := Pipeline{ |
| 829 | exec: func(ctx context.Context, cmds []Cmder) error { |
| 830 | cmds = wrapMultiExec(ctx, cmds) |
| 831 | return c.processTxPipelineHook(ctx, cmds) |
| 832 | }, |
| 833 | } |
| 834 | pipe.init() |
| 835 | return &pipe |
| 836 | } |
| 837 | |
| 838 | func (c *Ring) generalProcessPipeline( |
| 839 | ctx context.Context, cmds []Cmder, tx bool, |
no test coverage detected