connection

README

Apache Pulsar Connection

This connection connects to apache pulsar.

Flogo CLI

flogo install github.com/project-flogo/messaging-contrib/pulsar/connection

Configuration

Settings:

Name	Type	Description
url	string	The url used to connect to pulsar - REQUIRED
athenzAuth	params	The params used for Athenz Authentication
certFile	string	The location of the certificate file used in TLS.
keyFile	string	The location of the key file used in TLS.

Documentation

Index

• type Factory
  • func (*Factory) NewManager(settings map[string]interface{}) (connection.Manager, error)
  • func (*Factory) Type() string
• type PulsarConnection
  • func (p *PulsarConnection) GetConnection() interface{}
  • func (p *PulsarConnection) ReleaseConnection(connection interface{})
  • func (p *PulsarConnection) Start() error
  • func (p *PulsarConnection) Stop() error
  • func (p *PulsarConnection) Type() string
• type Settings

Types

type Factory

type Factory struct {
}

func (*Factory) NewManager

func (*Factory) NewManager(settings map[string]interface{}) (connection.Manager, error)

func (*Factory) Type

func (*Factory) Type() string

type PulsarConnection

type PulsarConnection struct {
	// contains filtered or unexported fields
}

func (*PulsarConnection) GetConnection

func (p *PulsarConnection) GetConnection() interface{}

func (*PulsarConnection) ReleaseConnection

func (p *PulsarConnection) ReleaseConnection(connection interface{})

func (*PulsarConnection) Start

func (p *PulsarConnection) Start() error

func (*PulsarConnection) Stop

func (p *PulsarConnection) Stop() error

func (*PulsarConnection) Type

func (p *PulsarConnection) Type() string

type Settings

type Settings struct {
	URL                  string            `md:"url,required"`
	AthenzAuthentication map[string]string `md:"athenzAuth"`
	CertFile             string            `md:"certFile"`
	KeyFile              string            `md:"keyFile"`
}