kafka

Documentation

Index

• Variables
• type KafkaDriver
  • func (d *KafkaDriver) Close(context.Context) error
  • func (d *KafkaDriver) Init(context.Context) error
  • func (d *KafkaDriver) Prepare() error
  • func (d *KafkaDriver) Send(key, data []byte) error
• type KafkaSASLAlgorithm
• type XDGSCRAMClient
  • func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)
  • func (x *XDGSCRAMClient) Done() bool
  • func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)

Variables

var (
	SHA256 scram.HashGeneratorFcn = sha256.New
	SHA512 scram.HashGeneratorFcn = sha512.New
)

Types

type KafkaDriver

type KafkaDriver struct {
	// contains filtered or unexported fields
}

func (*KafkaDriver) Close

func (d *KafkaDriver) Close(context.Context) error

func (*KafkaDriver) Init

func (d *KafkaDriver) Init(context.Context) 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 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

func (*XDGSCRAMClient) Step

func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)