options

Documentation

Index

• type AuthenticationFlags
  • func (f *AuthenticationFlags) AddFlags(flags *flag.FlagSet)
  • func (f *AuthenticationFlags) ToAuthenticationProvider() (pulsar.Authentication, error)
  • func (f *AuthenticationFlags) Validate() error

Types

type AuthenticationFlags

type AuthenticationFlags struct {

	// custom authentication
	AuthPlugin string
	AuthParams string

	// TLS mutual authentication
	TLSCertFile string
	TLSKeyFile  string

	// token-based authentication
	Token     string
	TokenFile string

	// OAuth 2.0-based authentication
	Oauth2Issuer   string
	Oauth2ClientID string
	Oauth2Audience string
	Oauth2KeyFile  string
}

AuthenticationFlags defines common authentication flags for Pulsar.

func (*AuthenticationFlags) AddFlags

func (f *AuthenticationFlags) AddFlags(flags *flag.FlagSet)

func (*AuthenticationFlags) ToAuthenticationProvider

func (f *AuthenticationFlags) ToAuthenticationProvider() (pulsar.Authentication, error)

func (*AuthenticationFlags) Validate

func (f *AuthenticationFlags) Validate() error