(ctx context.Context, cmds []Cmder)
| 1695 | } |
| 1696 | |
| 1697 | func (c *ClusterClient) cmdsAreReadOnly(ctx context.Context, cmds []Cmder) bool { |
| 1698 | for _, cmd := range cmds { |
| 1699 | cmdInfo := c.cmdInfo(ctx, cmd.Name()) |
| 1700 | if cmdInfo == nil || !cmdInfo.ReadOnly { |
| 1701 | return false |
| 1702 | } |
| 1703 | } |
| 1704 | return true |
| 1705 | } |
| 1706 | |
| 1707 | func (c *ClusterClient) processPipelineNode( |
| 1708 | ctx context.Context, node *clusterNode, cmds []Cmder, failedCmds *cmdsMap, |
no test coverage detected