kafka

Documentation

Index

• Variables
• func OAuthBearerTokenProvider(clientID, clientSecret, tokenURL string, scopes []string, ...) sarama.AccessTokenProvider
• type TokenProvider
  • func (t *TokenProvider) Token() (*sarama.AccessToken, error)
• 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

SHA256 hash generator function for SCRAM conversation

var SHA512 scram.HashGeneratorFcn = sha512.New

SHA512 hash generator function for SCRAM conversation

Functions

func OAuthBearerTokenProvider

func OAuthBearerTokenProvider(clientID, clientSecret, tokenURL string, scopes []string, extensions map[string]string) sarama.AccessTokenProvider

Types

type TokenProvider

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

func (*TokenProvider) Token

func (t *TokenProvider) Token() (*sarama.AccessToken, error)

type XDGSCRAMClient

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}

XDGSCRAMClient struct to perform SCRAM conversation

func (*XDGSCRAMClient) Begin

func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

Begin starts SCRAM conversation

func (*XDGSCRAMClient) Done

func (x *XDGSCRAMClient) Done() bool

Done completes SCRAM conversation

func (*XDGSCRAMClient) Step

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

Step performs step in SCRAM conversation