Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var SHA256 scram.HashGeneratorFcn = func() hash.Hash { return sha256.New() }
View Source
var SHA512 scram.HashGeneratorFcn = func() hash.Hash { return sha512.New() }
Functions ¶
This section is empty.
Types ¶
type KafkaClient ¶
type KafkaClient struct {
// contains filtered or unexported fields
}
func NewConsumerClient ¶
func NewConsumerClient(cfg xkafka.Config) *KafkaClient
func NewProducerClient ¶
func NewProducerClient(cfg xkafka.Config) *KafkaClient
func (*KafkaClient) AsyncSend ¶
func (c *KafkaClient) AsyncSend(topic, key string, values ...interface{}) error
func (*KafkaClient) Close ¶
func (c *KafkaClient) Close()
func (*KafkaClient) Listen ¶
func (c *KafkaClient) Listen(fn func(message interface{}))
func (*KafkaClient) Send ¶
func (c *KafkaClient) Send(topic, key string, values ...interface{}) error
type KafkaMessage ¶
type KafkaMessage = sarama.ConsumerMessage
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.