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
}

func (*Connector) HandleConnectionError

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

func (*Connector) Run

func (c *Connector) Run() error

func (*Connector) Shutdown

func (c *Connector) Shutdown()

type RabbitToOpenFaaS

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

func New

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