utils

Documentation

Index

• func NewTokenProvider(clientID, clientSecret, tokenURL string) sarama.AccessTokenProvider
• type TokenProvider
  • func (t *TokenProvider) Token() (*sarama.AccessToken, error)

Functions

func NewTokenProvider

func NewTokenProvider(clientID, clientSecret, tokenURL string) sarama.AccessTokenProvider

Types

type TokenProvider

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

TokenProvider is a simple struct that implements sarama.AccessTokenProvider.

func (*TokenProvider) Token

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