| 793 | } |
| 794 | |
| 795 | func newAuthDispatchRequest(requestedModel string, sessionID string, headers http.Header, count int) authDispatchRequest { |
| 796 | if count <= 0 { |
| 797 | count = 1 |
| 798 | } |
| 799 | return authDispatchRequest{ |
| 800 | Type: "auth", |
| 801 | Model: requestedModel, |
| 802 | Count: count, |
| 803 | SessionID: strings.TrimSpace(sessionID), |
| 804 | Headers: headersToLowerMap(headers), |
| 805 | } |
| 806 | } |
| 807 | |
| 808 | func (c *Client) RPopAuth(ctx context.Context, requestedModel string, sessionID string, headers http.Header, count int) ([]byte, error) { |
| 809 | cmd, errClient := c.commandClient() |