Versions in this module Expand all Collapse all v0 v0.1.1 Jun 9, 2022 v0.1.0 Jun 9, 2022 Changes in this version + var SHA256 scram.HashGeneratorFcn = func() hash.Hash + var SHA512 scram.HashGeneratorFcn = func() hash.Hash + func NewKafkaAdapter(route *router.Route) (router.LogAdapter, error) + type DockerInfo struct + Hostname string + ID string + Image string + Labels map[string]string + Name string + type KafkaAdapter struct + func (a *KafkaAdapter) Stream(logstream chan *router.Message) + type SASLAuthentication struct + func NewSASLAuthentication(options map[string]string) *SASLAuthentication + func (authen *SASLAuthentication) SetConfig(config *sarama.Config) error + type SCRAMClient struct + func (x *SCRAMClient) Begin(userName, password, authzID string) (err error) + func (x *SCRAMClient) Done() bool + func (x *SCRAMClient) Step(challenge string) (string, error)