Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( SHA256 scram.HashGeneratorFcn = sha256.New SHA512 scram.HashGeneratorFcn = sha512.New )
Functions ¶
func GetServiceAddresses ¶
todo: deprecate?
Types ¶
type KafkaDriver ¶
type KafkaDriver struct {
// contains filtered or unexported fields
}
func (*KafkaDriver) Close ¶
func (d *KafkaDriver) Close() error
func (*KafkaDriver) Errors ¶
func (d *KafkaDriver) Errors() <-chan error
func (*KafkaDriver) Init ¶
func (d *KafkaDriver) Init() error
func (*KafkaDriver) Prepare ¶
func (d *KafkaDriver) Prepare() error
func (*KafkaDriver) Send ¶
func (d *KafkaDriver) Send(key, data []byte) error
type KafkaSASLAlgorithm ¶
type KafkaSASLAlgorithm string
const ( KAFKA_SASL_NONE KafkaSASLAlgorithm = "none" KAFKA_SASL_PLAIN KafkaSASLAlgorithm = "plain" KAFKA_SASL_SCRAM_SHA256 KafkaSASLAlgorithm = "scram-sha256" KAFKA_SASL_SCRAM_SHA512 KafkaSASLAlgorithm = "scram-sha512" )
type KafkaTransportError ¶
type KafkaTransportError struct {
Err error
}
Error specifically for inner Kafka errors
func (*KafkaTransportError) Error ¶
func (e *KafkaTransportError) Error() string
func (*KafkaTransportError) Unwrap ¶
func (e *KafkaTransportError) Unwrap() []error
type XDGSCRAMClient ¶
type XDGSCRAMClient struct {
*scram.Client
*scram.ClientConversation
scram.HashGeneratorFcn
}
func (*XDGSCRAMClient) Begin ¶
func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)
func (*XDGSCRAMClient) Done ¶
func (x *XDGSCRAMClient) Done() bool
Source Files
Click to show internal directories.
Click to hide internal directories.