auth

Documentation

Index

• Constants
• func GetDefaultTransport(config *common.Config) http.RoundTripper
• func MakeKeyringStore() (store.Store, error)
• type OAuth2Provider
  • func NewAuthenticationOAuth2(issuer oauth2.Issuer, store store.Store) (*OAuth2Provider, error)
  • func NewAuthenticationOAuth2WithParams(issueEndpoint, clientID, audience string, transport http.RoundTripper) (*OAuth2Provider, error)
  • func (o *OAuth2Provider) RoundTrip(req *http.Request) (*http.Response, error)
  • func (o *OAuth2Provider) Transport() http.RoundTripper
  • func (o *OAuth2Provider) WithTransport(tripper http.RoundTripper)
• type Provider
  • func GetAuthProvider(config *common.Config) (*Provider, error)
  • func NewAuthenticationOAuth2WithDefaultFlow(issuer oauth2.Issuer, keyFile string) (Provider, error)
• type TLSAuthProvider
  • func NewAuthenticationTLS(certificatePath string, privateKeyPath string, transport http.RoundTripper) (*TLSAuthProvider, error)
  • func NewAuthenticationTLSFromAuthParams(encodedAuthParams string, transport http.RoundTripper) (*TLSAuthProvider, error)
  • func (p *TLSAuthProvider) GetTLSCertificate() (*tls.Certificate, error)
  • func (p *TLSAuthProvider) RoundTrip(req *http.Request) (*http.Response, error)
  • func (p *TLSAuthProvider) Transport() http.RoundTripper
  • func (p *TLSAuthProvider) WithTransport(tripper http.RoundTripper)
• type TokenAuthProvider
  • func NewAuthenticationToken(token string, transport http.RoundTripper) (*TokenAuthProvider, error)
  • func NewAuthenticationTokenFromAuthParams(encodedAuthParam string, transport http.RoundTripper) (*TokenAuthProvider, error)
  • func NewAuthenticationTokenFromFile(tokenFilePath string, transport http.RoundTripper) (*TokenAuthProvider, error)
  • func (p *TokenAuthProvider) RoundTrip(req *http.Request) (*http.Response, error)
  • func (p *TokenAuthProvider) Transport() http.RoundTripper
  • func (p *TokenAuthProvider) WithTransport(tripper http.RoundTripper)
• type Transport

Constants

const (
	TypeClientCredential = "client_credentials"
	TypeDeviceCode       = "device_code"
)

const (
	TLSPluginName = "org.apache.pulsar.client.impl.auth.AuthenticationTls"
)

const (
	TokenPluginName = "org.apache.pulsar.client.impl.auth.AuthenticationToken"
)

Functions

func GetDefaultTransport

func GetDefaultTransport(config *common.Config) http.RoundTripper

func MakeKeyringStore

func MakeKeyringStore() (store.Store, error)

Types

type OAuth2Provider

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

func NewAuthenticationOAuth2

func NewAuthenticationOAuth2(issuer oauth2.Issuer, store store.Store) (*OAuth2Provider, error)

func NewAuthenticationOAuth2WithParams

func NewAuthenticationOAuth2WithParams(
	issueEndpoint,
	clientID,
	audience string,
	transport http.RoundTripper) (*OAuth2Provider, error)

func (*OAuth2Provider) RoundTrip

func (o *OAuth2Provider) RoundTrip(req *http.Request) (*http.Response, error)

func (*OAuth2Provider) Transport

func (o *OAuth2Provider) Transport() http.RoundTripper

func (*OAuth2Provider) WithTransport

func (o *OAuth2Provider) WithTransport(tripper http.RoundTripper)

type Provider

type Provider interface {
	RoundTrip(req *http.Request) (*http.Response, error)
	Transport() http.RoundTripper
	WithTransport(tripper http.RoundTripper)
}

Provider provide a general method to add auth message

func GetAuthProvider

func GetAuthProvider(config *common.Config) (*Provider, error)

func NewAuthenticationOAuth2WithDefaultFlow

func NewAuthenticationOAuth2WithDefaultFlow(issuer oauth2.Issuer, keyFile string) (Provider, error)

NewAuthenticationOAuth2WithDefaultFlow uses memory to save the grant

type TLSAuthProvider

type TLSAuthProvider struct {
	T http.RoundTripper
	// contains filtered or unexported fields
}

func NewAuthenticationTLS

func NewAuthenticationTLS(certificatePath string, privateKeyPath string,
	transport http.RoundTripper) (*TLSAuthProvider, error)

NewAuthenticationTLS initialize the authentication provider

func NewAuthenticationTLSFromAuthParams

func NewAuthenticationTLSFromAuthParams(encodedAuthParams string,
	transport http.RoundTripper) (*TLSAuthProvider, error)

func (*TLSAuthProvider) GetTLSCertificate

func (p *TLSAuthProvider) GetTLSCertificate() (*tls.Certificate, error)

func (*TLSAuthProvider) RoundTrip

func (p *TLSAuthProvider) RoundTrip(req *http.Request) (*http.Response, error)

func (*TLSAuthProvider) Transport

func (p *TLSAuthProvider) Transport() http.RoundTripper

func (*TLSAuthProvider) WithTransport

func (p *TLSAuthProvider) WithTransport(tripper http.RoundTripper)

type TokenAuthProvider

type TokenAuthProvider struct {
	T http.RoundTripper
	// contains filtered or unexported fields
}

func NewAuthenticationToken

func NewAuthenticationToken(token string, transport http.RoundTripper) (*TokenAuthProvider, error)

NewAuthenticationToken return a interface of Provider with a string token.

func NewAuthenticationTokenFromAuthParams

func NewAuthenticationTokenFromAuthParams(encodedAuthParam string,
	transport http.RoundTripper) (*TokenAuthProvider, error)

func NewAuthenticationTokenFromFile

func NewAuthenticationTokenFromFile(tokenFilePath string, transport http.RoundTripper) (*TokenAuthProvider, error)

NewAuthenticationTokenFromFile return a interface of a Provider with a string token file path.

func (*TokenAuthProvider) RoundTrip

func (p *TokenAuthProvider) RoundTrip(req *http.Request) (*http.Response, error)

func (*TokenAuthProvider) Transport

func (p *TokenAuthProvider) Transport() http.RoundTripper

func (*TokenAuthProvider) WithTransport

func (p *TokenAuthProvider) WithTransport(tripper http.RoundTripper)

type Transport

type Transport struct {
	T http.RoundTripper
}