executeSpecialCommand handles commands with special routing requirements
(ctx context.Context, cmd Cmder, policy *routing.CommandPolicy, node *clusterNode)
| 279 | |
| 280 | // executeSpecialCommand handles commands with special routing requirements |
| 281 | func (c *ClusterClient) executeSpecialCommand(ctx context.Context, cmd Cmder, policy *routing.CommandPolicy, node *clusterNode) error { |
| 282 | switch cmd.Name() { |
| 283 | case "ft.cursor": |
| 284 | return c.executeCursorCommand(ctx, cmd) |
| 285 | default: |
| 286 | return c.executeDefault(ctx, cmd, policy, node) |
| 287 | } |
| 288 | } |
| 289 | |
| 290 | // executeCursorCommand handles FT.CURSOR commands with sticky routing |
| 291 | func (c *ClusterClient) executeCursorCommand(ctx context.Context, cmd Cmder) error { |
no test coverage detected