auth

Documentation

Index

• Variables
• type AuthOptions
  • func GetAuthOptions(opts ...Option) *AuthOptions
  • func (opts *AuthOptions) CreateTlsConfiguration() (t *tls.Config)
  • func (opts *AuthOptions) InitSASLSCRAM(conf *sarama.Config)
  • func (opts *AuthOptions) InitSSL(config *sarama.Config)
• type Option
  • func WithAuthentication(authentication string) Option
  • func WithEnableSASL(enableSASL bool) Option
  • func WithEnableSSL(enableSSL bool) Option
  • func WithSASLPassword(saslPassword string) Option
  • func WithSASLUser(saslUser string) Option
  • func WithSSLCaFile(caFile string) Option
  • func WithSSLCertFile(certFile string) Option
  • func WithSSLKeyFile(keyFile string) Option
  • func WithScramAlgorithm(scramAlgorithm string) Option
• 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 AuthOptions

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

func GetAuthOptions

func GetAuthOptions(opts ...Option) *AuthOptions

func (*AuthOptions) CreateTlsConfiguration

func (opts *AuthOptions) CreateTlsConfiguration() (t *tls.Config)

func (*AuthOptions) InitSASLSCRAM

func (opts *AuthOptions) InitSASLSCRAM(conf *sarama.Config)

func (*AuthOptions) InitSSL

func (opts *AuthOptions) InitSSL(config *sarama.Config)

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithAuthentication

func WithAuthentication(authentication string) Option

func WithEnableSASL

func WithEnableSASL(enableSASL bool) Option

func WithEnableSSL

func WithEnableSSL(enableSSL bool) Option

func WithSASLPassword

func WithSASLPassword(saslPassword string) Option

func WithSASLUser

func WithSASLUser(saslUser string) Option

func WithSSLCaFile

func WithSSLCaFile(caFile string) Option

func WithSSLCertFile

func WithSSLCertFile(certFile string) Option

func WithSSLKeyFile

func WithSSLKeyFile(keyFile string) Option

func WithScramAlgorithm

func WithScramAlgorithm(scramAlgorithm string) Option

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)