client

Documentation

Index

• func NewAmqpConnector() connectors.Connector
• type AmqpConnector
  • func (c AmqpConnector) GetConnString(schema amqptype.Amqp) string
  • func (c AmqpConnector) Id() string
  • func (c AmqpConnector) Load(schema interface{}) (interface{}, error)
  • func (c AmqpConnector) Name() string
  • func (c AmqpConnector) Schema() interface{}
  • func (c AmqpConnector) Tags() []string

Functions

func NewAmqpConnector

func NewAmqpConnector() connectors.Connector

Types

type AmqpConnector

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

func (AmqpConnector) GetConnString

func (c AmqpConnector) GetConnString(schema amqptype.Amqp) string

func (AmqpConnector) Id

func (c AmqpConnector) Id() string

func (AmqpConnector) Load

func (c AmqpConnector) Load(schema interface{}) (interface{}, error)

func (AmqpConnector) Name

func (c AmqpConnector) Name() string

func (AmqpConnector) Schema

func (c AmqpConnector) Schema() interface{}

func (AmqpConnector) Tags

func (c AmqpConnector) Tags() []string