pulsar

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

type Session struct {
	Ctx             PulsarContext
	Client          pulsar.Client
	AdminClient     cmdutils.Client
	AdminV3Client   cmdutils.Client
	ClientOptions   pulsar.ClientOptions
	PulsarCtlConfig *cmdutils.ClusterConfig
	// contains filtered or unexported fields
}