Versions in this module Expand all Collapse all v1 v1.0.2 May 13, 2022 Changes in this version + var KafkaSHA256 scram.HashGeneratorFcn = sha256.New + var KafkaSHA512 scram.HashGeneratorFcn = sha512.New + type Config struct + Brokers []xnet.Host + Enabled bool + LogOnce func(ctx context.Context, err error, id interface{}, errKind ...interface{}) + SASL struct{ ... } + TLS struct{ ... } + Topic string + Version string + type Target struct + func New(config Config) *Target + func (h *Target) Cancel() + func (h *Target) Endpoint() string + func (h *Target) Init() error + func (h *Target) Send(entry interface{}, errKind string) error + func (h *Target) String() string + type XDGSCRAMClient struct + 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)
Go to main page