(ctx context.Context, fn func(Pipeliner) error)
| 1829 | } |
| 1830 | |
| 1831 | func (c *ClusterClient) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { |
| 1832 | return c.TxPipeline().Pipelined(ctx, fn) |
| 1833 | } |
| 1834 | |
| 1835 | func (c *ClusterClient) processTxPipeline(ctx context.Context, cmds []Cmder) error { |
| 1836 | // Only call time.Now() if pipeline operation duration callback is set to avoid overhead |
nothing calls this directly
no test coverage detected