(msg []byte)
| 1779 | } |
| 1780 | |
| 1781 | func (b *Broker) createSaslAuthenticateRequest(msg []byte) *SaslAuthenticateRequest { |
| 1782 | authenticateRequest := SaslAuthenticateRequest{SaslAuthBytes: msg} |
| 1783 | if b.conf.Version.IsAtLeast(V2_5_0_0) { |
| 1784 | authenticateRequest.Version = 2 |
| 1785 | } else if b.conf.Version.IsAtLeast(V2_2_0_0) { |
| 1786 | authenticateRequest.Version = 1 |
| 1787 | } |
| 1788 | |
| 1789 | return &authenticateRequest |
| 1790 | } |
| 1791 | |
| 1792 | // Build SASL/OAUTHBEARER initial client response as described by RFC-7628 |
| 1793 | // https://tools.ietf.org/html/rfc7628 |
no test coverage detected