connector

Documentation

Index

• type Connector
  • func (c *Connector) HandleConnectionError(ch <-chan *amqp.Error)
  • func (c *Connector) Run() error
  • func (c *Connector) Shutdown()
• type RabbitToOpenFaaS
  • func New(manager rabbitmq.Manager, factory rabbitmq.Factory, invoker types.Invoker, ...) RabbitToOpenFaaS

Types

type Connector

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

Connector includes all relevant information that the connector needs to hold and maintain

func (*Connector) HandleConnectionError

func (c *Connector) HandleConnectionError(ch <-chan *amqp.Error)

HandleConnectionError listens for incoming connection errors. If it is recoverable it will attempt a self-heal. Otherwise it shutsdown the whole connector

func (*Connector) Run

func (c *Connector) Run() error

Run starts the connector and creates a connection RabbitMQ. Further it implements the defined Topology. Also it adds a listener that handles connection failures.

func (*Connector) Shutdown

func (c *Connector) Shutdown()

Shutdown is usually called during graceful shutdown. It stops all exchanges and finally closes the connection to RabbitMQ

type RabbitToOpenFaaS

type RabbitToOpenFaaS interface {
	Run() error
	Shutdown()
}

RabbitToOpenFaaS defines the basic interactions for the connector

func New

func New(manager rabbitmq.Manager, factory rabbitmq.Factory, invoker types.Invoker, conf *config.Controller) RabbitToOpenFaaS

New creates a new connector instance using the provided parameters & config to build it up