pulsar

Documentation

Index

• type Pulsar
  • func (d *Pulsar) Cleanup() error
  • func (d *Pulsar) Init() error
  • func (d *Pulsar) LoadEnv(prefix string) error
  • func (d *Pulsar) LoadFlags() error
  • func (d *Pulsar) Push(r io.Reader) error

Types

type Pulsar

type Pulsar struct {
	Client          pulsar.Client
	Address         string
	Topic           *string
	Name            *string
	AuthToken       *string
	AuthTokenFile   *string
	AuthCertPath    *string
	AuthKeyPath     *string
	AuthOAuthParams *map[string]string
	// TLS
	TLSTrustCertsFilePath      *string
	TLSAllowInsecureConnection *bool
	TLSValidateHostname        *bool
}

func (*Pulsar) Cleanup

func (d *Pulsar) Cleanup() error

func (*Pulsar) Init

func (d *Pulsar) Init() error

func (*Pulsar) LoadEnv

func (d *Pulsar) LoadEnv(prefix string) error

func (*Pulsar) LoadFlags

func (d *Pulsar) LoadFlags() error

func (*Pulsar) Push

func (d *Pulsar) Push(r io.Reader) error