saramaext

Documentation

Index

• Variables
• type ConfigBuilder
  • func NewConfigBuilder() *ConfigBuilder
  • func NewConfigBuilderFrom(conf *sarama.Config) *ConfigBuilder
  • func (cb *ConfigBuilder) Build() (*sarama.Config, error)
  • func (cb *ConfigBuilder) With(callback func(conf *sarama.Config)) *ConfigBuilder
  • func (cb *ConfigBuilder) WithSASLSCRAM(user, password string, hashGenFcn scram.HashGeneratorFcn, ...) *ConfigBuilder
• 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 ConfigBuilder

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

func NewConfigBuilder

func NewConfigBuilder() *ConfigBuilder

func NewConfigBuilderFrom

func NewConfigBuilderFrom(conf *sarama.Config) *ConfigBuilder

func (*ConfigBuilder) Build

func (cb *ConfigBuilder) Build() (*sarama.Config, error)

func (*ConfigBuilder) With

func (cb *ConfigBuilder) With(callback func(conf *sarama.Config)) *ConfigBuilder

func (*ConfigBuilder) WithSASLSCRAM

func (cb *ConfigBuilder) WithSASLSCRAM(user, password string, hashGenFcn scram.HashGeneratorFcn, mechanism sarama.SASLMechanism) *ConfigBuilder

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)