auth

package

v0.4.0 Latest Latest Go to latest Published: Mar 24, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Details

View Source

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

View Source

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

This section is empty.

This section is empty.

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

Provider provide a general method to add auth message

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

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

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

NewAuthenticationTLS initialize the authentication provider

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

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

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

NewAuthenticationToken return a interface of Provider with a string token.

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

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

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

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

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

type Transport struct {
	T http.RoundTripper
}