pulsar

Documentation

Index

• type Pulsar
  • func (d *Pulsar) Cleanup() error
  • func (d *Pulsar) ClearWork() error
  • func (d *Pulsar) GetWork() (io.Reader, error)
  • func (d *Pulsar) HandleFailure() error
  • func (d *Pulsar) Init() error
  • func (d *Pulsar) LoadEnv(prefix string) error
  • func (d *Pulsar) LoadFlags() error

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
	AuthOAuthParams *map[string]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