mqs

Documentation

Index

• func AddProvider(p Provider)
• func New(mqURL string) (models.MessageQueue, error)
• type Mock
  • func (mock *Mock) Close() error
  • func (mock *Mock) Delete(context.Context, *models.Call) error
  • func (mock *Mock) Push(context.Context, *models.Call) (*models.Call, error)
  • func (mock *Mock) Reserve(context.Context) (*models.Call, error)
• type Provider

Functions

func AddProvider

func AddProvider(p Provider)

AddProvider registers a new global message queue provider

func New

func New(mqURL string) (models.MessageQueue, error)

New will parse the URL and return the correct MQ implementation.

Types

type Mock

type Mock struct {
	FakeApp *models.App
	Apps    []*models.App
}

func (*Mock) Close

func (mock *Mock) Close() error

func (*Mock) Delete

func (mock *Mock) Delete(context.Context, *models.Call) error

func (*Mock) Push

func (mock *Mock) Push(context.Context, *models.Call) (*models.Call, error)

func (*Mock) Reserve

func (mock *Mock) Reserve(context.Context) (*models.Call, error)

type Provider

type Provider interface {
	fmt.Stringer
	//Supports indicates if this provider can handle a specific URL scheme
	Supports(url *url.URL) bool
	//New creates a new message queue from a given URL
	New(url *url.URL) (models.MessageQueue, error)
}

Provider for message queue extensions