()
| 1447 | } |
| 1448 | |
| 1449 | func (b *Broker) authenticateViaSASLv0() error { |
| 1450 | switch b.conf.Net.SASL.Mechanism { |
| 1451 | case SASLTypeSCRAMSHA256, SASLTypeSCRAMSHA512: |
| 1452 | return b.sendAndReceiveSASLSCRAMv0() |
| 1453 | case SASLTypeGSSAPI: |
| 1454 | return b.sendAndReceiveKerberos() |
| 1455 | default: |
| 1456 | return b.sendAndReceiveSASLPlainAuthV0() |
| 1457 | } |
| 1458 | } |
| 1459 | |
| 1460 | func (b *Broker) authenticateViaSASLv1() error { |
| 1461 | metricRegistry := b.metricRegistry |
no test coverage detected