pulsar

package

v0.1.5 Latest Latest Go to latest Published: May 13, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation ¶

Index ¶

Constants
Variables
func GetAdminClient() (cmdutils.Client, error)
func GetAdminV3Client() (cmdutils.Client, error)
func GetPulsarClient() (pulsar.Client, error)
func NewCurrentPulsarContext(pc PulsarContext, issuer *auth.Issuer, tokenStore *store.Store) error
func ResetCurrentPulsarContext()
type PulsarContext
- func (pc *PulsarContext) SetPulsarContext() error

Constants ¶

const (
	DefaultClientTimeout = 30 * time.Second
)

Variables ¶

View Source

var AdminClient cmdutils.Client

View Source

var AdminV3Client cmdutils.Client

View Source

var Client pulsar.Client

View Source

var CurrentPulsarClientOptions pulsar.ClientOptions

Functions ¶

func GetAdminClient ¶

func GetAdminClient() (cmdutils.Client, error)

func GetAdminV3Client ¶

func GetAdminV3Client() (cmdutils.Client, error)

func GetPulsarClient ¶

func GetPulsarClient() (pulsar.Client, error)

func NewCurrentPulsarContext ¶

func NewCurrentPulsarContext(pc PulsarContext, issuer *auth.Issuer, tokenStore *store.Store) error

func ResetCurrentPulsarContext ¶

func ResetCurrentPulsarContext()

Types ¶

type PulsarContext ¶

type PulsarContext struct {
	ServiceURL                    string
	WebServiceURL                 string
	Token                         string
	AuthPlugin                    string
	AuthParams                    string
	TLSAllowInsecureConnection    bool
	TLSEnableHostnameVerification bool
	TLSTrustCertsFilePath         string
	TLSCertFile                   string
	TLSKeyFile                    string
}

var CurrentPulsarContext PulsarContext

func (*PulsarContext) SetPulsarContext ¶

func (pc *PulsarContext) SetPulsarContext() error

Source Files ¶

View all Source files

connection.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL