pulsar

package
v0.0.42 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 11, 2022 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Pulsar

type Pulsar struct {
	Client        pulsar.Client
	Address       string
	Subscription  *string
	Topic         *string
	TopicsPattern *string
	Topics        []string
	AuthToken     *string
	AuthTokenFile *string
	AuthCertPath  *string
	AuthKeyPath   *string
	// TLS
	TLSTrustCertsFilePath      *string
	TLSAllowInsecureConnection *bool
	TLSValidateHostname        *bool
	// contains filtered or unexported fields
}

func (*Pulsar) Cleanup

func (d *Pulsar) Cleanup() error

func (*Pulsar) ClearWork

func (d *Pulsar) ClearWork() error

func (*Pulsar) GetWork

func (d *Pulsar) GetWork() (io.Reader, error)

func (*Pulsar) HandleFailure

func (d *Pulsar) HandleFailure() 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

Jump to

Keyboard shortcuts

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