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	string	The string 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 {
}

Factory comment

func (*Factory) NewManager

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

NewManager comment

func (*Factory) Type

func (*Factory) Type() string

Type comment

type PulsarConnection

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

PulsarConnection comment

func (*PulsarConnection) GetConnection

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

GetConnection comment

func (*PulsarConnection) ReleaseConnection

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

ReleaseConnection comment

func (*PulsarConnection) Start

func (p *PulsarConnection) Start() error

Start comment

func (*PulsarConnection) Stop

func (p *PulsarConnection) Stop() error

Stop comment

func (*PulsarConnection) Type

func (p *PulsarConnection) Type() string

Type comment

type Settings

type Settings struct {
	URL                  string `md:"url,required"`
	AthenzAuthentication string `md:"athenzauth"`
}

Settings comment